Uses of Interface
org.apache.camel.builder.endpoint.dsl.FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder

Packages that use FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder

Package	Description
org.apache.camel.builder.endpoint.dsl

Uses of FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder in org.apache.camel.builder.endpoint.dsl

Methods in org.apache.camel.builder.endpoint.dsl that return FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder

Modifier and Type	Method	Description
default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder	FlinkEndpointBuilderFactory.FlinkEndpointBuilder.advanced()
default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder	FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder.checkpointingMode(String checkpointingMode)	Checkpointing mode: EXACTLY_ONCE (default) or AT_LEAST_ONCE.
default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder	FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder.checkpointInterval(Long checkpointInterval)	Interval in milliseconds between checkpoints.
default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder	FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder.checkpointInterval(String checkpointInterval)	Interval in milliseconds between checkpoints.
default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder	FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder.checkpointTimeout(Long checkpointTimeout)	Timeout in milliseconds for checkpoints.
default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder	FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder.checkpointTimeout(String checkpointTimeout)	Timeout in milliseconds for checkpoints.
default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder	FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder.executionMode(String executionMode)	Execution mode for the Flink job.
default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder	FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder.jobName(String jobName)	Name for the Flink job.
default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder	FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder.lazyStartProducer(boolean lazyStartProducer)	Whether the producer should be started lazy (on the first message).
default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder	FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder.lazyStartProducer(String lazyStartProducer)	Whether the producer should be started lazy (on the first message).
default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder	FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder.maxParallelism(Integer maxParallelism)	Maximum parallelism for the Flink job.
default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder	FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder.maxParallelism(String maxParallelism)	Maximum parallelism for the Flink job.
default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder	FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder.minPauseBetweenCheckpoints(Long minPauseBetweenCheckpoints)	Minimum pause in milliseconds between consecutive checkpoints.
default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder	FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder.minPauseBetweenCheckpoints(String minPauseBetweenCheckpoints)	Minimum pause in milliseconds between consecutive checkpoints.
default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder	FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder.parallelism(Integer parallelism)	Parallelism for the Flink job.
default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder	FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder.parallelism(String parallelism)	Parallelism for the Flink job.