codecov

Author: Caideyipi

iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/pattern/IoTDBTreePatternTest.java

@@ -27,6 +27,16 @@
 import org.junit.Assert;
 import org.junit.Test;
 
+import java.util.ArrayList;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Random;
+import java.util.Set;
+import java.util.stream.Collectors;
+import java.util.stream.IntStream;
+
+import static org.apache.iotdb.commons.pipe.datastructure.pattern.IoTDBTreePattern.applyReversedIndexesOnList;
+
 public class IoTDBTreePatternTest {
 
   @Test
@@ -109,4 +119,29 @@ public void testIotdbPipePattern() {
       Assert.assertFalse(new IoTDBTreePattern(t).matchesMeasurement(device, measurement));
     }
   }
+
+  @Test
+  public void testApplyReversedIndexes() {
+    final int elementNum = 10_000_000;
+    final int filteredNum = elementNum / 10;
+    final Random random = new Random();
+    final List<Integer> originalList =
+        IntStream.range(0, elementNum).boxed().collect(Collectors.toList());
+    List<Integer> filteredIndexes = new ArrayList<>(filteredNum);
+    for (int i = 0; i < filteredNum; i++) {
+      filteredIndexes.add(random.nextInt(elementNum));
+    }
+    filteredIndexes = filteredIndexes.stream().sorted().distinct().collect(Collectors.toList());
+
+    final long start = System.currentTimeMillis();
+    final List<Integer> appliedList = applyReversedIndexesOnList(filteredIndexes, originalList);
+    System.out.println(System.currentTimeMillis() - start);
+    final Set<Integer> appliedSet = new HashSet<>(appliedList);
+    for (Integer filteredIndex : filteredIndexes) {
+      if (appliedSet.contains(filteredIndex)) {
+        System.out.println("Incorrect implementation");
+        System.exit(-1);
+      }
+    }
+  }
 }