Namespace com.ibm.streamsx.plumbing.shedders

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

Load shedding operators. Load shedding operators provide the ability for SPL applications to temporarily discard tuples to reduce workload, for example an application may shed tuples in a low priority analytic flow to ensure high priority analytics have access to required cluster resources, during a peak in activity.

Operators

• ExpressionLoadShedder: Controllable load shedder that sheds (drops) tuples based upon evaluating an expression.
• RandomLoadShedder: Controllable load shedder that sheds (drops) tuples randomly.

Functions

• getExpressionShedderMode(rstring): Get the shedding mode for ExpressionLoadShedder operator invocations using control variable name.
• getRandomShedderFraction(rstring): Get the fraction of tuples being shed for RandomLoadShedder operator invocations using control variable name.
• registerExpressionShedder(rstring): Register that an operator invocation will call setExpressionShedderMode(rstring, boolean) or getExpressionShedderMode(rstring).
• registerRandomShedder(rstring): Register that an operator invocation will call setRandomShedderFraction(rstring, float64) or getRandomShedderFraction(rstring).
• setExpressionShedderMode(rstring, boolean): Set the shedding mode for ExpressionLoadShedder operator invocations using control variable name.
• setRandomShedderFraction(rstring, float64): Set the fraction of tuples to be shed for RandomLoadShedder operator invocations using control variable name.