Uses of Package
org.apache.flink.cdc.runtime.operators.schema.common
-
Classes in org.apache.flink.cdc.runtime.operators.schema.common used by org.apache.flink.cdc.connectors.paimon.sink.v2.bucket Class Description SchemaDerivator A utility class to derive how evolved schemas should change. -
Classes in org.apache.flink.cdc.runtime.operators.schema.common used by org.apache.flink.cdc.runtime.operators.schema.common Class Description ExistingTableSchemaExpander Handles the initialCreateTableEventfor an existing target table according to the configuredExistingTableSchemaExpansionMode.SchemaManager Schema manager handles schema changes for tables, and manages historical schema versions of tables.SchemaManager.Serializer Serializer forSchemaManager. -
Classes in org.apache.flink.cdc.runtime.operators.schema.common used by org.apache.flink.cdc.runtime.operators.schema.distributed Class Description SchemaRegistry An abstract centralized schema registry that accepts requests fromSchemaEvolutionClient. -
Classes in org.apache.flink.cdc.runtime.operators.schema.common used by org.apache.flink.cdc.runtime.operators.schema.regular Class Description SchemaManager Schema manager handles schema changes for tables, and manages historical schema versions of tables.SchemaRegistry An abstract centralized schema registry that accepts requests fromSchemaEvolutionClient.