@Public public class PythonWindowedStream<W extends Window> extends Object
WindowedStream
.
A PythonWindowedStream
represents a data stream where elements are grouped by
key, and for each key, the stream of elements is split into windows based on a
WindowAssigner
. Window emission
is triggered based on a Trigger
.
Modifier and Type | Method and Description |
---|---|
PythonSingleOutputStreamOperator |
apply(WindowFunction<org.python.core.PyObject,Object,Object,W> fun)
A thin wrapper layer over
WindowedStream.apply(WindowFunction) . |
PythonSingleOutputStreamOperator |
reduce(ReduceFunction<org.python.core.PyObject> fun)
A thin wrapper layer over
WindowedStream.reduce(org.apache.flink.api.common.functions.ReduceFunction) . |
public PythonSingleOutputStreamOperator reduce(ReduceFunction<org.python.core.PyObject> fun) throws IOException
WindowedStream.reduce(org.apache.flink.api.common.functions.ReduceFunction)
.fun
- The reduce function.IOException
public PythonSingleOutputStreamOperator apply(WindowFunction<org.python.core.PyObject,Object,Object,W> fun) throws IOException
WindowedStream.apply(WindowFunction)
.fun
- The window function.IOException
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.