Operators: com.ibm.streamsx.plumbing

com.ibm.streamsx.plumbing > Operators

Operators

ActiveReplicasLeader: Active replica flow as a single job with leadership election.
ActiveReplicasManual2: Execution of two copies of Flow() to provide a single level of redundancy.
ActiveReplicasManual3: Execution of three copies of Flow() to provide two levels of redundancy.
ActiveReplicasManual3DeDup: Example application demonstrating use of redundant flows and de-duplicators, with leadership election using ZooKeeper.
ActiveReplicasUDP: Execution of redundant copies of Flow() using @parallel.
Analytics: The "analytics" portion of the application including the source.
Changeover: Changeover switch.
ChangeoverDataFlow: The data flow that will demonstrate use of ControlledSwitch.
ControlFlow: The flow that controls DataFlow in ControlledSwitchSample.
ControlVariableChange: Control variable change notifications.
ControlledChangeover: Controlled changeover switch.
ControlledChangeoverSample: Sample showing use of com.ibm.streamsx.plumbing.switches::ControlledChangeover.
ControlledSwitch: Controlled switch.
ControlledSwitchSample: Sample showing use of com.ibm.streamsx.plumbing.switches::ControlledSwitch.
DataFlow: The data flow that will demonstrate use of ControlledSwitch.
ElasticLoadBalance: This operator distributes tuples to the output ports that have the capacity to receive them.
ExpressionLoadShedder: Controllable load shedder that sheds (drops) tuples based upon evaluating an expression.
ExpressionShedderSample
Flow: Simple flow to be executed multiple times to provide redundant copies.
KeyedDelay: The KeyedDelay operator is used to delay the incoming tuples for a configured amount of seconds before sending them out for downstream processing.
KeyedDelayTest
LeadershipChangeover: Changeover switch that changes state based upon if the PE is marked as the leader of group.
LeadershipElection: Performs a leadership election between other operator invocations with the same group.
LeadershipSwitchWithReplay: Switch operator that only generates output when its PE is the leader of the group.
RandomLoadShedder: Controllable load shedder that sheds (drops) tuples randomly.
RandomSample: Randomly sample a stream.
RandomShedderFailureSample: Sample application that can be used to demonstrate recovery from failure for com.ibm.streamsx.plumbing.shedders::RandomLoadShedder.
RandomShedderSample
ReplayBuffer: Replay tuple buffer.
SendSMS: The sink of the application.
Source
SourceAnalyticsFlow
Synchronize: The Synchronize operator synchronizes the flow of tuples across multiple streams according to timestamps in the tuples.
SynchronizeThreeStreams: This sample application for the Synchronize operator reads three pre-recorded streams from three files.
SynchronizeTwoStreams: This sample application for the Synchronize operator reads a pair of streams from files.
SynchronizeTwoStreamsWithPunctuation: This sample application for the Synchronize operator reads a pair of streams from three pairs of files.
TraceLevelSwitch: Non-blocking switch set by application trace level.
ZnodeAction: Take an action against a znode path for each tuple.