Uses of Interface
org.apache.flink.cdc.common.sink.MetadataApplier

Packages that use MetadataApplier

Package	Description
org.apache.flink.cdc.common.sink
org.apache.flink.cdc.composer.flink.translator
org.apache.flink.cdc.connectors.doris.sink
org.apache.flink.cdc.connectors.elasticsearch.sink
org.apache.flink.cdc.connectors.fluss.sink
org.apache.flink.cdc.connectors.hudi.sink
org.apache.flink.cdc.connectors.iceberg.sink
org.apache.flink.cdc.connectors.kafka.sink
org.apache.flink.cdc.connectors.maxcompute
org.apache.flink.cdc.connectors.oceanbase.sink
org.apache.flink.cdc.connectors.paimon.sink
org.apache.flink.cdc.connectors.starrocks.sink
org.apache.flink.cdc.connectors.values
org.apache.flink.cdc.connectors.values.sink
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 MetadataApplier in org.apache.flink.cdc.common.sink

Methods in org.apache.flink.cdc.common.sink that return MetadataApplier

Modifier and Type	Method	Description
MetadataApplier	DataSink.getMetadataApplier()	Get the MetadataApplier for applying metadata changes to external systems.
default MetadataApplier	MetadataApplier.setAcceptedSchemaEvolutionTypes(Set<SchemaChangeEventType> schemaEvolutionTypes)	Sets enabled schema evolution event types of current metadata applier.

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

Methods in org.apache.flink.cdc.composer.flink.translator with parameters of type MetadataApplier

Modifier and Type	Method	Description
org.apache.flink.streaming.api.datastream.DataStream<Event>	SchemaOperatorTranslator.translateDistributed(org.apache.flink.streaming.api.datastream.DataStream<PartitioningEvent> input, int parallelism, MetadataApplier metadataApplier, List<RouteDef> routes, RouteMode routeMode)
org.apache.flink.streaming.api.datastream.DataStream<Event>	SchemaOperatorTranslator.translateRegular(org.apache.flink.streaming.api.datastream.DataStream<Event> input, int parallelism, boolean isBatchMode, MetadataApplier metadataApplier, List<RouteDef> routes)
org.apache.flink.streaming.api.datastream.DataStream<Event>	SchemaOperatorTranslator.translateRegular(org.apache.flink.streaming.api.datastream.DataStream<Event> input, int parallelism, boolean isBatchMode, MetadataApplier metadataApplier, List<RouteDef> routes, RouteMode routeMode)
org.apache.flink.streaming.api.datastream.DataStream<Event>	SchemaOperatorTranslator.translateRegular(org.apache.flink.streaming.api.datastream.DataStream<Event> input, int parallelism, MetadataApplier metadataApplier, List<RouteDef> routes)

Uses of MetadataApplier in org.apache.flink.cdc.connectors.doris.sink

Classes in org.apache.flink.cdc.connectors.doris.sink that implement MetadataApplier

Modifier and Type	Class	Description
class	DorisMetadataApplier	Supports DorisDataSink to schema evolution.

Methods in org.apache.flink.cdc.connectors.doris.sink that return MetadataApplier

Modifier and Type	Method	Description
MetadataApplier	DorisDataSink.getMetadataApplier()
MetadataApplier	DorisMetadataApplier.setAcceptedSchemaEvolutionTypes(Set<SchemaChangeEventType> schemaEvolutionTypes)

Uses of MetadataApplier in org.apache.flink.cdc.connectors.elasticsearch.sink

Methods in org.apache.flink.cdc.connectors.elasticsearch.sink that return MetadataApplier

Modifier and Type	Method	Description
MetadataApplier	ElasticsearchDataSink.getMetadataApplier()

Uses of MetadataApplier in org.apache.flink.cdc.connectors.fluss.sink

Classes in org.apache.flink.cdc.connectors.fluss.sink that implement MetadataApplier

Modifier and Type	Class	Description
class	FlussMetaDataApplier	MetadataApplier for fluss.

Methods in org.apache.flink.cdc.connectors.fluss.sink that return MetadataApplier

Modifier and Type	Method	Description
MetadataApplier	FlussDataSink.getMetadataApplier()
MetadataApplier	FlussMetaDataApplier.setAcceptedSchemaEvolutionTypes(Set<SchemaChangeEventType> schemaEvolutionTypes)

Uses of MetadataApplier in org.apache.flink.cdc.connectors.hudi.sink

Classes in org.apache.flink.cdc.connectors.hudi.sink that implement MetadataApplier

Modifier and Type	Class	Description
class	HudiMetadataApplier	A MetadataApplier that applies schema changes to Hudi tables.

Methods in org.apache.flink.cdc.connectors.hudi.sink that return MetadataApplier

Modifier and Type	Method	Description
MetadataApplier	HudiDataSink.getMetadataApplier()	Provides the metadata applier.

Uses of MetadataApplier in org.apache.flink.cdc.connectors.iceberg.sink

Classes in org.apache.flink.cdc.connectors.iceberg.sink that implement MetadataApplier

Modifier and Type	Class	Description
class	IcebergMetadataApplier	A MetadataApplier for Apache Iceberg.

Methods in org.apache.flink.cdc.connectors.iceberg.sink that return MetadataApplier

Modifier and Type	Method	Description
MetadataApplier	IcebergDataSink.getMetadataApplier()
MetadataApplier	IcebergMetadataApplier.setAcceptedSchemaEvolutionTypes(Set<SchemaChangeEventType> schemaEvolutionTypes)

