KEY
- The key type.W
- The window type.IN
- The type stored in state.public class PassThroughReader<KEY,W extends Window,IN> extends WindowReaderFunction<IN,IN,KEY,W>
WindowReaderFunction
that just emits each input element.WindowReaderFunction.Context<W extends Window>
Constructor and Description |
---|
PassThroughReader() |
Modifier and Type | Method and Description |
---|---|
void |
readWindow(KEY key,
WindowReaderFunction.Context<W> context,
Iterable<IN> elements,
Collector<IN> out)
Evaluates the window and outputs none or several elements.
|
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
open
public void readWindow(KEY key, WindowReaderFunction.Context<W> context, Iterable<IN> elements, Collector<IN> out)
WindowReaderFunction
readWindow
in class WindowReaderFunction<IN,IN,KEY,W extends Window>
key
- The key for which this window is evaluated.context
- The context in which the window is being evaluated.elements
- The elements in the window being evaluated.out
- A collector for emitting elements.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.