Constructor and Description |
---|
MapReduceJobException(String stage,
Status status) |
Modifier and Type | Method and Description |
---|---|
void |
WorkerController.failed(Status status) |
void |
ReduceShardTask.jobCompleted(Status status) |
void |
MapShardTask.jobCompleted(Status status) |
void |
MapOnlyShardTask.jobCompleted(Status status) |
Modifier and Type | Method and Description |
---|---|
Status |
ResultAndStatus.getStatus() |
Constructor and Description |
---|
ResultAndStatus(MapReduceResult<R> result,
Status status) |
Modifier and Type | Method and Description |
---|---|
Status |
IncrementalTaskState.getStatus() |
Status |
ShardedJobState.getStatus()
Returns whether this job is running, finished, etc.
|
Modifier and Type | Method and Description |
---|---|
abstract void |
ShardedJobController.failed(Status status)
Called when the sharded job has failed to complete successfully.
|
void |
IncrementalTask.jobCompleted(Status status)
A job completed callback to allow resource cleanup and compaction of the finalized state.
|
Constructor and Description |
---|
FinalizeShardedJob(String jobId,
int taskCount,
Status status) |
Modifier and Type | Method and Description |
---|---|
void |
MergeShardTask.jobCompleted(Status status) |
void |
SortShardTask.jobCompleted(Status status) |
Copyright © 2015 Google. All rights reserved.