flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java