Package org.apache.flink.table.runtime.operators.window.groupwindow.operator

Class WindowOperatorBuilder.AggregateWindowOperatorBuilder

java.lang.Object

org.apache.flink.table.runtime.operators.window.groupwindow.operator.WindowOperatorBuilder.AggregateWindowOperatorBuilder

Enclosing class:

WindowOperatorBuilder

public static class WindowOperatorBuilder.AggregateWindowOperatorBuilder
extends Object

The builder which is used to build AggregateWindowOperator fluently.

Constructor Summary

Constructors

Constructor	Description
AggregateWindowOperatorBuilder(GeneratedNamespaceAggsHandleFunction<?> generatedAggregateFunction, GeneratedRecordEqualiser generatedEqualiser, WindowOperatorBuilder windowOperatorBuilder)
AggregateWindowOperatorBuilder(NamespaceAggsHandleFunction<?> aggregateFunction, RecordEqualiser equaliser, WindowOperatorBuilder windowOperatorBuilder)

Method Summary

Modifier and Type	Method	Description
AggregateWindowOperator	build()

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregateWindowOperatorBuilder

public AggregateWindowOperatorBuilder(GeneratedNamespaceAggsHandleFunction<?> generatedAggregateFunction,
                                      GeneratedRecordEqualiser generatedEqualiser,
                                      WindowOperatorBuilder windowOperatorBuilder)

AggregateWindowOperatorBuilder

public AggregateWindowOperatorBuilder(NamespaceAggsHandleFunction<?> aggregateFunction,
                                      RecordEqualiser equaliser,
                                      WindowOperatorBuilder windowOperatorBuilder)

Method Detail

build

public AggregateWindowOperator build()