Package | Description |
---|---|
org.apache.giraph.block_app.reducers.collect |
Reducers for distributed collection of objects.
|
org.apache.giraph.reducers.impl |
Package of Giraph reducers.
|
Modifier and Type | Field and Description |
---|---|
protected BroadcastArrayHandle<KryoWritableWrapper<R>> |
ShardedReducerHandle.ShardedBroadcastHandle.broadcasts |
protected ArrayOfHandles.ArrayOfReducers<S,KryoWritableWrapper<R>> |
ShardedReducerHandle.reducers |
Modifier and Type | Method and Description |
---|---|
ReduceOperation<S,KryoWritableWrapper<List<S>>> |
CollectShardedReducerHandle.createReduceOperation() |
ReduceOperation<List<Object>,KryoWritableWrapper<List<WArrayList>>> |
CollectShardedTuplesOfPrimitivesReducerHandle.createReduceOperation() |
ReduceOperation<S,KryoWritableWrapper<WArrayList<S>>> |
CollectShardedPrimitiveReducerHandle.createReduceOperation() |
abstract ReduceOperation<S,KryoWritableWrapper<R>> |
ShardedReducerHandle.createReduceOperation() |
Modifier and Type | Method and Description |
---|---|
BroadcastHandle<List<S>> |
CollectShardedReducerHandle.createBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<List<S>>> broadcasts) |
BroadcastHandle<List<WArrayList>> |
CollectShardedTuplesOfPrimitivesReducerHandle.createBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<List<WArrayList>>> broadcasts) |
BroadcastHandle<R> |
ShardedReducerHandle.createBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<R>> broadcasts) |
BroadcastHandle<WArrayList<S>> |
CollectShardedPrimitiveReducerHandle.createBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<WArrayList<S>>> broadcasts) |
Constructor and Description |
---|
CollectShardedBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<List<S>>> broadcasts) |
CollectShardedPrimitiveBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<WArrayList<S>>> broadcasts) |
CollectShardedTuplesOfPrimitivesBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<List<WArrayList>>> broadcasts) |
ShardedBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<R>> broadcasts) |
Modifier and Type | Method and Description |
---|---|
KryoWritableWrapper<R> |
KryoWrappedReduceOperation.createInitialValue() |
KryoWritableWrapper<R> |
KryoWrappedReduceOperation.reduce(KryoWritableWrapper<R> wrapper,
S value) |
KryoWritableWrapper<R> |
KryoWrappedReduceOperation.reduceMerge(KryoWritableWrapper<R> wrapper,
KryoWritableWrapper<R> wrapperToReduce) |
Modifier and Type | Method and Description |
---|---|
KryoWritableWrapper<R> |
KryoWrappedReduceOperation.reduce(KryoWritableWrapper<R> wrapper,
S value) |
KryoWritableWrapper<R> |
KryoWrappedReduceOperation.reduceMerge(KryoWritableWrapper<R> wrapper,
KryoWritableWrapper<R> wrapperToReduce) |
KryoWritableWrapper<R> |
KryoWrappedReduceOperation.reduceMerge(KryoWritableWrapper<R> wrapper,
KryoWritableWrapper<R> wrapperToReduce) |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.