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

Packages that use SchemaChangeBehavior

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

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

Fields in org.apache.flink.cdc.common.pipeline with type parameters of type SchemaChangeBehavior

Modifier and Type	Field	Description
static ConfigOption<SchemaChangeBehavior>	PipelineOptions.PIPELINE_SCHEMA_CHANGE_BEHAVIOR

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

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

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

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

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

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

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

Modifier and Type	Field	Description
protected SchemaChangeBehavior	SchemaRegistry.behavior

Methods in org.apache.flink.cdc.runtime.operators.schema.common that return SchemaChangeBehavior

Modifier and Type	Method	Description
SchemaChangeBehavior	SchemaManager.getBehavior()

Methods in org.apache.flink.cdc.runtime.operators.schema.common with parameters of type SchemaChangeBehavior

Modifier and Type	Method	Description
static List<SchemaChangeEvent>	SchemaDerivator.normalizeSchemaChangeEvents(Schema oldSchema, List<SchemaChangeEvent> schemaChangeEvents, SchemaChangeBehavior schemaChangeBehavior, MetadataApplier metadataApplier)	Rewrite SchemaChangeEvents by current SchemaChangeBehavior and include / exclude them by fine-grained schema change event configurations.

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

Constructor	Description
ExistingTableSchemaExpander(MetadataApplier metadataApplier, ExistingTableSchemaExpansionSupport expansionSupport, SchemaChangeBehavior schemaChangeBehavior)
ExistingTableSchemaExpander(MetadataApplier metadataApplier, ExistingTableSchemaExpansionSupport expansionSupport, SchemaChangeBehavior schemaChangeBehavior, ExistingTableSchemaExpansionMode mode)
SchemaManager(Map<TableId,SortedMap<Integer,Schema>> originalSchemas, Map<TableId,SortedMap<Integer,Schema>> evolvedSchemas, SchemaChangeBehavior behavior)
SchemaManager(SchemaChangeBehavior schemaChangeBehavior)
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 SchemaChangeBehavior in org.apache.flink.cdc.runtime.operators.schema.common.metrics

Fields in org.apache.flink.cdc.runtime.operators.schema.common.metrics with type parameters of type SchemaChangeBehavior

Modifier and Type	Field	Description
static Map<SchemaChangeBehavior,Integer>	SchemaOperatorMetrics.SCHEMA_CHANGE_BEHAVIOR_INTEGER_MAP

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

Constructor	Description
SchemaOperatorMetrics(org.apache.flink.metrics.MetricGroup metricGroup, SchemaChangeBehavior behavior)

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

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

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, java.time.Duration rpcTimeout)
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, 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)
SchemaOperator(List<RouteRule> routingRules, RouteMode routeMode, java.time.Duration rpcTimeOut, SchemaChangeBehavior schemaChangeBehavior, String timezone)
SchemaOperatorFactory(MetadataApplier metadataApplier, List<RouteRule> routingRules, RouteMode routeMode, java.time.Duration rpcTimeout, SchemaChangeBehavior schemaChangeBehavior, String timezone)
SchemaOperatorFactory(MetadataApplier metadataApplier, List<RouteRule> routingRules, RouteMode routeMode, java.time.Duration rpcTimeout, SchemaChangeBehavior schemaChangeBehavior, ExistingTableSchemaExpansionMode existingTableSchemaExpansionMode, String timezone)

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

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

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, java.time.Duration rpcTimeout)
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, 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)
SchemaOperator(List<RouteRule> routingRules, RouteMode routeMode, java.time.Duration rpcTimeOut, SchemaChangeBehavior schemaChangeBehavior)
SchemaOperator(List<RouteRule> routingRules, RouteMode routeMode, java.time.Duration rpcTimeOut, SchemaChangeBehavior schemaChangeBehavior, String timezone)
SchemaOperatorFactory(MetadataApplier metadataApplier, List<RouteRule> routingRules, RouteMode routeMode, java.time.Duration rpcTimeout, SchemaChangeBehavior schemaChangeBehavior, String timezone)
SchemaOperatorFactory(MetadataApplier metadataApplier, List<RouteRule> routingRules, RouteMode routeMode, java.time.Duration rpcTimeout, SchemaChangeBehavior schemaChangeBehavior, ExistingTableSchemaExpansionMode existingTableSchemaExpansionMode, String timezone)