org.apache.flink.table.runtime.operators.window

Class WindowOperatorBuilder

java.lang.Object

org.apache.flink.table.runtime.operators.window.WindowOperatorBuilder

public class WindowOperatorBuilder
extends Object

The WindowOperatorBuilder is used to build WindowOperator fluently.

Note: You have to call the aggregate method before the last build method.

 WindowOperatorBuilder
   .builder(KeyedStream)
   .tumble(Duration.ofMinutes(1))       // sliding(...), session(...)
   .withEventTime()     // withProcessingTime()
   .withAllowedLateness(Duration.ZERO)
   .produceUpdates()
   .aggregate(AggregationsFunction, accTypes, windowTypes)
   .build();
 

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	WindowOperatorBuilder.AggregateWindowOperatorBuilder The builder which is used to build AggregateWindowOperator fluently.
static class	WindowOperatorBuilder.TableAggregateWindowOperatorBuilder The builder which is used to build TableAggregateWindowOperator fluently.

Field Summary

Fields

Modifier and Type	Field and Description
protected LogicalType[]	accumulatorTypes
protected LogicalType[]	aggResultTypes
protected long	allowedLateness
protected LogicalType[]	inputFieldTypes
protected boolean	produceUpdates
protected int	rowtimeIndex
protected Trigger<?>	trigger
protected WindowAssigner<?>	windowAssigner
protected LogicalType[]	windowPropertyTypes

Constructor Summary

Constructors

Constructor and Description
WindowOperatorBuilder()

Method Summary

Modifier and Type	Method and Description
WindowOperatorBuilder.AggregateWindowOperatorBuilder	aggregate(GeneratedNamespaceAggsHandleFunction<?> generatedAggregateFunction, GeneratedRecordEqualiser generatedEqualiser, LogicalType[] accumulatorTypes, LogicalType[] aggResultTypes, LogicalType[] windowPropertyTypes)
WindowOperatorBuilder.TableAggregateWindowOperatorBuilder	aggregate(GeneratedNamespaceTableAggsHandleFunction<?> generatedTableAggregateFunction, LogicalType[] accumulatorTypes, LogicalType[] aggResultTypes, LogicalType[] windowPropertyTypes)
protected void	aggregate(LogicalType[] accumulatorTypes, LogicalType[] aggResultTypes, LogicalType[] windowPropertyTypes)
WindowOperatorBuilder.AggregateWindowOperatorBuilder	aggregate(NamespaceAggsHandleFunction<?> aggregateFunction, RecordEqualiser equaliser, LogicalType[] accumulatorTypes, LogicalType[] aggResultTypes, LogicalType[] windowPropertyTypes)
WindowOperatorBuilder.TableAggregateWindowOperatorBuilder	aggregate(NamespaceTableAggsHandleFunction<?> tableAggregateFunction, LogicalType[] accumulatorTypes, LogicalType[] aggResultTypes, LogicalType[] windowPropertyTypes)
WindowOperatorBuilder	assigner(WindowAssigner<?> windowAssigner)
static WindowOperatorBuilder	builder()
WindowOperatorBuilder	countWindow(long size)
WindowOperatorBuilder	countWindow(long size, long slide)
WindowOperatorBuilder	cumulative(java.time.Duration size, java.time.Duration step)
WindowOperatorBuilder	produceUpdates()
WindowOperatorBuilder	session(java.time.Duration sessionGap)
WindowOperatorBuilder	sliding(java.time.Duration size, java.time.Duration slide)
WindowOperatorBuilder	triggering(Trigger<?> trigger)
WindowOperatorBuilder	tumble(java.time.Duration size)
WindowOperatorBuilder	withAllowedLateness(java.time.Duration allowedLateness)
WindowOperatorBuilder	withEventTime(int rowtimeIndex)
WindowOperatorBuilder	withInputFields(LogicalType[] inputFieldTypes)
WindowOperatorBuilder	withProcessingTime()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

inputFieldTypes

protected LogicalType[] inputFieldTypes

windowAssigner

protected WindowAssigner<?> windowAssigner

trigger

protected Trigger<?> trigger

accumulatorTypes

protected LogicalType[] accumulatorTypes

aggResultTypes

protected LogicalType[] aggResultTypes

windowPropertyTypes

protected LogicalType[] windowPropertyTypes

allowedLateness

protected long allowedLateness

produceUpdates

protected boolean produceUpdates

rowtimeIndex

protected int rowtimeIndex

Constructor Detail

WindowOperatorBuilder

public WindowOperatorBuilder()

Method Detail

builder

public static WindowOperatorBuilder builder()

withInputFields

public WindowOperatorBuilder withInputFields(LogicalType[] inputFieldTypes)

tumble

public WindowOperatorBuilder tumble(java.time.Duration size)

sliding

public WindowOperatorBuilder sliding(java.time.Duration size,
                                     java.time.Duration slide)

cumulative

public WindowOperatorBuilder cumulative(java.time.Duration size,
                                        java.time.Duration step)

session

public WindowOperatorBuilder session(java.time.Duration sessionGap)

countWindow

public WindowOperatorBuilder countWindow(long size)

countWindow

public WindowOperatorBuilder countWindow(long size,
                                         long slide)

assigner

public WindowOperatorBuilder assigner(WindowAssigner<?> windowAssigner)

triggering

public WindowOperatorBuilder triggering(Trigger<?> trigger)

withEventTime

public WindowOperatorBuilder withEventTime(int rowtimeIndex)

withProcessingTime

public WindowOperatorBuilder withProcessingTime()

withAllowedLateness

public WindowOperatorBuilder withAllowedLateness(java.time.Duration allowedLateness)

produceUpdates

public WindowOperatorBuilder produceUpdates()

aggregate

protected void aggregate(LogicalType[] accumulatorTypes,
                         LogicalType[] aggResultTypes,
                         LogicalType[] windowPropertyTypes)

aggregate

public WindowOperatorBuilder.AggregateWindowOperatorBuilder aggregate(NamespaceAggsHandleFunction<?> aggregateFunction,
                                                                      RecordEqualiser equaliser,
                                                                      LogicalType[] accumulatorTypes,
                                                                      LogicalType[] aggResultTypes,
                                                                      LogicalType[] windowPropertyTypes)

aggregate

public WindowOperatorBuilder.AggregateWindowOperatorBuilder aggregate(GeneratedNamespaceAggsHandleFunction<?> generatedAggregateFunction,
                                                                      GeneratedRecordEqualiser generatedEqualiser,
                                                                      LogicalType[] accumulatorTypes,
                                                                      LogicalType[] aggResultTypes,
                                                                      LogicalType[] windowPropertyTypes)

aggregate

public WindowOperatorBuilder.TableAggregateWindowOperatorBuilder aggregate(NamespaceTableAggsHandleFunction<?> tableAggregateFunction,
                                                                           LogicalType[] accumulatorTypes,
                                                                           LogicalType[] aggResultTypes,
                                                                           LogicalType[] windowPropertyTypes)

aggregate

public WindowOperatorBuilder.TableAggregateWindowOperatorBuilder aggregate(GeneratedNamespaceTableAggsHandleFunction<?> generatedTableAggregateFunction,
                                                                           LogicalType[] accumulatorTypes,
                                                                           LogicalType[] aggResultTypes,
                                                                           LogicalType[] windowPropertyTypes)