Uses of Class
org.apache.flink.cdc.common.pipeline.ExistingTableSchemaExpansionMode

Packages that use ExistingTableSchemaExpansionMode

Package	Description
org.apache.flink.cdc.common.pipeline
org.apache.flink.cdc.composer.definition
org.apache.flink.cdc.composer.flink.translator
org.apache.flink.cdc.runtime.operators.schema.common
org.apache.flink.cdc.runtime.operators.schema.distributed
org.apache.flink.cdc.runtime.operators.schema.regular

Uses of ExistingTableSchemaExpansionMode in org.apache.flink.cdc.common.pipeline

Methods in org.apache.flink.cdc.common.pipeline that return ExistingTableSchemaExpansionMode

Modifier and Type	Method	Description
static ExistingTableSchemaExpansionMode	ExistingTableSchemaExpansionMode.valueOf(String name)	Returns the enum constant of this type with the specified name.
static ExistingTableSchemaExpansionMode[]	ExistingTableSchemaExpansionMode.values()	Returns an array containing the constants of this enum type, in the order they are declared.

Uses of ExistingTableSchemaExpansionMode in org.apache.flink.cdc.composer.definition

Methods in org.apache.flink.cdc.composer.definition that return ExistingTableSchemaExpansionMode

Modifier and Type	Method	Description
ExistingTableSchemaExpansionMode	SinkDef.getExistingTableSchemaExpansionMode()

Constructors in org.apache.flink.cdc.composer.definition with parameters of type ExistingTableSchemaExpansionMode

Constructor	Description
SinkDef(String type, String name, Configuration config, Set<SchemaChangeEventType> includedSchemaEvolutionTypes, ExistingTableSchemaExpansionMode existingTableSchemaExpansionMode)

Uses of ExistingTableSchemaExpansionMode in org.apache.flink.cdc.composer.flink.translator

Constructors in org.apache.flink.cdc.composer.flink.translator with parameters of type ExistingTableSchemaExpansionMode

Constructor	Description
SchemaOperatorTranslator(SchemaChangeBehavior schemaChangeBehavior, ExistingTableSchemaExpansionMode existingTableSchemaExpansionMode, String schemaOperatorUid, java.time.Duration rpcTimeOut, String timezone)

Uses of ExistingTableSchemaExpansionMode in org.apache.flink.cdc.runtime.operators.schema.common

Fields in org.apache.flink.cdc.runtime.operators.schema.common declared as ExistingTableSchemaExpansionMode

Modifier and Type	Field	Description
protected ExistingTableSchemaExpansionMode	SchemaRegistry.existingTableSchemaExpansionMode

Constructors in org.apache.flink.cdc.runtime.operators.schema.common with parameters of type ExistingTableSchemaExpansionMode

Constructor	Description
ExistingTableSchemaExpander(MetadataApplier metadataApplier, ExistingTableSchemaExpansionSupport expansionSupport, SchemaChangeBehavior schemaChangeBehavior, ExistingTableSchemaExpansionMode mode)
SchemaRegistry(org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Context context, String operatorName, ExecutorService coordinatorExecutor, MetadataApplier metadataApplier, List<RouteRule> routingRules, RouteMode routeMode, SchemaChangeBehavior schemaChangeBehavior, ExistingTableSchemaExpansionMode existingTableSchemaExpansionMode, java.time.Duration rpcTimeout)

Uses of ExistingTableSchemaExpansionMode in org.apache.flink.cdc.runtime.operators.schema.distributed

Constructors in org.apache.flink.cdc.runtime.operators.schema.distributed with parameters of type ExistingTableSchemaExpansionMode

Constructor	Description
SchemaCoordinator(String operatorName, org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Context context, ExecutorService coordinatorExecutor, MetadataApplier metadataApplier, List<RouteRule> routingRules, RouteMode routeMode, SchemaChangeBehavior schemaChangeBehavior, ExistingTableSchemaExpansionMode existingTableSchemaExpansionMode, java.time.Duration rpcTimeout)
SchemaCoordinatorProvider(org.apache.flink.runtime.jobgraph.OperatorID operatorID, String operatorName, MetadataApplier metadataApplier, List<RouteRule> routingRules, RouteMode routeMode, SchemaChangeBehavior schemaChangeBehavior, ExistingTableSchemaExpansionMode existingTableSchemaExpansionMode, java.time.Duration rpcTimeout)
SchemaOperatorFactory(MetadataApplier metadataApplier, List<RouteRule> routingRules, RouteMode routeMode, java.time.Duration rpcTimeout, SchemaChangeBehavior schemaChangeBehavior, ExistingTableSchemaExpansionMode existingTableSchemaExpansionMode, String timezone)

Uses of ExistingTableSchemaExpansionMode in org.apache.flink.cdc.runtime.operators.schema.regular

Constructors in org.apache.flink.cdc.runtime.operators.schema.regular with parameters of type ExistingTableSchemaExpansionMode

Constructor	Description
SchemaCoordinator(String operatorName, org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Context context, ExecutorService coordinatorExecutor, MetadataApplier metadataApplier, List<RouteRule> routes, RouteMode routeMode, SchemaChangeBehavior schemaChangeBehavior, ExistingTableSchemaExpansionMode existingTableSchemaExpansionMode, java.time.Duration rpcTimeout)
SchemaCoordinatorProvider(org.apache.flink.runtime.jobgraph.OperatorID operatorID, String operatorName, MetadataApplier metadataApplier, List<RouteRule> routingRules, RouteMode routeMode, SchemaChangeBehavior schemaChangeBehavior, ExistingTableSchemaExpansionMode existingTableSchemaExpansionMode, java.time.Duration rpcTimeout)
SchemaOperatorFactory(MetadataApplier metadataApplier, List<RouteRule> routingRules, RouteMode routeMode, java.time.Duration rpcTimeout, SchemaChangeBehavior schemaChangeBehavior, ExistingTableSchemaExpansionMode existingTableSchemaExpansionMode, String timezone)