Package | Description |
---|---|
org.apache.giraph.conf |
Package of Giraph configuration related things.
|
org.apache.giraph.job |
Package of all the classes involved in job launch.
|
Modifier and Type | Field and Description |
---|---|
static ClassConfOption<GiraphJobObserver> |
GiraphConstants.JOB_OBSERVER_CLASS
Observer class to watch over job status - optional
|
Modifier and Type | Method and Description |
---|---|
GiraphJobObserver |
ImmutableClassesGiraphConfiguration.getJobObserver()
Create job observer
|
Modifier and Type | Method and Description |
---|---|
Class<? extends GiraphJobObserver> |
GiraphConfiguration.getJobObserverClass()
Get job observer class
|
Modifier and Type | Method and Description |
---|---|
void |
GiraphConfiguration.setJobObserverClass(Class<? extends GiraphJobObserver> klass)
Set job observer class
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultJobObserver
Default implementation of job observer that does nothing.
|
Modifier and Type | Method and Description |
---|---|
static JobProgressTrackerService |
DefaultJobProgressTrackerService.createJobProgressTrackerService(GiraphConfiguration conf,
GiraphJobObserver jobObserver)
Create job progress server on job client if enabled in configuration.
|
void |
DefaultJobProgressTrackerService.init(GiraphConfiguration conf,
GiraphJobObserver jobObserver) |
void |
JobProgressTrackerService.init(GiraphConfiguration conf,
GiraphJobObserver jobObserver)
Initialize the service
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.