flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/TableSchemaInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Selectors.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/schema/Selectors.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/DefaultDataChangeEventHashFunctionProvider.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/sink/MaxComputeHashFunctionProvider.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/ArrayData.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/TypeConvertUtils.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/TypeConvertUtils.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksUtils.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonWriterHelper.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/utils/IcebergTypeUtils.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/utils/DataTypeUtils.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/utils/IcebergTypeUtils.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java