Uses of MetadataApplier in org.apache.flink.cdc.connectors.kafka.sink

Classes in org.apache.flink.cdc.connectors.kafka.sink that implement MetadataApplier

Modifier and Type	Class	Description
class	KafkaMetaDataApplier	Supports KafkaDataSink to schema evolution.

Methods in org.apache.flink.cdc.connectors.kafka.sink that return MetadataApplier

Modifier and Type	Method	Description
MetadataApplier	KafkaDataSink.getMetadataApplier()
MetadataApplier	KafkaMetaDataApplier.setAcceptedSchemaEvolutionTypes(Set<SchemaChangeEventType> schemaEvolutionTypes)

Uses of MetadataApplier in org.apache.flink.cdc.connectors.maxcompute

Classes in org.apache.flink.cdc.connectors.maxcompute that implement MetadataApplier

Modifier and Type	Class	Description
class	MaxComputeMetadataApplier	A MetadataApplier for "MaxCompute" connector.

Methods in org.apache.flink.cdc.connectors.maxcompute that return MetadataApplier

Modifier and Type	Method	Description
MetadataApplier	MaxComputeDataSink.getMetadataApplier()

Uses of MetadataApplier in org.apache.flink.cdc.connectors.oceanbase.sink

Classes in org.apache.flink.cdc.connectors.oceanbase.sink that implement MetadataApplier

Modifier and Type	Class	Description
class	OceanBaseMetadataApplier	Supports OceanBaseDataSink to schema evolution.

Methods in org.apache.flink.cdc.connectors.oceanbase.sink that return MetadataApplier

Modifier and Type	Method	Description
MetadataApplier	OceanBaseDataSink.getMetadataApplier()

Uses of MetadataApplier in org.apache.flink.cdc.connectors.paimon.sink

Classes in org.apache.flink.cdc.connectors.paimon.sink that implement MetadataApplier

Modifier and Type	Class	Description
class	PaimonMetadataApplier	A MetadataApplier that applies metadata changes to Paimon.

Methods in org.apache.flink.cdc.connectors.paimon.sink that return MetadataApplier

Modifier and Type	Method	Description
MetadataApplier	PaimonDataSink.getMetadataApplier()
MetadataApplier	PaimonMetadataApplier.setAcceptedSchemaEvolutionTypes(Set<SchemaChangeEventType> schemaEvolutionTypes)

Uses of MetadataApplier in org.apache.flink.cdc.connectors.starrocks.sink

Classes in org.apache.flink.cdc.connectors.starrocks.sink that implement MetadataApplier

Modifier and Type	Class	Description
class	StarRocksMetadataApplier	A MetadataApplier that applies metadata changes to StarRocks.

Methods in org.apache.flink.cdc.connectors.starrocks.sink that return MetadataApplier

Modifier and Type	Method	Description
MetadataApplier	StarRocksDataSink.getMetadataApplier()
MetadataApplier	StarRocksMetadataApplier.setAcceptedSchemaEvolutionTypes(Set<SchemaChangeEventType> schemaEvolutionTypes)

Uses of MetadataApplier in org.apache.flink.cdc.connectors.values

Classes in org.apache.flink.cdc.connectors.values that implement MetadataApplier

Modifier and Type	Class	Description
static class	ValuesDatabase.ErrorOnChangeMetadataApplier	apply SchemaChangeEvent to ValuesDatabase and print it out, throw exception if illegal changes occur.
static class	ValuesDatabase.ValuesMetadataApplier	apply SchemaChangeEvent to ValuesDatabase and print it out, throw exception if illegal changes occur.

Methods in org.apache.flink.cdc.connectors.values that return MetadataApplier

Modifier and Type	Method	Description
MetadataApplier	ValuesDatabase.ErrorOnChangeMetadataApplier.setAcceptedSchemaEvolutionTypes(Set<SchemaChangeEventType> schemaEvolutionTypes)
MetadataApplier	ValuesDatabase.ValuesMetadataApplier.setAcceptedSchemaEvolutionTypes(Set<SchemaChangeEventType> schemaEvolutionTypes)

Uses of MetadataApplier in org.apache.flink.cdc.connectors.values.sink

Methods in org.apache.flink.cdc.connectors.values.sink that return MetadataApplier

Modifier and Type	Method	Description
MetadataApplier	ValuesDataSink.getMetadataApplier()

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

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

Modifier and Type	Field	Description
protected MetadataApplier	SchemaRegistry.metadataApplier

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

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 MetadataApplier

Constructor	Description
ExistingTableSchemaExpander(MetadataApplier metadataApplier, ExistingTableSchemaExpansionSupport expansionSupport, SchemaChangeBehavior schemaChangeBehavior)
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 MetadataApplier in org.apache.flink.cdc.runtime.operators.schema.distributed

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

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)
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 MetadataApplier in org.apache.flink.cdc.runtime.operators.schema.regular

Fields in org.apache.flink.cdc.runtime.operators.schema.regular declared as MetadataApplier

Modifier and Type	Field	Description
protected MetadataApplier	BatchSchemaOperator.metadataApplier

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

Constructor	Description
BatchSchemaOperator(List<RouteRule> routingRules, RouteMode routeMode, MetadataApplier metadataApplier, String timezone)
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)
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)