Package | Description |
---|---|
org.apache.giraph.block_app.framework.piece.global_comm.array |
Interfaces representing arrays of individual handles.
|
org.apache.giraph.block_app.reducers.array |
Reducers for collecting arrays of objects.
|
org.apache.giraph.block_app.reducers.collect |
Reducers for distributed collection of objects.
|
Modifier and Type | Method and Description |
---|---|
BroadcastArrayHandle<R> |
ReducerArrayHandle.broadcastValue(BlockMasterApi master)
Broadcast whole array of reducers to master
|
Modifier and Type | Class and Description |
---|---|
static class |
ArrayOfHandles.ArrayOfBroadcasts<T>
BroadcastArrayHandle implemented as an array of separate broadcast handles.
|
Modifier and Type | Method and Description |
---|---|
static <V extends org.apache.hadoop.io.Writable> |
HugeArrayUtils.broadcast(int count,
Int2ObjFunction<V> valueSupplier,
BlockMasterApi master)
Broadcast a huge array, by splitting into NUM_STRIPES number of parts.
|
static <V extends org.apache.hadoop.io.Writable> |
HugeArrayUtils.broadcast(int count,
Int2ObjFunction<V> valueSupplier,
PrimitiveTypeOps<V> typeOps,
BlockMasterApi master)
Broadcast a huge array, by splitting into NUM_STRIPES number of parts.
|
BroadcastArrayHandle<R> |
ArrayOfHandles.ArrayOfReducers.broadcastValue(BlockMasterApi master) |
Modifier and Type | Field and Description |
---|---|
protected BroadcastArrayHandle<KryoWritableWrapper<R>> |
ShardedReducerHandle.ShardedBroadcastHandle.broadcasts |
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) |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.