stream.scotty.core

Interface WindowOperator<InputType>

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

SlicingWindowOperator

public interface WindowOperator<InputType>
extends java.io.Serializable

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.
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

Method Detail

processElement

void processElement(InputType element,
                    long ts)

Process a new element of the stream

processWatermark

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

Process a watermark at a specific timestamp

addWindowAssigner

void addWindowAssigner(Window window)

Add a window assigner to the window operator.

addAggregation

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

Add a aggregation

Parameters:

windowFunction -