Package | Description |
---|---|
org.apache.giraph.bsp |
Package of generic bulk synchronous processing objects.
|
org.apache.giraph.graph |
Package of all the graph related objects, built on the
org.apache.bsp package.
|
org.apache.giraph.job |
Package of all the classes involved in job launch.
|
org.apache.giraph.worker |
Package of all the worker related things
|
Modifier and Type | Method and Description |
---|---|
JobProgressTracker |
CentralizedService.getJobProgressTracker()
Get JobProgressTracker to report progress to
|
JobProgressTracker |
BspService.getJobProgressTracker() |
Modifier and Type | Interface and Description |
---|---|
interface |
JobProgressTrackerClient
Wrapper around JobProgressTracker which retries to connect and swallows
exceptions so app wouldn't crash if something goes wrong with progress
reports.
|
Modifier and Type | Class and Description |
---|---|
class |
JobProgressTrackerClientNoOp
Class to use for JobProgressTracker client when progress shouldn't be
tracked or something goes wrong
|
class |
RetryableJobProgressTrackerClient
Wrapper around JobProgressTracker which retries to connect and swallows
exceptions so app wouldn't crash if something goes wrong with progress
reports.
|
Modifier and Type | Method and Description |
---|---|
JobProgressTracker |
GraphTaskManager.getJobProgressTracker() |
Modifier and Type | Interface and Description |
---|---|
interface |
JobProgressTrackerService
Implementation of job progress tracker service on job client
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultJobProgressTrackerService
Default implementation of JobProgressTrackerService
|
Constructor and Description |
---|
WorkerProgressWriter(JobProgressTracker jobProgressTracker)
Constructor, starts separate thread to periodically update worker's
progress
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.