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.AggregatorsBenchmarkMasterCompute
MasterCompute class for AggregatorsBenchmark
|
static class |
RandomMessageBenchmark.RandomMessageBenchmarkMasterCompute
Master compute associated with
RandomMessageBenchmark . |
static class |
ReducersBenchmark.ReducersBenchmarkMasterCompute
MasterCompute class for ReducersBenchmark
|
Modifier and Type | Interface and Description |
---|---|
interface |
BlockMasterApi
Block 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.AggregatorsTestMasterCompute
Master compute which uses aggregators.
|
static class |
PageRankWithKryoSimpleWritable.PageRankWithKryoMasterCompute
Master compute associated with
PageRankWithKryoSimpleWritable . |
class |
RandomWalkVertexMasterCompute
Master compute associated with
RandomWalkComputation . |
static class |
SimpleCheckpoint.SimpleCheckpointVertexMasterCompute
Master compute associated with
SimpleCheckpoint . |
static class |
SimpleMasterComputeComputation.SimpleMasterCompute
MasterCompute used with
SimpleMasterComputeComputation . |
static class |
SimplePageRankComputation.SimplePageRankMasterCompute
Master compute associated with
SimplePageRankComputation . |
static class |
VerifyMessage.VerifyMessageMasterCompute
Master compute associated with
VerifyMessage.VerifyMessageComputation . |
Modifier and Type | Class and Description |
---|---|
class |
SccPhaseMasterCompute
This master compute keeps track of what phase is being currently executed by
the Strongly Connected Components computation.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultMasterCompute
A dumb implementation of
MasterCompute . |
class |
MasterCompute
Interface for defining a master vertex that can perform centralized
computation between supersteps.
|
class |
MasterGlobalCommHandler
Handler for all master communications
|
Constructor and Description |
---|
AggregatorToGlobalCommTranslation(ImmutableClassesGiraphConfiguration<?,?,?> conf,
MasterGlobalCommUsage globalComm)
Constructor
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.