[streaming] Initial commit
[streaming] updated README
[streaming] Initial commit
[streaming] JobGraphBuilder refactor
[streaming] Begin implementing StreamSource object
[streaming] Source and Task interface updated
[streaming] StringRecord to Record migrate
[streaming] Ordered imports, migrated StringValues to IntValues and LongValues
[streaming] My stream refactored, JobGraphbuilder update
[streaming] UserTaskInvokable usage added to JobGraphBuilder
[streaming] Added UserSinkInvokable
[streaming] UserSinkInvokable fixed
[streaming] Automatically getting the number of input components in StreamTask
[streaming] Refactored the NumberOfInputs setting in JobGraphBuilder
[streaming] Refactor 2 of the NumberOfInputs setting in JobGraphBuilder
[streaming] Jobgraphbuilder connect update with partitioning
[streaming] Package naming refactor
[streaming] Added DefaultInvokable functionality
[streaming] Added DefaultInvokable functionality
[streaming] StreamSource and Task updated to support connection level partitioning