static CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder |
CheckpointCoordinatorConfiguration.builder() |
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder |
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder.setAlignedCheckpointTimeout(long alignedCheckpointTimeout) |
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder |
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder.setCheckpointIdOfIgnoredInFlightData(long checkpointIdOfIgnoredInFlightData) |
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder |
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder.setCheckpointInterval(long checkpointInterval) |
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder |
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder.setCheckpointRetentionPolicy(CheckpointRetentionPolicy checkpointRetentionPolicy) |
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder |
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder.setCheckpointTimeout(long checkpointTimeout) |
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder |
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder.setEnableCheckpointsAfterTasksFinish(boolean enableCheckpointsAfterTasksFinish) |
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder |
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder.setExactlyOnce(boolean exactlyOnce) |
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder |
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder.setMaxConcurrentCheckpoints(int maxConcurrentCheckpoints) |
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder |
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder.setMinPauseBetweenCheckpoints(long minPauseBetweenCheckpoints) |
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder |
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder.setTolerableCheckpointFailureNumber(int tolerableCheckpointFailureNumber) |
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder |
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder.setUnalignedCheckpointsEnabled(boolean unalignedCheckpointsEnabled) |