Uses of Package
org.apache.flink.cdc.common.pipeline
-
Classes in org.apache.flink.cdc.common.pipeline used by org.apache.flink.cdc.common.pipeline Class 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. -
Classes in org.apache.flink.cdc.common.pipeline used by org.apache.flink.cdc.common.route Class Description RouteMode Route mode for routing rules. -
Classes in org.apache.flink.cdc.common.pipeline used by org.apache.flink.cdc.composer.definition Class Description ExistingTableSchemaExpansionMode Strategy for handling an existing target table when the initialCreateTableEventarrives.RouteMode Route mode for routing rules. -
Classes in org.apache.flink.cdc.common.pipeline used by org.apache.flink.cdc.composer.flink.translator Class Description DecimalPrecisionMode Maximum precision mode for DECIMAL type in transform expressions.ExistingTableSchemaExpansionMode Strategy for handling an existing target table when the initialCreateTableEventarrives.RouteMode Route mode for routing rules.SchemaChangeBehavior Behavior for handling schema changes. -
Classes in org.apache.flink.cdc.common.pipeline used by org.apache.flink.cdc.runtime.operators.schema.common Class Description ExistingTableSchemaExpansionMode Strategy for handling an existing target table when the initialCreateTableEventarrives.RouteMode Route mode for routing rules.SchemaChangeBehavior Behavior for handling schema changes. -
Classes in org.apache.flink.cdc.common.pipeline used by org.apache.flink.cdc.runtime.operators.schema.common.metrics Class Description SchemaChangeBehavior Behavior for handling schema changes. -
Classes in org.apache.flink.cdc.common.pipeline used by org.apache.flink.cdc.runtime.operators.schema.distributed Class Description ExistingTableSchemaExpansionMode Strategy for handling an existing target table when the initialCreateTableEventarrives.RouteMode Route mode for routing rules.SchemaChangeBehavior Behavior for handling schema changes. -
Classes in org.apache.flink.cdc.common.pipeline used by org.apache.flink.cdc.runtime.operators.schema.regular Class Description ExistingTableSchemaExpansionMode Strategy for handling an existing target table when the initialCreateTableEventarrives.RouteMode Route mode for routing rules.SchemaChangeBehavior Behavior for handling schema changes. -
Classes in org.apache.flink.cdc.common.pipeline used by org.apache.flink.cdc.runtime.operators.transform Class Description DecimalPrecisionMode Maximum precision mode for DECIMAL type in transform expressions. -
Classes in org.apache.flink.cdc.common.pipeline used by org.apache.flink.cdc.runtime.operators.transform.async Class Description DecimalPrecisionMode Maximum precision mode for DECIMAL type in transform expressions. -
Classes in org.apache.flink.cdc.common.pipeline used by org.apache.flink.cdc.runtime.parser Class Description DecimalPrecisionMode Maximum precision mode for DECIMAL type in transform expressions.