Package | Description |
---|---|
org.apache.flink.runtime.checkpoint |
Modifier and Type | Method and Description |
---|---|
CompletedCheckpointStats |
CheckpointStatsHistory.getLatestCompletedCheckpoint() |
CompletedCheckpointStats |
CheckpointStatsHistory.getLatestSavepoint() |
CompletedCheckpointStats |
CompletedCheckpoint.getStatistic() |
Constructor and Description |
---|
CompletedCheckpoint(JobID job,
long checkpointID,
long timestamp,
long completionTimestamp,
Map<OperatorID,OperatorState> operatorStates,
Collection<MasterState> masterHookStates,
CheckpointProperties props,
CompletedCheckpointStorageLocation storageLocation,
CompletedCheckpointStats completedCheckpointStats) |
CompletedCheckpoint(JobID job,
long checkpointID,
long timestamp,
long completionTimestamp,
Map<OperatorID,OperatorState> operatorStates,
Collection<MasterState> masterHookStates,
CheckpointProperties props,
CompletedCheckpointStorageLocation storageLocation,
CompletedCheckpointStats completedCheckpointStats,
CheckpointProperties restoredProps) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.