6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java (139:145, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java (101:107, 10%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java (60:66, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java (60:66, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java (84:90, 12%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java (84:90, 12%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java (134:140, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java (49:55, 25%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java (60:66, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java (76:82, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java (134:140, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java (76:82, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java (101:107, 10%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java (139:145, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java (139:145, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java (49:55, 25%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java (84:90, 12%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java (101:107, 10%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java (76:82, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java (101:107, 10%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java (49:55, 25%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java (101:107, 10%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java (101:107, 10%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java (76:82, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java (134:140, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java (49:55, 25%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java (101:107, 10%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java (84:90, 12%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java (49:55, 25%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java (76:82, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java (49:55, 25%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java (76:82, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java (76:82, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java (101:107, 10%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java (49:55, 25%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java (139:145, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java (76:82, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java (101:107, 10%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java (76:82, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java (49:55, 25%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java (134:140, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java (134:140, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java (134:140, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java (60:66, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java (76:82, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java (84:90, 12%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java (139:145, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java (101:107, 10%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java (49:55, 25%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java (49:55, 25%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java (76:82, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java (60:66, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java (49:55, 25%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java (139:145, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java (139:145, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java (76:82, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java (134:140, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java (84:90, 12%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java (84:90, 12%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java (60:66, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java (76:82, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java (101:107, 10%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java (101:107, 10%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java (139:145, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java (134:140, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java (84:90, 12%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java (139:145, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java (60:66, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java (49:55, 25%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java (84:90, 12%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java (60:66, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java (134:140, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java (101:107, 10%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java (134:140, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java (84:90, 12%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java (139:145, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java (49:55, 25%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java (101:107, 10%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java (84:90, 12%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java (49:55, 25%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java (76:82, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java (60:66, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java (76:82, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java (60:66, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java (134:140, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java (139:145, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java (84:90, 12%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java (134:140, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java (134:140, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java (84:90, 12%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java (134:140, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java (139:145, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java (60:66, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java (139:145, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java (49:55, 25%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java (134:140, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java (60:66, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java (139:145, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java (84:90, 12%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java (134:140, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java (101:107, 10%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java (49:55, 25%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java (101:107, 10%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java (101:107, 10%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java (139:145, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java (76:82, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java (84:90, 12%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java (60:66, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java (139:145, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java (139:145, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java (60:66, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java (134:140, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java (84:90, 12%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java (76:82, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java (84:90, 12%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java (60:66, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java (60:66, 15%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java (49:55, 25%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%) - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java (60:66, 15%)