Build fixes

apache · Jun 16, 2022 · c2794e5 · c2794e5
1 parent 66c416c
commit c2794e5
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 3 deletions.
diff --git a/processing/src/main/java/org/apache/druid/queryng/config/QueryNGConfig.java b/processing/src/main/java/org/apache/druid/queryng/config/QueryNGConfig.java
@@ -29,6 +29,7 @@
  */
 public class QueryNGConfig
 {
+  @SuppressWarnings("unused") // To be used later
   public static final String CONFIG_ROOT = "druid.queryng";
 
   /**

diff --git a/processing/src/main/java/org/apache/druid/queryng/operators/Operator.java b/processing/src/main/java/org/apache/druid/queryng/operators/Operator.java
@@ -19,6 +19,8 @@
 
 package org.apache.druid.queryng.operators;
 
+import java.util.Iterator;
+
 /**
  * An operator is a data pipeline transform: something that operates on
  * a stream of results in some way. An operator has a very simple lifecycle:
@@ -147,7 +149,8 @@ class EofException extends Exception
    * {@code Iterator} class: the simpler implementation here
    * minimizes per-row overhead. An {@code OperatorIterator} can
    * be converted to a Java {@code Iterator} by calling
-   * {@link Operators#toIterator()}#, but that adds overhead.
+   * {@link static <T> Iterator<T> Operators#toIterator(Operator<T>)},
+   * but that approach adds overhead.
    */
   interface RowIterator<T>
   {

diff --git a/processing/src/main/java/org/apache/druid/queryng/operators/Operators.java b/processing/src/main/java/org/apache/druid/queryng/operators/Operators.java
@@ -53,7 +53,7 @@ public Iterator<T> iterator()
    * iterator mechanism (since an operator looks like an iterator.)
    *
    * This is a named class so we can unwrap the operator in
-   * {@link #toOperator()} below.
+   * {@link static <T> Operator<T> #toOperator(DAGBuilder, Sequence<T>)}.
    */
   public static class OperatorWrapperSequence<T> extends BaseSequence<T, Iterator<T>>
   {

diff --git a/processing/src/main/java/org/apache/druid/queryng/operators/SequenceOperator.java b/processing/src/main/java/org/apache/druid/queryng/operators/SequenceOperator.java
@@ -73,7 +73,7 @@ public T accumulate(T accumulated, T in)
   @Override
   public T next() throws EofException
   {
-    if (yielder == null && yielder.isDone()) {
+    if (yielder == null || yielder.isDone()) {
       throw Operators.eof();
     }
     if (yielder.isDone()) {