Operators
- Changeover
- Changeover switch.
- ControlVariableChange
- Control variable change notifications.
- ControlledChangeover
- Controlled changeover switch.
- ControlledSwitch
- Controlled switch.
- 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.
- KeyedDelay
- The KeyedDelay operator is used to delay the incoming tuples for a configured amount of seconds before sending them out for downstream processing.
- 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.
- ReplayBuffer
- Replay tuple buffer.
- Synchronize
- The Synchronize operator synchronizes the flow of tuples across multiple streams according to timestamps in the tuples.
- TraceLevelSwitch
- Non-blocking switch set by application trace level.
- ZnodeAction
- Take an action against a znode path for each tuple.