Class | Description |
---|---|
AggregateWindowOperator<K,W extends Window> |
A
WindowOperator for grouped window aggregates. |
CountWindow |
A
Window that represents a count window. |
CountWindow.Serializer |
The serializer used to write the CountWindow type.
|
CountWindow.Serializer.CountWindowSerializerSnapshot |
Serializer configuration snapshot for compatibility and format evolution.
|
TableAggregateWindowOperator<K,W extends Window> |
A
WindowOperator for grouped and windowed table aggregates. |
TimeWindow | |
TimeWindow.Serializer |
The serializer used to write the TimeWindow type.
|
TimeWindow.Serializer.TimeWindowSerializerSnapshot |
Serializer configuration snapshot for compatibility and format evolution.
|
Window |
A
Window is a grouping of elements into finite buckets. |
WindowOperator<K,W extends Window> |
An operator that implements the logic for windowing based on a
WindowAssigner and Trigger . |
WindowOperatorBuilder |
The
WindowOperatorBuilder is used to build WindowOperator fluently. |
WindowOperatorBuilder.AggregateWindowOperatorBuilder |
The builder which is used to build
AggregateWindowOperator fluently. |
WindowOperatorBuilder.TableAggregateWindowOperatorBuilder |
The builder which is used to build
TableAggregateWindowOperator fluently. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.