Modifier and Type | Method and Description |
---|---|
boolean |
CheckpointCoordinator.restoreLatestCheckpointedState(Map<JobVertexID,ExecutionJobVertex> tasks,
boolean errorIfNoCheckpoint,
boolean allOrNothingState) |
Modifier and Type | Method and Description |
---|---|
void |
SavepointCoordinator.restoreSavepoint(Map<JobVertexID,ExecutionJobVertex> tasks,
String savepointPath,
boolean allowNonRestoredState)
Resets the state of
Execution instances back to the state of a savepoint. |
Constructor and Description |
---|
SimpleCheckpointStatsTracker(int historySize,
List<ExecutionJobVertex> tasksToWaitFor,
MetricGroup metrics) |
Modifier and Type | Method and Description |
---|---|
ExecutionJobVertex |
ExecutionVertex.getJobVertex() |
ExecutionJobVertex |
ExecutionGraph.getJobVertex(JobVertexID id) |
ExecutionJobVertex |
IntermediateResult.getProducer() |
Modifier and Type | Method and Description |
---|---|
Map<JobVertexID,ExecutionJobVertex> |
ExecutionGraph.getAllVertices() |
Iterable<ExecutionJobVertex> |
ExecutionGraph.getVerticesTopologically() |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionGraph.enableSnapshotCheckpointing(long interval,
long checkpointTimeout,
long minPauseBetweenCheckpoints,
int maxConcurrentCheckpoints,
int numberKeyGroups,
List<ExecutionJobVertex> verticesToTrigger,
List<ExecutionJobVertex> verticesToWaitFor,
List<ExecutionJobVertex> verticesToCommitTo,
akka.actor.ActorSystem actorSystem,
UUID leaderSessionID,
CheckpointIDCounter checkpointIDCounter,
CompletedCheckpointStore checkpointStore,
RecoveryMode recoveryMode,
SavepointStore savepointStore,
CheckpointStatsTracker statsTracker) |
void |
ExecutionGraph.enableSnapshotCheckpointing(long interval,
long checkpointTimeout,
long minPauseBetweenCheckpoints,
int maxConcurrentCheckpoints,
int numberKeyGroups,
List<ExecutionJobVertex> verticesToTrigger,
List<ExecutionJobVertex> verticesToWaitFor,
List<ExecutionJobVertex> verticesToCommitTo,
akka.actor.ActorSystem actorSystem,
UUID leaderSessionID,
CheckpointIDCounter checkpointIDCounter,
CompletedCheckpointStore checkpointStore,
RecoveryMode recoveryMode,
SavepointStore savepointStore,
CheckpointStatsTracker statsTracker) |
void |
ExecutionGraph.enableSnapshotCheckpointing(long interval,
long checkpointTimeout,
long minPauseBetweenCheckpoints,
int maxConcurrentCheckpoints,
int numberKeyGroups,
List<ExecutionJobVertex> verticesToTrigger,
List<ExecutionJobVertex> verticesToWaitFor,
List<ExecutionJobVertex> verticesToCommitTo,
akka.actor.ActorSystem actorSystem,
UUID leaderSessionID,
CheckpointIDCounter checkpointIDCounter,
CompletedCheckpointStore checkpointStore,
RecoveryMode recoveryMode,
SavepointStore savepointStore,
CheckpointStatsTracker statsTracker) |
Constructor and Description |
---|
ExecutionVertex(ExecutionJobVertex jobVertex,
int subTaskIndex,
IntermediateResult[] producedDataSets,
scala.concurrent.duration.FiniteDuration timeout) |
ExecutionVertex(ExecutionJobVertex jobVertex,
int subTaskIndex,
IntermediateResult[] producedDataSets,
scala.concurrent.duration.FiniteDuration timeout,
int maxPriorExecutionHistoryLength) |
ExecutionVertex(ExecutionJobVertex jobVertex,
int subTaskIndex,
IntermediateResult[] producedDataSets,
scala.concurrent.duration.FiniteDuration timeout,
long createTimestamp,
int maxPriorExecutionHistoryLength) |
IntermediateResult(IntermediateDataSetID id,
ExecutionJobVertex producer,
int numParallelProducers,
ResultPartitionType resultType) |
Modifier and Type | Method and Description |
---|---|
scala.Option<OperatorBackPressureStats> |
BackPressureStatsTracker.getOperatorBackPressureStats(ExecutionJobVertex vertex)
Returns back pressure statistics for a operator.
|
boolean |
BackPressureStatsTracker.triggerStackTraceSample(ExecutionJobVertex vertex)
Triggers a stack trace sample for a operator to gather the back pressure
statistics.
|
Modifier and Type | Method and Description |
---|---|
String |
SubtasksTimesHandler.handleRequest(ExecutionJobVertex jobVertex,
Map<String,String> params) |
String |
SubtasksAllAccumulatorsHandler.handleRequest(ExecutionJobVertex jobVertex,
Map<String,String> params) |
String |
JobVertexTaskManagersHandler.handleRequest(ExecutionJobVertex jobVertex,
Map<String,String> params) |
String |
JobVertexDetailsHandler.handleRequest(ExecutionJobVertex jobVertex,
Map<String,String> params) |
String |
JobVertexCheckpointsHandler.handleRequest(ExecutionJobVertex jobVertex,
Map<String,String> params) |
String |
JobVertexBackPressureHandler.handleRequest(ExecutionJobVertex jobVertex,
Map<String,String> params) |
String |
JobVertexAccumulatorsHandler.handleRequest(ExecutionJobVertex jobVertex,
Map<String,String> params) |
String |
AbstractSubtaskRequestHandler.handleRequest(ExecutionJobVertex jobVertex,
Map<String,String> params) |
abstract String |
AbstractJobVertexRequestHandler.handleRequest(ExecutionJobVertex jobVertex,
Map<String,String> params) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.