public static class CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder extends Object
CheckpointCoordinatorConfiguration
builder.Constructor and Description |
---|
CheckpointCoordinatorConfigurationBuilder() |
public CheckpointCoordinatorConfigurationBuilder()
public CheckpointCoordinatorConfiguration build()
public CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder setCheckpointInterval(long checkpointInterval)
public CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder setCheckpointTimeout(long checkpointTimeout)
public CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder setMinPauseBetweenCheckpoints(long minPauseBetweenCheckpoints)
public CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder setMaxConcurrentCheckpoints(int maxConcurrentCheckpoints)
public CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder setCheckpointRetentionPolicy(CheckpointRetentionPolicy checkpointRetentionPolicy)
public CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder setExactlyOnce(boolean exactlyOnce)
public CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder setPreferCheckpointForRecovery(boolean preferCheckpointForRecovery)
public CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder setTolerableCheckpointFailureNumber(int tolerableCheckpointFailureNumber)
public CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder setUnalignedCheckpointsEnabled(boolean unalignedCheckpointsEnabled)
public CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder setAlignmentTimeout(long alignmentTimeout)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.