T- Tuple type.
K- Key type.
public class PressureReliever<T,K> extends Pipe<T,T>
A window partition is maintained for each key seen on the input stream. Any tuple arriving on the input stream is inserted into the window. Asynchronously tuples are taken from the window using FIFO and submitted downstream. The submission of tuples maintains order within a partition but not across partitions.
Tuples are discarded and not submitted to the output port if the downstream processing cannot keep up the incoming tuple rate.
PressureRelieverup to last (most recent)
Ntuples are maintained in a window partition.
Insertion of the oplet into a stream disconnects the upstream processing from the downstream processing, so that downstream processing is executed on a different thread to the thread that processed the input tuple.
|Constructor and Description|
Pressure reliever that maintains up to
|Modifier and Type||Method and Description|
Apply the function to
Initialize the oplet.
getDestination, getInputs, start, submit
public void initialize(OpletContext<T,T> context)
public void accept(T tuple)
tuple- Value function is applied to.
public void close() throws java.lang.Exception
Copyright © 2017 The Apache Software Foundation. All Rights Reserved - 4744f56-20170226-1707