See: Description
Interface | Description |
---|---|
KeyMap.LazyFactory<V> |
A factory for lazy/on-demand instantiation of values.
|
KeyMap.TraversalEvaluator<K,V> |
A visitor for a traversal over the union of multiple hash maps.
|
MergingWindowSet.MergeFunction<W> |
Callback for
MergingWindowSet.addWindow(Window, MergeFunction) . |
Class | Description |
---|---|
EvictingWindowOperator<K,IN,OUT,W extends Window> |
A
WindowOperator that also allows an Evictor to be used. |
KeyMap<K,V> |
A special Hash Map implementation that can be traversed efficiently in sync with other
hash maps.
|
KeyMap.Entry<K,V> |
An entry in the hash table.
|
MergingWindowSet<W extends Window> |
Utility for keeping track of merging
Windows when using a
MergingWindowAssigner in a WindowOperator . |
TimestampedValue<T> |
Stores the value and the timestamp of the record.
|
WindowOperator<K,IN,ACC,OUT,W extends Window> |
An operator that implements the logic for windowing based on a
WindowAssigner and
Trigger . |
WindowOperator.Timer<K,W extends Window> |
Internal class for keeping track of in-flight timers.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.