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

Interface FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder

All Superinterfaces:
org.apache.camel.builder.EndpointProducerBuilder, org.apache.camel.EndpointProducerResolver
Enclosing interface:
FlinkEndpointBuilderFactory
public static interface FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder extends org.apache.camel.builder.EndpointProducerBuilder
Advanced builder for endpoint for the Flink component.

  • Method Details

    • basic

      default FlinkEndpointBuilderFactory.FlinkEndpointBuilder basic()

    • checkpointingMode

      default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder checkpointingMode(String checkpointingMode)
      Checkpointing mode: EXACTLY_ONCE (default) or AT_LEAST_ONCE. EXACTLY_ONCE provides stronger guarantees but may have higher overhead. The option is a: java.lang.String type. Group: producer (advanced)
      Parameters:
      checkpointingMode - the value to set
      Returns:
      the dsl builder

    • checkpointInterval

      default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder checkpointInterval(Long checkpointInterval)
      Interval in milliseconds between checkpoints. Enables checkpointing when set. Recommended for streaming jobs to ensure fault tolerance. The option is a: java.lang.Long type. Group: producer (advanced)
      Parameters:
      checkpointInterval - the value to set
      Returns:
      the dsl builder

    • checkpointInterval

      default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder checkpointInterval(String checkpointInterval)
      Interval in milliseconds between checkpoints. Enables checkpointing when set. Recommended for streaming jobs to ensure fault tolerance. The option will be converted to a java.lang.Long type. Group: producer (advanced)
      Parameters:
      checkpointInterval - the value to set
      Returns:
      the dsl builder

    • checkpointTimeout

      default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder checkpointTimeout(Long checkpointTimeout)
      Timeout in milliseconds for checkpoints. Checkpoints that take longer will be aborted. The option is a: java.lang.Long type. Group: producer (advanced)
      Parameters:
      checkpointTimeout - the value to set
      Returns:
      the dsl builder

    • checkpointTimeout

      default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder checkpointTimeout(String checkpointTimeout)
      Timeout in milliseconds for checkpoints. Checkpoints that take longer will be aborted. The option will be converted to a java.lang.Long type. Group: producer (advanced)
      Parameters:
      checkpointTimeout - the value to set
      Returns:
      the dsl builder

    • executionMode

      default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder executionMode(String executionMode)
      Execution mode for the Flink job. Options: STREAMING (default), BATCH, AUTOMATIC. BATCH mode is recommended for bounded streams (batch processing). The option is a: java.lang.String type. Group: producer (advanced)
      Parameters:
      executionMode - the value to set
      Returns:
      the dsl builder

    • jobName

      default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder jobName(String jobName)
      Name for the Flink job. Useful for identification in the Flink UI and logs. The option is a: java.lang.String type. Group: producer (advanced)
      Parameters:
      jobName - the value to set
      Returns:
      the dsl builder

    • lazyStartProducer

      default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder lazyStartProducer(boolean lazyStartProducer)
      Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and starting the producer may take a little time and prolong the total processing time of the processing. The option is a: boolean type. Default: false Group: producer (advanced)
      Parameters:
      lazyStartProducer - the value to set
      Returns:
      the dsl builder

    • lazyStartProducer

      default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder lazyStartProducer(String lazyStartProducer)
      Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and starting the producer may take a little time and prolong the total processing time of the processing. The option will be converted to a boolean type. Default: false Group: producer (advanced)
      Parameters:
      lazyStartProducer - the value to set
      Returns:
      the dsl builder

    • maxParallelism

      default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder maxParallelism(Integer maxParallelism)
      Maximum parallelism for the Flink job. Defines the upper bound for dynamic scaling and the number of key groups for stateful operators. The option is a: java.lang.Integer type. Group: producer (advanced)
      Parameters:
      maxParallelism - the value to set
      Returns:
      the dsl builder

    • maxParallelism

      default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder maxParallelism(String maxParallelism)
      Maximum parallelism for the Flink job. Defines the upper bound for dynamic scaling and the number of key groups for stateful operators. The option will be converted to a java.lang.Integer type. Group: producer (advanced)
      Parameters:
      maxParallelism - the value to set
      Returns:
      the dsl builder

    • minPauseBetweenCheckpoints

      default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder minPauseBetweenCheckpoints(Long minPauseBetweenCheckpoints)
      Minimum pause in milliseconds between consecutive checkpoints. Helps prevent checkpoint storms under heavy load. The option is a: java.lang.Long type. Group: producer (advanced)
      Parameters:
      minPauseBetweenCheckpoints - the value to set
      Returns:
      the dsl builder

    • minPauseBetweenCheckpoints

      default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder minPauseBetweenCheckpoints(String minPauseBetweenCheckpoints)
      Minimum pause in milliseconds between consecutive checkpoints. Helps prevent checkpoint storms under heavy load. The option will be converted to a java.lang.Long type. Group: producer (advanced)
      Parameters:
      minPauseBetweenCheckpoints - the value to set
      Returns:
      the dsl builder

    • parallelism

      default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder parallelism(Integer parallelism)
      Parallelism for the Flink job. If not set, uses the default parallelism of the execution environment. The option is a: java.lang.Integer type. Group: producer (advanced)
      Parameters:
      parallelism - the value to set
      Returns:
      the dsl builder

    • parallelism

      default FlinkEndpointBuilderFactory.AdvancedFlinkEndpointBuilder parallelism(String parallelism)
      Parallelism for the Flink job. If not set, uses the default parallelism of the execution environment. The option will be converted to a java.lang.Integer type. Group: producer (advanced)
      Parameters:
      parallelism - the value to set
      Returns:
      the dsl builder