UserTaskInvokable usage added to JobGraphBuilder
Added UserSinkInvokable
UserSinkInvokable fixed
Automatically getting the number of input components in StreamTask
Refactored the NumberOfInputs setting in JobGraphBuilder
Refactor 2 of the NumberOfInputs setting in JobGraphBuilder
Jobgraphbuilder connect update with partitioning
Package naming refactor
Added DefaultInvokable functionality
Added DefaultInvokable functionality
StreamSource and Task updated to support connection level partitioning
merge resolved
Apache Licensing added
Stream classes refactor
StreamInvokable class added, updated UserInvokables
test case update
ShufflePartitioner Concept added
Merge branch 'master' of https://github.com/stratosphere/stratosphere-streaming
Started implementing FlatStreamTask
Started implementing FlatStreamTask