Package org.apache.flink.cdc.runtime.operators.schema.common

Class Summary

Class	Description
CoordinationResponseUtils	Utilities for wrapping and unwrapping CoordinationResponse by CollectCoordinationResponse.
CoordinatorExecutorThreadFactory	A thread factory class that provides some helper methods.
ExistingTableSchemaExpander	Handles the initial CreateTableEvent for an existing target table according to the configured ExistingTableSchemaExpansionMode.
SchemaDerivator	A utility class to derive how evolved schemas should change.
SchemaManager	Schema manager handles schema changes for tables, and manages historical schema versions of tables.
SchemaManager.Serializer	Serializer for SchemaManager.
SchemaRegistry	An abstract centralized schema registry that accepts requests from SchemaEvolutionClient.