[parquet-mr] branch master updated: PARQUET-1749: Use Java 8 Streams for Empty PrimitiveIterator (#734)

[fo...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

fokko pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/parquet-mr.git


The following commit(s) were added to refs/heads/master by this push:
     new 438cb3c  PARQUET-1749: Use Java 8 Streams for Empty PrimitiveIterator (#734)
438cb3c is described below

commit 438cb3c761daf8d916a85c8742fb321905a07df8
Author: belugabehr <12...@users.noreply.github.com>
AuthorDate: Sun Jan 26 15:11:26 2020 -0500

    PARQUET-1749: Use Java 8 Streams for Empty PrimitiveIterator (#734)
---
 .../parquet/internal/column/columnindex/IndexIterator.java  | 13 ++-----------
 1 file changed, 2 insertions(+), 11 deletions(-)

diff --git a/parquet-column/src/main/java/org/apache/parquet/internal/column/columnindex/IndexIterator.java b/parquet-column/src/main/java/org/apache/parquet/internal/column/columnindex/IndexIterator.java
index 9eab65e..e1ae750 100644
--- a/parquet-column/src/main/java/org/apache/parquet/internal/column/columnindex/IndexIterator.java
+++ b/parquet-column/src/main/java/org/apache/parquet/internal/column/columnindex/IndexIterator.java
@@ -22,6 +22,7 @@ import java.util.NoSuchElementException;
 import java.util.PrimitiveIterator;
 import java.util.function.IntPredicate;
 import java.util.function.IntUnaryOperator;
+import java.util.stream.IntStream;
 
 import org.apache.parquet.internal.column.columnindex.ColumnIndexBuilder.ColumnIndexBase;
 
@@ -29,17 +30,7 @@ import org.apache.parquet.internal.column.columnindex.ColumnIndexBuilder.ColumnI
  * Iterator implementation for page indexes.
  */
 class IndexIterator implements PrimitiveIterator.OfInt {
-  public static final PrimitiveIterator.OfInt EMPTY = new OfInt() {
-    @Override
-    public boolean hasNext() {
-      return false;
-    }
-
-    @Override
-    public int nextInt() {
-      throw new NoSuchElementException();
-    }
-  };
+  public static final PrimitiveIterator.OfInt EMPTY = IntStream.empty().iterator();
   private int index;
   private final int endIndex;
   private final IntPredicate filter;