Package | Description |
---|---|
org.apache.giraph.benchmark |
Package of benchmarks for performance testing and optimization
|
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.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 | 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 |
---|---|
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.