public class ExecutionGraphHandler extends Object
ExecutionGraph
which offers some common operations.Constructor and Description |
---|
ExecutionGraphHandler(ExecutionGraph executionGraph,
org.slf4j.Logger log,
Executor ioExecutor,
ComponentMainThreadExecutor mainThreadExecutor) |
Modifier and Type | Method and Description |
---|---|
void |
acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics,
TaskStateSnapshot checkpointState) |
void |
declineCheckpoint(DeclineCheckpoint decline) |
void |
reportCheckpointMetrics(ExecutionAttemptID attemptId,
long id,
CheckpointMetrics metrics) |
void |
reportInitializationMetrics(SubTaskInitializationMetrics initializationMetrics) |
SerializedInputSplit |
requestNextInputSplit(JobVertexID vertexID,
ExecutionAttemptID executionAttempt) |
ExecutionState |
requestPartitionState(IntermediateDataSetID intermediateResultId,
ResultPartitionID resultPartitionId) |
public ExecutionGraphHandler(ExecutionGraph executionGraph, org.slf4j.Logger log, Executor ioExecutor, ComponentMainThreadExecutor mainThreadExecutor)
public void reportCheckpointMetrics(ExecutionAttemptID attemptId, long id, CheckpointMetrics metrics)
public void reportInitializationMetrics(SubTaskInitializationMetrics initializationMetrics)
public void acknowledgeCheckpoint(JobID jobID, ExecutionAttemptID executionAttemptID, long checkpointId, CheckpointMetrics checkpointMetrics, TaskStateSnapshot checkpointState)
public void declineCheckpoint(DeclineCheckpoint decline)
public ExecutionState requestPartitionState(IntermediateDataSetID intermediateResultId, ResultPartitionID resultPartitionId) throws PartitionProducerDisposedException
public SerializedInputSplit requestNextInputSplit(JobVertexID vertexID, ExecutionAttemptID executionAttempt) throws IOException
IOException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.