See: Description
Class | Description |
---|---|
CollectPrimitiveReduceOperation<S> |
Collect primitive values reduce operation
|
CollectReduceOperation<S> |
Collect values reduce operation
|
CollectShardedPrimitiveReducerHandle<S> |
ShardedReducerHandle where we keep a list of reduced values,
when primitives are used
|
CollectShardedReducerHandle<S> |
ShardedReducerHandle where we keep a list of reduced values
|
CollectShardedTuplesOfPrimitivesReducerHandle |
ShardedReducerHandle where we keep a list of reduced values,
and values consist of multiple primitives, so we keep one primitive
list for each
|
CollectShardedTuplesOfPrimitivesReducerHandle.CollectShardedTuplesOfPrimitivesReduceBroadcast |
Reduce broadcast wrapper
|
CollectTuplesOfPrimitivesReduceOperation |
Collect tuples of primitive values reduce operation
|
ShardedReducerHandle<S,R> |
Reducing values into a list of reducers, randomly,
and getting the results of all reducers together
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.