Stream Processing ToolKit