Package org.apache.flink.cdc.runtime.operators.schema.regular
-
Class Summary Class Description BatchSchemaOperator The operator will apply create table event and router mapper in batch mode.SchemaCoordinator Coordinator node forSchemaOperator.SchemaCoordinatorProvider Provider ofSchemaCoordinator.SchemaOperator The operator will evolve schemas inSchemaCoordinatorfor incomingSchemaChangeEvents and block the stream for tables before their schema changes finish.SchemaOperatorFactory Factory to createSchemaOperator.