| Package | Description | 
|---|---|
| org.apache.giraph.benchmark | Package of benchmarks for performance testing and optimization | 
| org.apache.giraph.block_app.framework.api | Interfaces representing full API to the underlying graph processing system. | 
| org.apache.giraph.block_app.framework.api.giraph | Giraph implementation of graph processing system API used by
 Blocks Framework. | 
| 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.collect | Reducers for distributed collection of objects. | 
| org.apache.giraph.examples | Package of Giraph examples. | 
| org.apache.giraph.examples.scc | Classes for Strongly Connected Components computation. | 
| org.apache.giraph.master | Package of all the master related things. | 
| Modifier and Type | Class and Description | 
|---|---|
| static class  | AggregatorsBenchmark.AggregatorsBenchmarkMasterComputeMasterCompute class for AggregatorsBenchmark | 
| static class  | RandomMessageBenchmark.RandomMessageBenchmarkMasterComputeMaster compute associated with  RandomMessageBenchmark. | 
| static class  | ReducersBenchmark.ReducersBenchmarkMasterComputeMasterCompute class for ReducersBenchmark | 
| Modifier and Type | Interface and Description | 
|---|---|
| interface  | BlockMasterApiBlock computation API available for the master methods. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | BlockMasterCompute<S>MasterCompute class which executes block computation. | 
| Modifier and Type | Method and Description | 
|---|---|
| R | ReducerAndBroadcastWrapperHandle. getReducedValue(MasterGlobalCommUsage master)Get reduced value | 
| R | ReducerHandle. getReducedValue(MasterGlobalCommUsage master)Get reduced value | 
| Modifier and Type | Method and Description | 
|---|---|
| <S,R extends org.apache.hadoop.io.Writable> | ReducersForPieceHandler. createGlobalReducer(MasterGlobalCommUsage master,
                   ReduceOperation<S,R> reduceOp,
                   R globalInitialValue) | 
| <S,R extends org.apache.hadoop.io.Writable> | ReducersForPieceHandler. createLocalReducer(MasterGlobalCommUsage master,
                  ReduceOperation<S,R> reduceOp,
                  R globalInitialValue) | 
| R | ReducersForPieceHandler.ReduceHandleImpl. getReducedValue(MasterGlobalCommUsage master) | 
| Modifier and Type | Method and Description | 
|---|---|
| List<S> | CollectShardedReducerHandle. createReduceResult(MasterGlobalCommUsage master) | 
| List<WArrayList> | CollectShardedTuplesOfPrimitivesReducerHandle. createReduceResult(MasterGlobalCommUsage master) | 
| WArrayList<S> | CollectShardedPrimitiveReducerHandle. createReduceResult(MasterGlobalCommUsage master) | 
| R | ShardedReducerHandle. createReduceResult(MasterGlobalCommUsage master) | 
| List<WArrayList> | CollectShardedTuplesOfPrimitivesReducerHandle.CollectShardedTuplesOfPrimitivesReduceBroadcast. getReducedValue(MasterGlobalCommUsage master)Get reduced value | 
| R | ShardedReducerHandle. getReducedValue(MasterGlobalCommUsage master) | 
| Modifier and Type | Class and Description | 
|---|---|
| static class  | AggregatorsTestComputation.AggregatorsTestMasterComputeMaster compute which uses aggregators. | 
| static class  | PageRankWithKryoSimpleWritable.PageRankWithKryoMasterComputeMaster compute associated with  PageRankWithKryoSimpleWritable. | 
| class  | RandomWalkVertexMasterComputeMaster compute associated with  RandomWalkComputation. | 
| static class  | SimpleCheckpoint.SimpleCheckpointVertexMasterComputeMaster compute associated with  SimpleCheckpoint. | 
| static class  | SimpleMasterComputeComputation.SimpleMasterComputeMasterCompute used with  SimpleMasterComputeComputation. | 
| static class  | SimplePageRankComputation.SimplePageRankMasterComputeMaster compute associated with  SimplePageRankComputation. | 
| static class  | VerifyMessage.VerifyMessageMasterComputeMaster compute associated with  VerifyMessage.VerifyMessageComputation. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | SccPhaseMasterComputeThis master compute keeps track of what phase is being currently executed by
 the Strongly Connected Components computation. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | DefaultMasterComputeA dumb implementation of  MasterCompute. | 
| class  | MasterComputeInterface for defining a master vertex that can perform centralized
 computation between supersteps. | 
| class  | MasterGlobalCommHandlerHandler for all master communications | 
| Constructor and Description | 
|---|
| AggregatorToGlobalCommTranslation(ImmutableClassesGiraphConfiguration<?,?,?> conf,
                                 MasterGlobalCommUsage globalComm)Constructor | 
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.