Package org.apache.flink.cdc.common.pipeline
-
Class Summary Class Description PipelineOptions Predefined pipeline configuration options. -
Enum Summary Enum Description DecimalPrecisionMode Maximum precision mode for DECIMAL type in transform expressions.ExistingTableSchemaExpansionMode Strategy for handling an existing target table when the initialCreateTableEventarrives.HashFunctionStrategy Partitioning strategy forDataChangeEventin Flink CDC pipeline.RouteMode Route mode for routing rules.RuntimeExecutionMode Runtime execution mode of the pipeline includes STREAMING and BATCH, with the default value being STREAMING.SchemaChangeBehavior Behavior for handling schema changes.