| 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.