Namespaces: com.ibm.streamsx.plumbing

com.ibm.streamsx.plumbing > Namespaces

Namespaces

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.delay

Hold the incoming tuples for a specified time before sending them out.

com.ibm.streamsx.plumbing.leader

Leadership election functionality.

com.ibm.streamsx.plumbing.replay

Replay buffer for streams.

com.ibm.streamsx.plumbing.sample.delay

com.ibm.streamsx.plumbing.sample.redundant.active

Sample applications demonstrating redundant active flows.

com.ibm.streamsx.plumbing.sample.redundant.flow

com.ibm.streamsx.plumbing.sample.shedding

com.ibm.streamsx.plumbing.sample.switches

com.ibm.streamsx.plumbing.sample.synchronize

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.zookeeper