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

Class WindowOperatorBuilder.AggregateWindowOperatorBuilder

java.lang.Object

org.apache.flink.table.runtime.operators.window.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 and Description
AggregateWindowOperatorBuilder(GeneratedNamespaceAggsHandleFunction<?> generatedAggregateFunction, GeneratedRecordEqualiser generatedEqualiser, WindowOperatorBuilder windowOperatorBuilder)
AggregateWindowOperatorBuilder(NamespaceAggsHandleFunction<?> aggregateFunction, RecordEqualiser equaliser, WindowOperatorBuilder windowOperatorBuilder)

Method Summary

Modifier and Type	Method and 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()