Toolkit com.ibm.streamsx.plumbing 1.0.0

com.ibm.streamsx.plumbing > com.ibm.streamsx.plumbing 1.0.0

General Information

Plumbing operators manipulate the flow of tuples in a Streams application, but are not part of the logic of the application.

Version

1.0.0

Required Product Version

4.0.1.0

Author

IBMStreams Open Source Community at GitHub - https://github.com/IBMStreams/streamsx.plumbing

Indexes

Namespaces

Operators

Functions

Types

Namespaces

com.ibm.streamsx.plumbing.balancers

Load balancing operators.

Operators

• ElasticLoadBalance

com.ibm.streamsx.plumbing.control

Functionality that utilizes the JobControlPlane operator to provide intra-job control mechanisms.

Operators

• ControlVariableChange

Functions

• createBooleanControlVariable(T, boolean, boolean)
• createFloat64ControlVariable(T, boolean, float64)
• getBooleanControlVariable(T)
• getControlVariableObjectName(rstring)
• getFloat64ControlVariable(T)
• setBooleanControlVariable(T, boolean)
• setFloat64ControlVariable(T, float64)

com.ibm.streamsx.plumbing.delay

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

Operators

• KeyedDelay

com.ibm.streamsx.plumbing.leader

Leadership election functionality.

Operators

• LeadershipChangeover
• LeadershipElection
• LeadershipSwitchWithReplay

Types

• LeaderStatus

com.ibm.streamsx.plumbing.replay

Replay buffer for streams.

Operators

• ReplayBuffer

com.ibm.streamsx.plumbing.sampling

Random sampling of a stream.

Operators

• RandomSample

Functions

• percent(float64)

com.ibm.streamsx.plumbing.shedders

Load shedding operators.

Operators

• ExpressionLoadShedder
• RandomLoadShedder

Functions

• getExpressionShedderMode(rstring)
• getRandomShedderFraction(rstring)
• registerExpressionShedder(rstring)
• registerRandomShedder(rstring)
• setExpressionShedderMode(rstring, boolean)
• setRandomShedderFraction(rstring, float64)

com.ibm.streamsx.plumbing.switches

Switch operators.

Operators

• Changeover
• ControlledChangeover
• ControlledSwitch
• TraceLevelSwitch

Functions

• getSwitchState(rstring)
• registerSwitch(rstring, boolean)
• setSwitchState(rstring, boolean)

com.ibm.streamsx.plumbing.synchronize

Synchronization across streams.

Operators

• Synchronize

com.ibm.streamsx.plumbing.zookeeper

Operators

• ZnodeAction