Skip to content
Permalink
Browse files
[FLINK-27271][python] Expose GroupWindow to users
  • Loading branch information
dianfu committed May 13, 2022
1 parent 3595a73 commit 80cd2ca5d7507776081a4161dea1568868f8cb17
Showing 2 changed files with 8 additions and 4 deletions.
@@ -83,6 +83,8 @@
A grouping of elements according to a time interval from start (inclusive) to end (exclusive).
- :class:`CountWindow`:
A grouping of elements according to element count from start (inclusive) to end (exclusive).
- :class:`GlobalWindow`:
The window into which all data is placed.
- :class:`WindowAssigner`:
Assigns zero or more :class:`Window` to an element.
- :class:`MergingWindowAssigner`:
@@ -211,7 +213,7 @@
from pyflink.datastream.functions import ProcessFunction
from pyflink.datastream.timerservice import TimerService
from pyflink.datastream.window import Window, TimeWindow, CountWindow, WindowAssigner, \
MergingWindowAssigner, TriggerResult, Trigger
MergingWindowAssigner, TriggerResult, Trigger, GlobalWindow
from pyflink.datastream.output_tag import OutputTag

__all__ = [
@@ -255,6 +257,7 @@
'Window',
'TimeWindow',
'CountWindow',
'GlobalWindow',
'WindowAssigner',
'MergingWindowAssigner',
'TriggerResult',
@@ -34,6 +34,7 @@
'TimeWindow',
'CountWindow',
'GlobalWindow',
'WindowAssigner',
'TumblingProcessingTimeWindows',
'TumblingEventTimeWindows',
'SlidingProcessingTimeWindows',
@@ -42,7 +43,7 @@
'EventTimeSessionWindows',
'DynamicProcessingTimeSessionWindows',
'DynamicEventTimeSessionWindows',
'WindowAssigner',
'GlobalWindows',
'MergingWindowAssigner',
'CountTumblingWindowAssigner',
'CountSlidingWindowAssigner',
@@ -57,8 +58,8 @@
'CountTrigger',
'TimeWindowSerializer',
'CountWindowSerializer',
'SessionWindowTimeGapExtractor',
'GlobalWindows']
'GlobalWindowSerializer',
'SessionWindowTimeGapExtractor']


def long_to_int_with_bit_mixing(x: int) -> int:

0 comments on commit 80cd2ca

Please sign in to comment.