Package | Description |
---|---|
org.apache.flink.streaming.python.api.datastream |
Modifier and Type | Method and Description |
---|---|
PythonWindowedStream |
PythonKeyedStream.count_window(long size,
long slide)
A thin wrapper layer over
KeyedStream.countWindow(long, long) . |
PythonWindowedStream |
PythonKeyedStream.time_window(Time size)
A thin wrapper layer over
KeyedStream.timeWindow(Time) . |
PythonWindowedStream |
PythonKeyedStream.time_window(Time size,
Time slide)
A thin wrapper layer over
KeyedStream.timeWindow(Time, Time) . |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.