Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.checkpoint.savepoint | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.query |
This package contains all KvState query related classes.
|
org.apache.flink.runtime.webmonitor |
Modifier and Type | Method and Description |
---|---|
boolean |
CheckpointCoordinator.restoreLatestCheckpointedState(Map<JobVertexID,ExecutionJobVertex> tasks,
boolean errorIfNoCheckpoint,
boolean allowNonRestoredState)
Restores the latest checkpointed state.
|
Constructor and Description |
---|
CheckpointStatsTracker(int numRememberedCheckpoints,
List<ExecutionJobVertex> jobVertices,
JobSnapshottingSettings jobSnapshottingSettings,
MetricGroup metricGroup)
Creates a new checkpoint stats tracker.
|
StateAssignmentOperation(org.slf4j.Logger logger,
Map<JobVertexID,ExecutionJobVertex> tasks,
Map<JobVertexID,TaskState> taskStates,
boolean allowNonRestoredState) |
Modifier and Type | Method and Description |
---|---|
static CompletedCheckpoint |
SavepointLoader.loadAndValidateSavepoint(JobID jobId,
Map<JobVertexID,ExecutionJobVertex> tasks,
String savepointPath,
ClassLoader userClassLoader,
boolean allowNonRestoredState)
Loads a savepoint back as a
CompletedCheckpoint . |
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() |
static Map<JobVertexID,ExecutionJobVertex> |
ExecutionJobVertex.includeLegacyJobVertexIDs(Map<JobVertexID,ExecutionJobVertex> tasks) |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionGraph.enableSnapshotCheckpointing(long interval,
long checkpointTimeout,
long minPauseBetweenCheckpoints,
int maxConcurrentCheckpoints,
ExternalizedCheckpointSettings externalizeSettings,
List<ExecutionJobVertex> verticesToTrigger,
List<ExecutionJobVertex> verticesToWaitFor,
List<ExecutionJobVertex> verticesToCommitTo,
CheckpointIDCounter checkpointIDCounter,
CompletedCheckpointStore checkpointStore,
String checkpointDir,
CheckpointStatsTracker statsTracker) |
void |
ExecutionGraph.enableSnapshotCheckpointing(long interval,
long checkpointTimeout,
long minPauseBetweenCheckpoints,
int maxConcurrentCheckpoints,
ExternalizedCheckpointSettings externalizeSettings,
List<ExecutionJobVertex> verticesToTrigger,
List<ExecutionJobVertex> verticesToWaitFor,
List<ExecutionJobVertex> verticesToCommitTo,
CheckpointIDCounter checkpointIDCounter,
CompletedCheckpointStore checkpointStore,
String checkpointDir,
CheckpointStatsTracker statsTracker) |
void |
ExecutionGraph.enableSnapshotCheckpointing(long interval,
long checkpointTimeout,
long minPauseBetweenCheckpoints,
int maxConcurrentCheckpoints,
ExternalizedCheckpointSettings externalizeSettings,
List<ExecutionJobVertex> verticesToTrigger,
List<ExecutionJobVertex> verticesToWaitFor,
List<ExecutionJobVertex> verticesToCommitTo,
CheckpointIDCounter checkpointIDCounter,
CompletedCheckpointStore checkpointStore,
String checkpointDir,
CheckpointStatsTracker statsTracker) |
static Map<JobVertexID,ExecutionJobVertex> |
ExecutionJobVertex.includeLegacyJobVertexIDs(Map<JobVertexID,ExecutionJobVertex> tasks) |
Constructor and Description |
---|
ArchivedExecutionJobVertex(ExecutionJobVertex jobVertex) |
ExecutionVertex(ExecutionJobVertex jobVertex,
int subTaskIndex,
IntermediateResult[] producedDataSets,
Time timeout) |
ExecutionVertex(ExecutionJobVertex jobVertex,
int subTaskIndex,
IntermediateResult[] producedDataSets,
Time timeout,
int maxPriorExecutionHistoryLength) |
ExecutionVertex(ExecutionJobVertex jobVertex,
int subTaskIndex,
IntermediateResult[] producedDataSets,
Time timeout,
long createTimestamp,
int maxPriorExecutionHistoryLength) |
IntermediateResult(IntermediateDataSetID id,
ExecutionJobVertex producer,
int numParallelProducers,
ResultPartitionType resultType) |
Constructor and Description |
---|
KvStateLocationRegistry(JobID jobId,
Map<JobVertexID,ExecutionJobVertex> jobVertices)
Creates the registry for the job.
|
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.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.