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

Interface RecordsCombiner.LocalFactory

All Superinterfaces:

Serializable

All Known Implementing Classes:

LocalAggCombiner.Factory

Enclosing interface:

RecordsCombiner

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public static interface RecordsCombiner.LocalFactory
extends Serializable

A factory that creates a RecordsCombiner used for combining at local stage.

Method Summary

Modifier and Type	Method and Description
RecordsCombiner	createRecordsCombiner(RuntimeContext runtimeContext, Collector<RowData> collector)

Method Detail

createRecordsCombiner

RecordsCombiner createRecordsCombiner(RuntimeContext runtimeContext,
                                      Collector<RowData> collector)
                               throws Exception

Throws:

Exception