diff --git a/java/algorithm/src/main/java/org/apache/arrow/algorithm/search/ParallelSearcher.java b/java/algorithm/src/main/java/org/apache/arrow/algorithm/search/ParallelSearcher.java index 890f4e52cc237..39678a17686d2 100644 --- a/java/algorithm/src/main/java/org/apache/arrow/algorithm/search/ParallelSearcher.java +++ b/java/algorithm/src/main/java/org/apache/arrow/algorithm/search/ParallelSearcher.java @@ -100,7 +100,7 @@ public int search(V keyVector, int keyIndex) throws ExecutionException, Interrup return; } - RangeEqualsVisitor visitor = new RangeEqualsVisitor(vector, keyVector, false); + RangeEqualsVisitor visitor = new RangeEqualsVisitor(vector, keyVector, null); Range range = new Range(0, 0, 1); for (int pos = start; pos < end; pos++) { if (keyPosition != -1) { diff --git a/java/vector/src/test/java/org/apache/arrow/vector/complex/impl/TestComplexCopier.java b/java/vector/src/test/java/org/apache/arrow/vector/complex/impl/TestComplexCopier.java index 593510a4b673b..4675d1c74b17f 100644 --- a/java/vector/src/test/java/org/apache/arrow/vector/complex/impl/TestComplexCopier.java +++ b/java/vector/src/test/java/org/apache/arrow/vector/complex/impl/TestComplexCopier.java @@ -163,7 +163,7 @@ public void testCopyMapVector() { @Test public void testCopyListVector() { try (ListVector from = ListVector.empty("from", allocator); - ListVector to = ListVector.empty("to", allocator)) { + ListVector to = ListVector.empty("from", allocator)) { UnionListWriter listWriter = from.getWriter(); listWriter.allocate(); @@ -202,7 +202,7 @@ public void testCopyListVector() { to.setValueCount(COUNT); // validate equals - assertTrue(VectorEqualsVisitor.vectorEquals(from, to)); + assertTrue(VectorEqualsVisitor.vectorEquals(from, to, TYPE_COMPARATOR)); } } diff --git a/java/vector/src/test/java/org/apache/arrow/vector/ipc/TestArrowReaderWriter.java b/java/vector/src/test/java/org/apache/arrow/vector/ipc/TestArrowReaderWriter.java index 6cd56a58e71ff..365a3aa79eb21 100644 --- a/java/vector/src/test/java/org/apache/arrow/vector/ipc/TestArrowReaderWriter.java +++ b/java/vector/src/test/java/org/apache/arrow/vector/ipc/TestArrowReaderWriter.java @@ -437,7 +437,7 @@ public void testDictionaryReplacement() throws Exception { assertTrue(reader.loadNextBatch()); FieldVector dictionaryVector = reader.getDictionaryVectors().get(1L).getVector(); // make sure the delta dictionary is concatenated. - assertTrue(VectorEqualsVisitor.vectorEquals(dictionaryVector, dictionaryVector1)); + assertTrue(VectorEqualsVisitor.vectorEquals(dictionaryVector, dictionaryVector1, null)); assertFalse(reader.loadNextBatch()); } @@ -503,7 +503,7 @@ public void testDeltaDictionary() throws Exception { assertTrue(reader.loadNextBatch()); FieldVector dictionaryVector = reader.getDictionaryVectors().get(1L).getVector(); // make sure the delta dictionary is concatenated. - assertTrue(VectorEqualsVisitor.vectorEquals(dictionaryVector, dictionaryVector3)); + assertTrue(VectorEqualsVisitor.vectorEquals(dictionaryVector, dictionaryVector3, null)); assertFalse(reader.loadNextBatch()); }