Modifier and Type | Method and Description |
---|---|
static WindowAssigner<TimeWindow> |
WindowTableFunctionUtil.createWindowAssigner(TimeAttributeWindowingStrategy windowingStrategy)
Creates window assigner based on input window strategy.
|
Modifier and Type | Method and Description |
---|---|
static <K,W extends Window> |
PythonStreamGroupWindowAggregateOperator.createSessionGroupWindowAggregateOperator(Configuration config,
RowType inputType,
RowType outputType,
PythonAggregateFunctionInfo[] aggregateFunctions,
DataViewSpec[][] dataViewSpecs,
int[] grouping,
int indexOfCountStar,
boolean generateUpdateBefore,
boolean countStarInserted,
int inputTimeFieldIndex,
WindowAssigner<W> windowAssigner,
boolean isRowTime,
long gap,
long allowedLateness,
NamedWindowProperty[] namedProperties,
java.time.ZoneId shiftTimeZone) |
static <K,W extends Window> |
PythonStreamGroupWindowAggregateOperator.createSlidingGroupWindowAggregateOperator(Configuration config,
RowType inputType,
RowType outputType,
PythonAggregateFunctionInfo[] aggregateFunctions,
DataViewSpec[][] dataViewSpecs,
int[] grouping,
int indexOfCountStar,
boolean generateUpdateBefore,
boolean countStarInserted,
int inputTimeFieldIndex,
WindowAssigner<W> windowAssigner,
boolean isRowTime,
boolean isTimeWindow,
long size,
long slide,
long allowedLateness,
NamedWindowProperty[] namedProperties,
java.time.ZoneId shiftTimeZone) |
static <K,W extends Window> |
PythonStreamGroupWindowAggregateOperator.createTumblingGroupWindowAggregateOperator(Configuration config,
RowType inputType,
RowType outputType,
PythonAggregateFunctionInfo[] aggregateFunctions,
DataViewSpec[][] dataViewSpecs,
int[] grouping,
int indexOfCountStar,
boolean generateUpdateBefore,
boolean countStarInserted,
int inputTimeFieldIndex,
WindowAssigner<W> windowAssigner,
boolean isRowTime,
boolean isTimeWindow,
long size,
long allowedLateness,
NamedWindowProperty[] namedProperties,
java.time.ZoneId shiftTimeZone) |
Constructor and Description |
---|
PythonStreamGroupWindowAggregateOperator(Configuration config,
RowType inputType,
RowType outputType,
PythonAggregateFunctionInfo[] aggregateFunctions,
DataViewSpec[][] dataViewSpecs,
int[] grouping,
int indexOfCountStar,
boolean generateUpdateBefore,
boolean countStarInserted,
int inputTimeFieldIndex,
WindowAssigner<W> windowAssigner,
FlinkFnApi.GroupWindow.WindowType windowType,
boolean isRowTime,
boolean isTimeWindow,
long size,
long slide,
long gap,
long allowedLateness,
NamedWindowProperty[] namedProperties,
java.time.ZoneId shiftTimeZone) |
Constructor and Description |
---|
StreamArrowPythonGroupWindowAggregateFunctionOperator(Configuration config,
PythonFunctionInfo[] pandasAggFunctions,
RowType inputType,
RowType udfInputType,
RowType udfOutputType,
int inputTimeFieldIndex,
WindowAssigner<W> windowAssigner,
Trigger<W> trigger,
long allowedLateness,
NamedWindowProperty[] namedProperties,
java.time.ZoneId shiftTimeZone,
GeneratedProjection generatedProjection) |
Modifier and Type | Field and Description |
---|---|
protected WindowAssigner<?> |
WindowOperatorBuilder.windowAssigner |
Modifier and Type | Method and Description |
---|---|
WindowOperatorBuilder |
WindowOperatorBuilder.assigner(WindowAssigner<?> windowAssigner) |
Constructor and Description |
---|
WindowTableFunctionOperator(WindowAssigner<TimeWindow> windowAssigner,
int rowtimeIndex,
java.time.ZoneId shiftTimeZone) |
Modifier and Type | Class and Description |
---|---|
class |
CountSlidingWindowAssigner
A
WindowAssigner that windows elements into sliding windows based on the count number of
the elements. |
class |
CountTumblingWindowAssigner
A
WindowAssigner that windows elements into fixed-size windows based on the count number
of the elements. |
class |
CumulativeWindowAssigner
A
WindowAssigner that windows elements into cumulative windows based on the timestamp of
the elements. |
class |
MergingWindowAssigner<W extends Window>
A
WindowAssigner that can merge windows. |
class |
PanedWindowAssigner<W extends Window>
A
WindowAssigner that window can be split into panes. |
class |
SessionWindowAssigner
A
WindowAssigner that windows elements into sessions based on the timestamp. |
class |
SlidingWindowAssigner
A
WindowAssigner that windows elements into sliding windows based on the timestamp of the
elements. |
class |
TumblingWindowAssigner
A
WindowAssigner that windows elements into fixed-size windows based on the timestamp of
the elements. |
Modifier and Type | Field and Description |
---|---|
protected WindowAssigner<W> |
InternalWindowProcessFunction.windowAssigner |
Constructor and Description |
---|
GeneralWindowProcessFunction(WindowAssigner<W> windowAssigner,
NamespaceAggsHandleFunctionBase<W> windowAggregator,
long allowedLateness) |
InternalWindowProcessFunction(WindowAssigner<W> windowAssigner,
NamespaceAggsHandleFunctionBase<W> windowAggregator,
long allowedLateness) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.