Modifier and Type | Class and 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.
|
Constructor and Description |
---|
KeyedMapBundleOperator(MapBundleFunction<K,V,IN,OUT> function,
BundleTrigger<IN> bundleTrigger) |
MapBundleOperator(MapBundleFunction<K,V,IN,OUT> function,
BundleTrigger<IN> bundleTrigger,
KeySelector<IN,K> keySelector) |
Modifier and Type | Class and Description |
---|---|
class |
MiniBatchDeduplicateKeepFirstRowFunction
This function is used to get the first row for every key partition in miniBatch mode.
|
class |
MiniBatchDeduplicateKeepLastRowFunction
This function is used to get the last row for every key partition in miniBatch mode.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.