| 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.CollectShardedPrimitiveBroadcastHandleBroadcast handle for CollectShardedPrimitiveReducerHandle | 
| class  | CollectShardedReducerHandle.CollectShardedBroadcastHandleBroadcastHandle for CollectShardedReducerHandle | 
| class  | CollectShardedTuplesOfPrimitivesReducerHandle.CollectShardedTuplesOfPrimitivesBroadcastHandleBroadcastHandle for CollectShardedTuplesOfPrimitivesReducerHandle | 
| class  | ShardedReducerHandle.ShardedBroadcastHandleBroadcast 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.