SPL File replay.spl

com.ibm.streamsx.plumbing > com.ibm.streamsx.plumbing 1.0.0 > com.ibm.streamsx.plumbing.replay > replay.spl

Content

Operators

• ReplayBuffer: Replay tuple buffer.

Composites

composite ReplayBuffer(output Replayed; input In, Control)

Replay tuple buffer. Maintains a buffer of period seconds of tuples from In and replays all tuples in the buffer when a tuple is received on Control.

Parameters

• period: Seconds to maintain input tuples for.

Input Ports

• In: Stream to be buffered.
• Control: Control signal to replay tuples.

Output Ports

• Replayed: Output stream tuples in the buffer are submitted to.

SPL Source Code

 public composite ReplayBuffer(input In, Control ; output Replayed)
 {
 	param
 		expression<float64> $period ;
 	graph
 		(stream<In> Replayed) as Buffer = Join(In ; Control)
 		{
 			window
 				In : sliding, time($period) ;
 				Control : sliding, count(0) ;
 			param
 				match : true ;
 		}
 }