Uses of Class
org.apache.flink.table.runtime.operators.window.WindowOperatorBuilder
-
Packages that use WindowOperatorBuilder Package Description org.apache.flink.table.runtime.operators.window -
-
Uses of WindowOperatorBuilder in org.apache.flink.table.runtime.operators.window
Methods in org.apache.flink.table.runtime.operators.window that return WindowOperatorBuilder Modifier and Type Method Description WindowOperatorBuilderWindowOperatorBuilder. assigner(WindowAssigner<?> windowAssigner)static WindowOperatorBuilderWindowOperatorBuilder. builder()WindowOperatorBuilderWindowOperatorBuilder. countWindow(long size)WindowOperatorBuilderWindowOperatorBuilder. countWindow(long size, long slide)WindowOperatorBuilderWindowOperatorBuilder. cumulative(java.time.Duration size, java.time.Duration step)WindowOperatorBuilderWindowOperatorBuilder. produceUpdates()WindowOperatorBuilderWindowOperatorBuilder. session(java.time.Duration sessionGap)WindowOperatorBuilderWindowOperatorBuilder. sliding(java.time.Duration size, java.time.Duration slide)WindowOperatorBuilderWindowOperatorBuilder. triggering(Trigger<?> trigger)WindowOperatorBuilderWindowOperatorBuilder. tumble(java.time.Duration size)WindowOperatorBuilderWindowOperatorBuilder. withAllowedLateness(java.time.Duration allowedLateness)WindowOperatorBuilderWindowOperatorBuilder. withEventTime(int rowtimeIndex)WindowOperatorBuilderWindowOperatorBuilder. withInputCountIndex(int inputCountIndex)The index of COUNT(*) in the aggregates.WindowOperatorBuilderWindowOperatorBuilder. withInputFields(org.apache.flink.table.types.logical.LogicalType[] inputFieldTypes)WindowOperatorBuilderWindowOperatorBuilder. withProcessingTime()WindowOperatorBuilderWindowOperatorBuilder. withShiftTimezone(java.time.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 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)
-