Uses of Class
org.apache.flink.table.runtime.operators.window.groupwindow.operator.WindowOperatorBuilder
-
Packages that use WindowOperatorBuilder Package Description org.apache.flink.table.runtime.operators.window.groupwindow.operator -
-
Uses of WindowOperatorBuilder in org.apache.flink.table.runtime.operators.window.groupwindow.operator
Methods in org.apache.flink.table.runtime.operators.window.groupwindow.operator that return WindowOperatorBuilder Modifier and Type Method Description WindowOperatorBuilderWindowOperatorBuilder. assigner(GroupWindowAssigner<?> windowAssigner)static WindowOperatorBuilderWindowOperatorBuilder. builder()WindowOperatorBuilderWindowOperatorBuilder. countWindow(long size)WindowOperatorBuilderWindowOperatorBuilder. countWindow(long size, long slide)WindowOperatorBuilderWindowOperatorBuilder. cumulative(Duration size, Duration step)WindowOperatorBuilderWindowOperatorBuilder. produceUpdates()WindowOperatorBuilderWindowOperatorBuilder. session(Duration sessionGap)WindowOperatorBuilderWindowOperatorBuilder. sliding(Duration size, Duration slide)WindowOperatorBuilderWindowOperatorBuilder. triggering(Trigger<?> trigger)WindowOperatorBuilderWindowOperatorBuilder. tumble(Duration size)WindowOperatorBuilderWindowOperatorBuilder. withAllowedLateness(Duration allowedLateness)WindowOperatorBuilderWindowOperatorBuilder. withEventTime(int rowtimeIndex)WindowOperatorBuilderWindowOperatorBuilder. withInputCountIndex(int inputCountIndex)The index of COUNT(*) in the aggregates. -1 when the input doesn't * contain COUNT(*), i.e.WindowOperatorBuilderWindowOperatorBuilder. withInputFields(org.apache.flink.table.types.logical.LogicalType[] inputFieldTypes)WindowOperatorBuilderWindowOperatorBuilder. withProcessingTime()WindowOperatorBuilderWindowOperatorBuilder. withShiftTimezone(ZoneId shiftTimeZone)The shift timezone of the window, if the proctime or rowtime type is TIMESTAMP_LTZ, the shift timezone is the timezone user configured in TableConfig, other cases the timezone is UTC which means never shift when assigning windows.Constructors in org.apache.flink.table.runtime.operators.window.groupwindow.operator with parameters of type WindowOperatorBuilder Constructor Description AggregateWindowOperatorBuilder(GeneratedNamespaceAggsHandleFunction<?> generatedAggregateFunction, GeneratedRecordEqualiser generatedEqualiser, WindowOperatorBuilder windowOperatorBuilder)AggregateWindowOperatorBuilder(NamespaceAggsHandleFunction<?> aggregateFunction, RecordEqualiser equaliser, WindowOperatorBuilder windowOperatorBuilder)TableAggregateWindowOperatorBuilder(GeneratedNamespaceTableAggsHandleFunction<?> generatedTableAggregateFunction, WindowOperatorBuilder windowOperatorBuilder)TableAggregateWindowOperatorBuilder(NamespaceTableAggsHandleFunction<?> tableAggregateFunction, WindowOperatorBuilder windowOperatorBuilder)
-