Functionality to control the flow of tuples in a Streams application.
- com.ibm.streamsx.plumbing.balancers - Load balancing operators.
- com.ibm.streamsx.plumbing.control - Functionality that utilizes the JobControlPlane operator to provide intra-job control mechanisms.
- com.ibm.streamsx.plumbing.leader - Leadership election functionality.
- com.ibm.streamsx.plumbing.sampling - Random sampling of a stream.
- com.ibm.streamsx.plumbing.shedders - Load shedding operators.
- com.ibm.streamsx.plumbing.switches - Switch operators.
- com.ibm.streamsx.plumbing.synchronize - Synchronization across streams.
- com.ibm.streamsx.plumbing.delay - Fine-grained user defined delaying of tuples. Created with own initiative and original intellectual ideas by: [email protected]
SPLDOC for the toolkit and its samples is at: http://ibmstreams.github.io/streamsx.plumbing/doc/spldoc/html/index.html