public static interface CheckpointConfiguration.Builder extends SdkPojo, CopyableBuilder<CheckpointConfiguration.Builder,CheckpointConfiguration>
Modifier and Type | Method and Description |
---|---|
CheckpointConfiguration.Builder |
checkpointingEnabled(Boolean checkpointingEnabled)
Describes whether checkpointing is enabled for a Java-based Kinesis Data Analytics application.
|
CheckpointConfiguration.Builder |
checkpointInterval(Long checkpointInterval)
Describes the interval in milliseconds between checkpoint operations.
|
CheckpointConfiguration.Builder |
configurationType(ConfigurationType configurationType)
Describes whether the application uses Amazon Kinesis Data Analytics' default checkpointing behavior.
|
CheckpointConfiguration.Builder |
configurationType(String configurationType)
Describes whether the application uses Amazon Kinesis Data Analytics' default checkpointing behavior.
|
CheckpointConfiguration.Builder |
minPauseBetweenCheckpoints(Long minPauseBetweenCheckpoints)
Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint
operation can start.
|
copy
applyMutation, build
CheckpointConfiguration.Builder configurationType(String configurationType)
Describes whether the application uses Amazon Kinesis Data Analytics' default checkpointing behavior.
configurationType
- Describes whether the application uses Amazon Kinesis Data Analytics' default checkpointing behavior.ConfigurationType
,
ConfigurationType
CheckpointConfiguration.Builder configurationType(ConfigurationType configurationType)
Describes whether the application uses Amazon Kinesis Data Analytics' default checkpointing behavior.
configurationType
- Describes whether the application uses Amazon Kinesis Data Analytics' default checkpointing behavior.ConfigurationType
,
ConfigurationType
CheckpointConfiguration.Builder checkpointingEnabled(Boolean checkpointingEnabled)
Describes whether checkpointing is enabled for a Java-based Kinesis Data Analytics application.
checkpointingEnabled
- Describes whether checkpointing is enabled for a Java-based Kinesis Data Analytics application.CheckpointConfiguration.Builder checkpointInterval(Long checkpointInterval)
Describes the interval in milliseconds between checkpoint operations.
checkpointInterval
- Describes the interval in milliseconds between checkpoint operations.CheckpointConfiguration.Builder minPauseBetweenCheckpoints(Long minPauseBetweenCheckpoints)
Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint
operation can start. If a checkpoint operation takes longer than the CheckpointInterval
, the
application otherwise performs continual checkpoint operations. For more information, see Tuning Checkpointing in the Apache Flink Documentation.
minPauseBetweenCheckpoints
- Describes the minimum time in milliseconds after a checkpoint operation completes that a new
checkpoint operation can start. If a checkpoint operation takes longer than the
CheckpointInterval
, the application otherwise performs continual checkpoint operations.
For more information, see Tuning Checkpointing in the Apache Flink Documentation.Copyright © 2017 Amazon Web Services, Inc. All Rights Reserved.