Uses of Class
org.apache.flink.table.runtime.operators.bundle.MapBundleFunction

Packages that use MapBundleFunction

Package	Description
org.apache.flink.table.runtime.operators.aggregate
org.apache.flink.table.runtime.operators.bundle
org.apache.flink.table.runtime.operators.deduplicate

Uses of MapBundleFunction in org.apache.flink.table.runtime.operators.aggregate

Subclasses of MapBundleFunction in org.apache.flink.table.runtime.operators.aggregate

Modifier and Type	Class	Description
class	MiniBatchGlobalGroupAggFunction	Aggregate Function used for the global groupby (without window) aggregate in miniBatch mode.
class	MiniBatchGroupAggFunction	Aggregate Function used for the groupby (without window) aggregate in miniBatch mode.
class	MiniBatchIncrementalGroupAggFunction	Aggregate Function used for the incremental groupby (without window) aggregate in miniBatch mode.
class	MiniBatchLocalGroupAggFunction	Aggregate Function used for the local groupby (without window) aggregate in miniBatch mode.

Uses of MapBundleFunction in org.apache.flink.table.runtime.operators.bundle

Constructors in org.apache.flink.table.runtime.operators.bundle with parameters of type MapBundleFunction

Constructor	Description
KeyedMapBundleOperator(MapBundleFunction<K,V,IN,OUT> function, BundleTrigger<IN> bundleTrigger)
MapBundleOperator(MapBundleFunction<K,V,IN,OUT> function, BundleTrigger<IN> bundleTrigger, org.apache.flink.api.java.functions.KeySelector<IN,K> keySelector)

Uses of MapBundleFunction in org.apache.flink.table.runtime.operators.deduplicate

Subclasses of MapBundleFunction in org.apache.flink.table.runtime.operators.deduplicate

Modifier and Type	Class	Description
class	ProcTimeMiniBatchDeduplicateKeepFirstRowFunction	This function is used to get the first row for every key partition in miniBatch mode.
class	ProcTimeMiniBatchDeduplicateKeepLastRowFunction	This function is used to get the last row for every key partition in miniBatch mode.
class	RowTimeMiniBatchDeduplicateFunction	This function is used to get the first or last row for every key partition in miniBatch mode.
class	RowTimeMiniBatchLatestChangeDeduplicateFunction	This function is used to get the first or last row for every key partition in miniBatch mode.