This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch tsfile-batch-ordering in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 6c0f636c24b140e973ea6cd6c7114904a4bdc2b3 Author: Steve Yurong Su <[email protected]> AuthorDate: Wed Jun 26 11:37:24 2024 +0800 Update PipeTabletEventSorter.java --- .../connector/payload/evolvable/batch/PipeTabletEventSorter.java | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/batch/PipeTabletEventSorter.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/batch/PipeTabletEventSorter.java index ca24972d798..7c1f6a3de8c 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/batch/PipeTabletEventSorter.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/batch/PipeTabletEventSorter.java @@ -108,18 +108,17 @@ public class PipeTabletEventSorter { final IMeasurementSchema schema = tablet.getSchemas().get(i); if (schema != null) { tablet.values[columnIndex] = - deduplicateValueList( - deduplicatedSize, tablet.values[columnIndex], schema.getType(), index); + reorderValueList(deduplicatedSize, tablet.values[columnIndex], schema.getType(), index); if (tablet.bitMaps != null && tablet.bitMaps[columnIndex] != null) { tablet.bitMaps[columnIndex] = - deduplicateBitMap(deduplicatedSize, tablet.bitMaps[columnIndex], index); + reorderBitMap(deduplicatedSize, tablet.bitMaps[columnIndex], index); } columnIndex++; } } } - private static Object deduplicateValueList( + private static Object reorderValueList( int deduplicatedSize, final Object valueList, final TSDataType dataType, @@ -183,7 +182,7 @@ public class PipeTabletEventSorter { } } - private static BitMap deduplicateBitMap( + private static BitMap reorderBitMap( int deduplicatedSize, final BitMap bitMap, final Integer[] index) { final BitMap deduplicatedBitMap = new BitMap(bitMap.getSize()); for (int i = 0; i < deduplicatedSize; i++) {
