Package org.apache.flink.table.runtime.operators.bundle

Class MapBundleFunction<K,V,IN,OUT>

java.lang.Object

org.apache.flink.table.runtime.operators.bundle.MapBundleFunction<K,V,IN,OUT>

Type Parameters:

K - The type of the key in the bundle map

V - The type of the value in the bundle map

IN - Type of the input elements.

OUT - Type of the returned elements.

All Implemented Interfaces:

Serializable, Function

Direct Known Subclasses:

MiniBatchGlobalGroupAggFunction, MiniBatchGroupAggFunction, MiniBatchIncrementalGroupAggFunction, MiniBatchLocalGroupAggFunction, ProcTimeMiniBatchDeduplicateKeepFirstRowFunction, ProcTimeMiniBatchDeduplicateKeepLastRowFunction, RowTimeMiniBatchDeduplicateFunction, RowTimeMiniBatchLatestChangeDeduplicateFunction

public abstract class MapBundleFunction<K,V,IN,OUT>
extends Object
implements Function

Basic interface for map bundle processing.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected ExecutionContext	ctx

Constructor Summary

Constructors

Constructor	Description
MapBundleFunction()

Method Summary

Modifier and Type	Method	Description
abstract V	addInput(V value, IN input)	Adds the given input to the given value, returning the new bundle value.
void	close()
abstract void	finishBundle(Map<K,V> buffer, Collector<OUT> out)	Called when a bundle is finished.
void	open(ExecutionContext ctx)

Methods inherited from class java.lang.Object

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

Field Detail

ctx

protected transient ExecutionContext ctx

Constructor Detail

MapBundleFunction

public MapBundleFunction()

Method Detail

open

public void open(ExecutionContext ctx)
          throws Exception

Throws:

Exception

addInput

public abstract V addInput(@Nullable
                           V value,
                           IN input)
                    throws Exception

Adds the given input to the given value, returning the new bundle value.

Parameters:

value - the existing bundle value, maybe null

input - the given input, not null

Throws:

Exception

finishBundle

public abstract void finishBundle(Map<K,V> buffer,
                                  Collector<OUT> out)
                           throws Exception

Called when a bundle is finished. Transform a bundle to zero, one, or more output elements.

Throws:

Exception

close

public void close()
           throws Exception

Throws:

Exception