Package | Description |
---|---|
org.apache.giraph.benchmark |
Package of benchmarks for performance testing and optimization
|
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.internal |
Implementation of execution logic, guiding internal execution of
Block Application.
|
org.apache.giraph.bsp |
Package of generic bulk synchronous processing objects.
|
org.apache.giraph.bsp.checkpoints |
Package of generic bulk synchronous processing objects.
|
org.apache.giraph.conf |
Package of Giraph configuration related things.
|
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 | Class and Description |
---|---|
class |
BlockMasterCompute<S>
MasterCompute class which executes block computation.
|
Modifier and Type | Method and Description |
---|---|
static <S> void |
BlockWorkerPieces.setNextWorkerPieces(MasterCompute master,
BlockWorkerPieces<S> nextWorkerPieces)
Sets which WorkerComputation is going to be executed in the next superstep.
|
Modifier and Type | Method and Description |
---|---|
MasterCompute |
CentralizedServiceMaster.getMasterCompute()
Get MasterCompute object
|
Modifier and Type | Method and Description |
---|---|
boolean |
DefaultCheckpointSupportedChecker.isCheckpointSupported(GiraphConfiguration conf,
MasterCompute masterCompute) |
boolean |
DisabledCheckpointSupportedChecker.isCheckpointSupported(GiraphConfiguration conf,
MasterCompute masterCompute) |
boolean |
CheckpointSupportedChecker.isCheckpointSupported(GiraphConfiguration conf,
MasterCompute masterCompute)
Does the job support checkpoints?
It is true by default, set it to false if your job uses some
non-checkpointable features:
- static variables for storing data between supersteps.
|
Modifier and Type | Field and Description |
---|---|
static ClassConfOption<MasterCompute> |
GiraphConstants.MASTER_COMPUTE_CLASS
Class for Master - optional
|
protected Class<? extends MasterCompute> |
GiraphClasses.masterComputeClass
Master compute class - cached for fast access
|
Modifier and Type | Method and Description |
---|---|
MasterCompute |
ImmutableClassesGiraphConfiguration.createMasterCompute()
Create a user master
|
Modifier and Type | Method and Description |
---|---|
Class<? extends MasterCompute> |
GiraphClasses.getMasterComputeClass()
Get MasterCompute used
|
Class<? extends MasterCompute> |
ImmutableClassesGiraphConfiguration.getMasterComputeClass()
Get the user's subclassed
MasterCompute |
Modifier and Type | Method and Description |
---|---|
GiraphClasses |
GiraphClasses.setMasterComputeClass(Class<? extends MasterCompute> masterComputeClass)
Set MasterCompute class used
|
void |
GiraphConfiguration.setMasterComputeClass(Class<? extends MasterCompute> masterComputeClass)
Set the master class (optional)
|
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 . |
Modifier and Type | Method and Description |
---|---|
MasterCompute |
BspServiceMaster.getMasterCompute() |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.