Package | Description |
---|---|
org.apache.flink.streaming.runtime.operators.windowing |
This package contains the operators that implement the various window operations
on data streams.
|
Modifier and Type | Field and Description |
---|---|
protected KeyMap<Key,Aggregate> |
AbstractKeyedTimePanes.latestPane
The latest time pane
|
Modifier and Type | Field and Description |
---|---|
protected ArrayDeque<KeyMap<Key,Aggregate>> |
AbstractKeyedTimePanes.previousPanes
The previous time panes, ordered by time (early to late)
|
Modifier and Type | Method and Description |
---|---|
static <K,V> void |
KeyMap.traverseMaps(KeyMap<K,V>[] maps,
KeyMap.TraversalEvaluator<K,V> visitor,
long touchedTag)
Performs a traversal about logical the multi-map that results from the union of the
given maps.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.