org.apache.flink.streaming.runtime.operators.windowing

Class AbstractKeyedTimePanes<Type,Key,Aggregate,Result>

java.lang.Object

org.apache.flink.streaming.runtime.operators.windowing.AbstractKeyedTimePanes<Type,Key,Aggregate,Result>

Direct Known Subclasses:

AccumulatingKeyedTimePanes, AggregatingKeyedTimePanes

@Internal
public abstract class AbstractKeyedTimePanes<Type,Key,Aggregate,Result>
extends Object

Base class for a multiple key/value maps organized in panes.

Field Summary

Fields

Modifier and Type	Field and Description
protected KeyMap<Key,Aggregate>	latestPane The latest time pane
protected ArrayDeque<KeyMap<Key,Aggregate>>	previousPanes The previous time panes, ordered by time (early to late)

Constructor Summary

Constructors

Constructor and Description
AbstractKeyedTimePanes()

Method Summary

Modifier and Type	Method and Description
abstract void	addElementToLatestPane(Type element)
void	dispose()
abstract void	evaluateWindow(Collector<Result> out, TimeWindow window, AbstractStreamOperator<Result> operator)
int	getNumPanes()
void	readFromInput(DataInputView input, TypeSerializer<Key> keySerializer, TypeSerializer<Aggregate> aggSerializer)
void	slidePanes(int panesToKeep)
protected void	traverseAllPanes(KeyMap.TraversalEvaluator<Key,Aggregate> traversal, long traversalPass)
void	truncatePanes(int numToRetain)
void	writeToOutput(DataOutputView output, TypeSerializer<Key> keySerializer, TypeSerializer<Aggregate> aggSerializer)

Methods inherited from class java.lang.Object

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

Field Detail

latestPane

protected KeyMap<Key,Aggregate> latestPane

The latest time pane

previousPanes

protected final ArrayDeque<KeyMap<Key,Aggregate>> previousPanes

The previous time panes, ordered by time (early to late)

Constructor Detail

AbstractKeyedTimePanes

public AbstractKeyedTimePanes()

Method Detail

addElementToLatestPane

public abstract void addElementToLatestPane(Type element)
                                     throws Exception

Throws:

Exception

evaluateWindow

public abstract void evaluateWindow(Collector<Result> out,
                                    TimeWindow window,
                                    AbstractStreamOperator<Result> operator)
                             throws Exception

Throws:

Exception

dispose

public void dispose()

getNumPanes

public int getNumPanes()

slidePanes

public void slidePanes(int panesToKeep)

truncatePanes

public void truncatePanes(int numToRetain)

traverseAllPanes

protected void traverseAllPanes(KeyMap.TraversalEvaluator<Key,Aggregate> traversal,
                                long traversalPass)
                         throws Exception

Throws:

Exception

writeToOutput

public void writeToOutput(DataOutputView output,
                          TypeSerializer<Key> keySerializer,
                          TypeSerializer<Aggregate> aggSerializer)
                   throws IOException

Throws:

IOException

readFromInput

public void readFromInput(DataInputView input,
                          TypeSerializer<Key> keySerializer,
                          TypeSerializer<Aggregate> aggSerializer)
                   throws IOException

Throws:

IOException