stream.scotty.slicing

Class SlicingWindowOperator<InputType>

java.lang.Object

stream.scotty.slicing.SlicingWindowOperator<InputType>

Type Parameters:

InputType -

All Implemented Interfaces:

WindowOperator<InputType>, java.io.Serializable

public class SlicingWindowOperator<InputType>
extends java.lang.Object
implements WindowOperator<InputType>

Implementation of the slicing window operator based on the Scotty technique: Scotty: Efficient AbstractWindow Aggregation for out-of-order Stream Processing: Jonas Traub, Philipp M. Grulich, Alejandro Rodrıguez Cuéllar, Sebastian Breß, Asterios Katsifodimos, Tilmann Rabl, Volker Markl *

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
private SliceFactory<java.lang.Integer,java.lang.Integer>	sliceFactory
private SliceManager<InputType>	sliceManager
private StreamSlicer	slicer
private StateFactory	stateFactory
private WindowManager	windowManager

Constructor Summary

Constructors

Constructor and Description
SlicingWindowOperator(StateFactory stateFactory)

Method Summary

Modifier and Type	Method and Description
<OutputType> void	addAggregation(AggregateFunction<InputType,?,OutputType> windowFunction) Add a aggregation
void	addWindowAssigner(Window window) Add a window assigner to the window operator.
<Agg,OutputType> void	addWindowFunction(AggregateFunction<InputType,Agg,OutputType> windowFunction)
void	processElement(InputType element, long ts) Process a new element of the stream
java.util.List<AggregateWindow>	processWatermark(long watermarkTs) Process a watermark at a specific timestamp

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

stateFactory

private final StateFactory stateFactory

windowManager

private final WindowManager windowManager

sliceFactory

private final SliceFactory<java.lang.Integer,java.lang.Integer> sliceFactory

sliceManager

private final SliceManager<InputType> sliceManager

slicer

private final StreamSlicer slicer

Constructor Detail

SlicingWindowOperator

public SlicingWindowOperator(StateFactory stateFactory)

Method Detail

processElement

public void processElement(InputType element,
                           long ts)

Description copied from interface: WindowOperator

Process a new element of the stream

Specified by:

processElement in interface WindowOperator<InputType>

processWatermark

public java.util.List<AggregateWindow> processWatermark(long watermarkTs)

Description copied from interface: WindowOperator

Process a watermark at a specific timestamp

Specified by:

processWatermark in interface WindowOperator<InputType>

addWindowAssigner

public void addWindowAssigner(Window window)

Description copied from interface: WindowOperator

Add a window assigner to the window operator.

Specified by:

addWindowAssigner in interface WindowOperator<InputType>

addAggregation

public <OutputType> void addAggregation(AggregateFunction<InputType,?,OutputType> windowFunction)

Description copied from interface: WindowOperator

Add a aggregation

Specified by:

addAggregation in interface WindowOperator<InputType>

addWindowFunction

public <Agg,OutputType> void addWindowFunction(AggregateFunction<InputType,Agg,OutputType> windowFunction)