25 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/KeyProjectedRow.java (62:102, 32%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/ProjectedRowData.java (79:119, 26%) 24 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Projection.java (161:198, 12%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/Projection.java (93:130, 22%) 23 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/ProjectedRow.java (84:122, 24%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/ProjectedRowData.java (81:119, 24%) 19 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/fs/PositionOutputStreamWrapper.java (29:59, 86%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkFileIO.java (169:199, 16%) 16 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/ProjectedRow.java (154:175, 17%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/ProjectedRowData.java (156:177, 16%) 15 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/fs/hadoop/HadoopFileIO.java (231:255, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkFileIO.java (169:193, 12%) 15 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/fs/local/LocalFileIO.java (288:310, 8%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkFileIO.java (177:199, 12%) 14 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Projection.java (218:240, 7%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/Projection.java (140:162, 13%) 14 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Projection.java (322:345, 7%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/Projection.java (192:215, 13%) 12 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/fs/hadoop/HadoopFileIO.java (180:197, 9%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkFileIO.java (143:160, 10%) 12 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/factories/FactoryUtil.java (97:113, 17%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/factories/FlinkFactoryUtil.java (185:201, 4%) 12 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/fs/SeekableInputStreamWrapper.java (37:54, 63%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkFileIO.java (143:160, 10%) 12 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Projection.java (114:153, 6%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/Projection.java (51:90, 11%) 9 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/ProjectedRow.java (65:79, 9%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/ProjectedRowData.java (66:80, 9%) 9 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/fs/local/LocalFileIO.java (258:270, 5%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkFileIO.java (148:160, 7%) 9 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/TypeCheckUtils.java (121:129, 15%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/PredicateConverter.java (262:270, 4%) 9 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/KeyProjectedRow.java (134:148, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/ProjectedRowData.java (156:170, 9%) 9 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/ProjectedRow.java (192:201, 9%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/ProjectedRowData.java (194:203, 9%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/CoreOptions.java (1489:1500, <1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (254:265, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/CoreOptions.java (1489:1500, <1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (284:295, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/LocalZonedTimestampType.java (88:97, 18%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:101, 14%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/CoreOptions.java (1695:1706, <1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (254:265, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/CoreOptions.java (1392:1403, <1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (254:265, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/CoreOptions.java (1695:1706, <1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (284:295, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/CoreOptions.java (1425:1436, <1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (284:295, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/CoreOptions.java (1425:1436, <1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (254:265, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/CoreOptions.java (1392:1403, <1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (284:295, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/InternalRowUtils.java (232:240, 4%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/kafka/KafkaLogDeserializationSchema.java (90:98, 8%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/CoreOptions.java (1720:1731, <1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (284:295, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/CoreOptions.java (1720:1731, <1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (254:265, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/CoreOptions.java (1533:1544, <1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (254:265, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/CoreOptions.java (1533:1544, <1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (284:295, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/TimeType.java (85:94, 18%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:101, 14%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/VarCharType.java (87:96, 16%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:101, 14%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/CharType.java (80:89, 18%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:101, 14%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/BinaryType.java (78:87, 18%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:101, 14%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/CoreOptions.java (1361:1372, <1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (254:265, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/CoreOptions.java (1361:1372, <1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (284:295, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DecimalType.java (99:108, 14%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:101, 14%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/CoreOptions.java (1256:1267, <1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (284:295, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/CoreOptions.java (1256:1267, <1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (254:265, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/MultisetType.java (83:92, 17%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:101, 14%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/CoreOptions.java (1631:1642, <1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (254:265, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/CoreOptions.java (1631:1642, <1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (284:295, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/RowType.java (126:135, 5%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:101, 14%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/CoreOptions.java (1450:1461, <1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (284:295, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/CoreOptions.java (1450:1461, <1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (254:265, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/TimestampType.java (83:92, 18%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:101, 14%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/WriteMode.java (41:52, 40%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (284:295, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/WriteMode.java (41:52, 40%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (254:265, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/CoreOptions.java (1331:1342, <1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (284:295, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/CoreOptions.java (1331:1342, <1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (254:265, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/VarBinaryType.java (83:92, 17%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:101, 14%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/ArrayType.java (79:88, 17%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:101, 14%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/table/TableType.java (39:50, 44%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (254:265, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/MapType.java (88:97, 15%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:101, 14%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/table/TableType.java (39:50, 44%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (284:295, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/CoreOptions.java (1662:1673, <1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (284:295, 3%) 8 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/CoreOptions.java (1662:1673, <1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (254:265, 3%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/PositiveIntInt.java (49:55, 22%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DecimalType.java (99:105, 10%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/TimestampType.java (83:89, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/TimestampType.java (83:89, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DecimalType.java (99:105, 10%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalArraySerializer.java (164:170, 5%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/fs/hadoop/HadoopFileIO.java (283:290, 4%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkFileIO.java (221:228, 5%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DataType.java (133:139, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/MultisetType.java (83:89, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/MultisetType.java (83:89, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DataField.java (128:134, 8%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/HadoopUtils.java (187:194, 6%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (258:265, 2%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/JoinedRow.java (242:248, 4%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/MapType.java (88:94, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/PositiveIntInt.java (49:55, 22%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalArraySerializer.java (164:170, 5%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/HadoopUtils.java (187:194, 6%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (288:295, 2%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/MultisetType.java (83:89, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DecimalType.java (99:105, 10%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/MultisetType.java (83:89, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/DecimalSerializer.java (72:78, 14%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/codegen/CompileUtils.java (122:128, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Triple.java (42:48, 22%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/TimeType.java (85:91, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/CharType.java (80:86, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/JoinedRow.java (242:248, 4%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalArraySerializer.java (164:170, 5%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Reference.java (40:46, 27%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/predicate/LeafPredicate.java (116:122, 8%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/GenericArray.java (142:148, 3%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Pair.java (77:83, 14%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Reference.java (40:46, 27%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DataType.java (133:139, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/JoinedRow.java (242:248, 4%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/TimestampType.java (83:89, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Pair.java (77:83, 14%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/BinarySection.java (117:123, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/predicate/LeafPredicate.java (116:122, 8%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/codegen/CompileUtils.java (122:128, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DataField.java (128:134, 8%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/VarBinaryType.java (83:89, 12%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Reference.java (40:46, 27%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Triple.java (42:48, 22%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/CharType.java (80:86, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/RowCompactedSerializer.java (115:121, 1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/RowCompactedSerializer.java (115:121, 1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/BinarySection.java (117:123, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/RowType.java (126:132, 4%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Projection.java (409:416, 3%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/Projection.java (225:232, 5%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/VarBinaryType.java (83:89, 12%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Pair.java (77:83, 14%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DataType.java (133:139, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/PositiveIntInt.java (49:55, 22%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/RowCompactedSerializer.java (115:121, 1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/DecimalSerializer.java (72:78, 14%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/ArrayType.java (79:85, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Triple.java (42:48, 22%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/predicate/FieldRef.java (53:59, 19%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/codegen/CompileUtils.java (122:128, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/RowCompactedSerializer.java (115:121, 1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/MapType.java (88:94, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/LocalZonedTimestampType.java (88:94, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/predicate/FieldRef.java (53:59, 19%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/PositiveIntInt.java (49:55, 22%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/TimestampType.java (83:89, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Triple.java (42:48, 22%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/predicate/LeafPredicate.java (116:122, 8%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/ArrayType.java (79:85, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/BinaryType.java (78:84, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/BinarySection.java (117:123, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Triple.java (42:48, 22%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/MultisetType.java (83:89, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/TimeType.java (85:91, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalArraySerializer.java (164:170, 5%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Reference.java (40:46, 27%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/RowCompactedSerializer.java (115:121, 1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/GenericArray.java (142:148, 3%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/BinarySection.java (117:123, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/predicate/FieldRef.java (53:59, 19%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/BinarySection.java (117:123, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/BinaryType.java (78:84, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalArraySerializer.java (164:170, 5%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/fs/hadoop/HadoopFileIO.java (270:279, 4%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkFileIO.java (208:217, 5%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/DecimalSerializer.java (72:78, 14%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/predicate/FieldRef.java (53:59, 19%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/JoinedRow.java (242:248, 4%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/ArrayType.java (79:85, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalMapSerializer.java (171:177, 5%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Pair.java (77:83, 14%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/VarCharType.java (87:93, 12%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/DecimalSerializer.java (72:78, 14%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Triple.java (42:48, 22%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/predicate/LeafPredicate.java (116:122, 8%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/LocalZonedTimestampType.java (88:94, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/MapType.java (88:94, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/MapType.java (88:94, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/predicate/FieldRef.java (53:59, 19%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/MapType.java (88:94, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Reference.java (40:46, 27%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/TimestampType.java (83:89, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/ArrayType.java (79:85, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/predicate/LeafPredicate.java (116:122, 8%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/MultisetType.java (83:89, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/codegen/CompileUtils.java (122:128, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/RowType.java (126:132, 4%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/TimeType.java (85:91, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DataField.java (128:134, 8%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/JoinedRow.java (242:248, 4%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/KeyProjectedRow.java (150:155, 7%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/ProjectedRowData.java (172:177, 6%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/VarCharType.java (87:93, 12%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DataField.java (128:134, 8%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/VarBinaryType.java (83:89, 12%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/TimeType.java (85:91, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DataType.java (133:139, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DataType.java (133:139, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/CharType.java (80:86, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/predicate/FieldRef.java (53:59, 19%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/PositiveIntInt.java (49:55, 22%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Projection.java (260:270, 3%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/Projection.java (182:192, 5%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalMapSerializer.java (171:177, 5%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Pair.java (77:83, 14%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/MapType.java (88:94, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/VarBinaryType.java (83:89, 12%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/RowType.java (126:132, 4%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalMapSerializer.java (171:177, 5%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DecimalType.java (99:105, 10%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/codegen/CompileUtils.java (122:128, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DataField.java (128:134, 8%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/predicate/LeafPredicate.java (116:122, 8%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DecimalType.java (99:105, 10%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/VarCharType.java (87:93, 12%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/predicate/LeafPredicate.java (116:122, 8%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalMapSerializer.java (171:177, 5%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DecimalType.java (99:105, 10%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/LocalZonedTimestampType.java (88:94, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/BinaryType.java (78:84, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DataField.java (128:134, 8%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Pair.java (77:83, 14%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/ArrayType.java (79:85, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/BinarySection.java (117:123, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/RowCompactedSerializer.java (115:121, 1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/RowCompactedSerializer.java (115:121, 1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/VarBinaryType.java (83:89, 12%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Pair.java (77:83, 14%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/ArrayType.java (79:85, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/JoinedRow.java (242:248, 4%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/VarCharType.java (87:93, 12%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/codegen/CompileUtils.java (122:128, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/RowCompactedSerializer.java (115:121, 1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/BinaryType.java (78:84, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/TimeType.java (85:91, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Pair.java (77:83, 14%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/BinarySection.java (117:123, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/RowCompactedSerializer.java (115:121, 1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Triple.java (42:48, 22%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/ArrayType.java (79:85, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/RowCompactedSerializer.java (115:121, 1%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/RowType.java (126:132, 4%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalArraySerializer.java (164:170, 5%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DataType.java (133:139, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/TimeType.java (85:91, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/DecimalSerializer.java (72:78, 14%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/LocalZonedTimestampType.java (88:94, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/ArrayType.java (79:85, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/RowType.java (126:132, 4%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/TimestampType.java (83:89, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DataField.java (128:134, 8%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/BinarySection.java (117:123, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DataField.java (128:134, 8%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/BinaryType.java (78:84, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/VarCharType.java (87:93, 12%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/DecimalSerializer.java (72:78, 14%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/LocalZonedTimestampType.java (88:94, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DecimalType.java (99:105, 10%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/TimeType.java (85:91, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalMapSerializer.java (171:177, 5%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DataType.java (133:139, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/BinarySection.java (117:123, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/GenericArray.java (142:148, 3%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Reference.java (40:46, 27%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/MapType.java (88:94, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Pair.java (77:83, 14%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/BinaryType.java (78:84, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/GenericArray.java (142:148, 3%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalArraySerializer.java (164:170, 5%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/GenericArray.java (142:148, 3%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/JoinedRow.java (242:248, 4%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/MapType.java (88:94, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DataField.java (128:134, 8%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/GenericArray.java (142:148, 3%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/predicate/LeafPredicate.java (116:122, 8%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/BinaryType.java (78:84, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DataType.java (133:139, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/MultisetType.java (83:89, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/DecimalSerializer.java (72:78, 14%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/GenericArray.java (142:148, 3%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalArraySerializer.java (164:170, 5%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/codegen/CompileUtils.java (122:128, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/CharType.java (80:86, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/GenericArray.java (142:148, 3%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Reference.java (40:46, 27%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalMapSerializer.java (171:177, 5%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/codegen/CompileUtils.java (122:128, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/PositiveIntInt.java (49:55, 22%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/PositiveIntInt.java (49:55, 22%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/CharType.java (80:86, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/LocalZonedTimestampType.java (88:94, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/JoinedRow.java (242:248, 4%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/VarBinaryType.java (83:89, 12%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalMapSerializer.java (171:177, 5%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/RowType.java (126:132, 4%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/MultisetType.java (83:89, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Reference.java (40:46, 27%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/TimestampType.java (83:89, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/MultisetType.java (83:89, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/RowType.java (126:132, 4%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/options/CatalogOptions.java (89:94, 9%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java (53:58, 2%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/VarCharType.java (87:93, 12%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Reference.java (40:46, 27%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/DecimalSerializer.java (72:78, 14%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DecimalType.java (99:105, 10%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/GenericArray.java (142:148, 3%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/JoinedRow.java (242:248, 4%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/TimeType.java (85:91, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/VarCharType.java (87:93, 12%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/TimestampType.java (83:89, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/RowType.java (126:132, 4%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/TypeUtils.java (144:149, 5%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/PredicateConverter.java (262:267, 3%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DataTypeChecks.java (119:124, 5%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/PredicateConverter.java (262:267, 3%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/LocalZonedTimestampType.java (88:94, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/CharType.java (80:86, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalMapSerializer.java (171:177, 5%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/codegen/CompileUtils.java (122:128, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalArraySerializer.java (164:170, 5%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/factories/FactoryUtil.java (76:83, 8%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/factories/FlinkFactoryUtil.java (150:157, 2%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/JoinedRow.java (242:248, 4%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/predicate/LeafPredicate.java (116:122, 8%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Reference.java (40:46, 27%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/predicate/FieldRef.java (53:59, 19%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/codegen/CompileUtils.java (122:128, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Pair.java (77:83, 14%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/PositiveIntInt.java (49:55, 22%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DecimalType.java (99:105, 10%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/VarBinaryType.java (83:89, 12%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/VarCharType.java (87:93, 12%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/BinaryType.java (78:84, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DataType.java (133:139, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/PositiveIntInt.java (49:55, 22%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalArraySerializer.java (164:170, 5%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/TimestampType.java (83:89, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/predicate/LeafPredicate.java (116:122, 8%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Triple.java (42:48, 22%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/PositiveIntInt.java (49:55, 22%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/CharType.java (80:86, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/ArrayType.java (79:85, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalMapSerializer.java (171:177, 5%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/VarBinaryType.java (83:89, 12%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/predicate/FieldRef.java (53:59, 19%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/predicate/FieldRef.java (53:59, 19%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DataField.java (128:134, 8%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/LocalZonedTimestampType.java (88:94, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Triple.java (42:48, 22%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/TimeType.java (85:91, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/predicate/FieldRef.java (53:59, 19%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/GenericArray.java (142:148, 3%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/BinaryType.java (78:84, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/CharType.java (80:86, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/DecimalSerializer.java (72:78, 14%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/DecimalSerializer.java (72:78, 14%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/RowType.java (126:132, 4%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/CharType.java (80:86, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/MapType.java (88:94, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/BinarySection.java (117:123, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/utils/Triple.java (42:48, 22%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/VarBinaryType.java (83:89, 12%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/VarCharType.java (87:93, 12%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/LocalZonedTimestampType.java (88:94, 13%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/types/DataType.java (133:139, 11%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%) 6 duplicated lines in: - paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalMapSerializer.java (171:177, 5%) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)