Merge pull request #1126 from RumbleDB/SerializerInline

Fix output.
RumbleDB · Nov 2, 2021 · aaae4ee · aaae4ee
2 parents 6d585c3 + e81f166
commit aaae4ee
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 6 deletions.
diff --git a/src/main/java/org/rumbledb/runtime/flwor/clauses/ForClauseSparkIterator.java b/src/main/java/org/rumbledb/runtime/flwor/clauses/ForClauseSparkIterator.java
@@ -962,7 +962,7 @@ public static Dataset<Row> tryNativeQuery(
         if (nativeQuery == NativeClauseContext.NoNativeQuery) {
             return null;
         }
-        System.out.println(
+        System.err.println(
             "[INFO] Rumble was able to optimize a for clause to a native SQL query."
         );
         String selectSQL = FlworDataFrameUtils.getSQLProjection(allColumns, true);

diff --git a/src/main/java/org/rumbledb/runtime/flwor/clauses/GroupByClauseSparkIterator.java b/src/main/java/org/rumbledb/runtime/flwor/clauses/GroupByClauseSparkIterator.java
@@ -570,7 +570,7 @@ private Dataset<Row> tryNativeQuery(
                 selectString.append(".sequence`");
             }
         }
-        System.out.println("[INFO] Rumble was able to optimize a let clause to a native SQL query.");
+        System.err.println("[INFO] Rumble was able to optimize a let clause to a native SQL query.");
         return dataFrame.sparkSession()
             .sql(
                 String.format(

diff --git a/src/main/java/org/rumbledb/runtime/flwor/clauses/LetClauseSparkIterator.java b/src/main/java/org/rumbledb/runtime/flwor/clauses/LetClauseSparkIterator.java
@@ -544,8 +544,6 @@ public static Dataset<Row> bindLetVariableInDataFrame(
             Map<Name, DynamicContext.VariableDependency> outputTupleVariableDependencies,
             boolean hash
     ) {
-        System.err.println("bindLetVariableInDataFrame");
-        dataFrame.show();
         StructType inputSchema = dataFrame.schema();
         // inputSchema.printTreeString();
 
@@ -765,7 +763,7 @@ public static Dataset<Row> tryNativeQuery(
         if (nativeQuery == NativeClauseContext.NoNativeQuery) {
             return null;
         }
-        System.out.println(
+        System.err.println(
             "[INFO] Rumble was able to optimize a let clause to a native SQL query."
         );
         String selectSQL = FlworDataFrameUtils.getSQLProjection(allColumns, true);

diff --git a/src/main/java/org/rumbledb/runtime/flwor/clauses/OrderByClauseSparkIterator.java b/src/main/java/org/rumbledb/runtime/flwor/clauses/OrderByClauseSparkIterator.java
@@ -563,7 +563,7 @@ public static Dataset<Row> tryNativeQuery(
             }
         }
 
-        System.out.println("[INFO] Rumble was able to optimize an order-by clause to a native SQL query.");
+        System.err.println("[INFO] Rumble was able to optimize an order-by clause to a native SQL query.");
         String selectSQL = FlworDataFrameUtils.getSQLProjection(allColumns, false);
         dataFrame.createOrReplaceTempView("input");
         return dataFrame.sparkSession()