Package | Description |
---|---|
org.apache.giraph.block_app.framework.api |
Interfaces representing full API to the underlying graph processing system.
|
org.apache.giraph.block_app.framework.piece.global_comm |
Interfaces for Reducer and Broadcast Handles for automatic handling
of global communication within Pieces, hiding a lot of it's complexities.
|
org.apache.giraph.block_app.framework.piece.global_comm.internal |
Reducer and Broadcast Handles internal implementation for automatic handling
of global communication within Pieces, hiding a lot of it's complexities.
|
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 |
---|---|
<T extends org.apache.hadoop.io.Writable> |
BlockMasterApi.broadcast(T value)
Broadcast given value to all workers for next computation.
|
Modifier and Type | Method and Description |
---|---|
BroadcastHandle<R> |
ReducerHandle.broadcastValue(BlockMasterApi master)
Broadcast reduced value from master
|
Modifier and Type | Class and Description |
---|---|
static class |
ReducersForPieceHandler.BroadcastHandleImpl<T>
Implementation of BroadcastHandle
|
Modifier and Type | Method and Description |
---|---|
BroadcastHandle<R> |
ReducersForPieceHandler.ReduceHandleImpl.broadcastValue(BlockMasterApi master) |
Constructor and Description |
---|
ArrayOfBroadcasts(int count,
Int2ObjFunction<BroadcastHandle<T>> broadcastHandleFactory) |
ArrayOfBroadcasts(int count,
Supplier<BroadcastHandle<T>> broadcastHandleFactory) |
Modifier and Type | Class and Description |
---|---|
class |
CollectShardedPrimitiveReducerHandle.CollectShardedPrimitiveBroadcastHandle
Broadcast handle for CollectShardedPrimitiveReducerHandle
|
class |
CollectShardedReducerHandle.CollectShardedBroadcastHandle
BroadcastHandle for CollectShardedReducerHandle
|
class |
CollectShardedTuplesOfPrimitivesReducerHandle.CollectShardedTuplesOfPrimitivesBroadcastHandle
BroadcastHandle for CollectShardedTuplesOfPrimitivesReducerHandle
|
class |
ShardedReducerHandle.ShardedBroadcastHandle
Broadcast for ShardedReducerHandle
|
Modifier and Type | Method and Description |
---|---|
BroadcastHandle<R> |
ShardedReducerHandle.broadcastValue(BlockMasterApi masterApi) |
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) |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.