streamsx.plumbing

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.

SPLDOC for the toolkit and its samples is at: http://ibmstreams.github.io/streamsx.plumbing/doc/spldoc/html/index.html