com.ibm.streamsx.plumbing > shedders 1.0.0 > com.ibm.streamsx.plumbing.sample.shedding > ExprShedderSample.spl
public composite ExpressionShedderSample { graph () as JCP = JobControlPlane() { } // DataFlow with controlled load shedding @spl_category(name = "data") () as DF = EDataFlow() { } // Flow that controls DataFlow // Note they are not connected using streams, // only indirectly through the control mechanisms // provided by JobControlPlane @spl_note(id = "0", text = "Flow that controls DataFlow by changing the shedding fraction every 30 seconds.") @spl_category(name = "control") () as CF = EControlFlow() { } }