| commit | 76c07911c11a36f4a1e0da3fb6e4864674cd26c9 | [log] [tgz] |
|---|---|---|
| author | madhusudancs@gmail.com <madhusudancs@gmail.com@123451ca-8445-de46-9d55-352943316053> | Sat Feb 23 11:45:52 2013 +0000 |
| committer | madhusudancs@gmail.com <madhusudancs@gmail.com@123451ca-8445-de46-9d55-352943316053> | Sat Feb 23 11:45:52 2013 +0000 |
| tree | 3a0e6790437a5b562b1dc645fadaf18aec64163d | |
| parent | e4551ab1b53adb1eaf3f6fe3e591e47a24bfdd92 [diff] |
The tuple printer should not print newline, the caller can do it by itself. Printing newline in print tuple makes the whole infrastructure unusable at other places where newline character is not required. git-svn-id: https://hyracks.googlecode.com/svn/branches/fullstack_hyracks_result_distribution@2977 123451ca-8445-de46-9d55-352943316053
diff --git a/algebricks/algebricks-runtime/src/main/java/edu/uci/ics/hyracks/algebricks/runtime/operators/std/SinkWriterRuntime.java b/algebricks/algebricks-runtime/src/main/java/edu/uci/ics/hyracks/algebricks/runtime/operators/std/SinkWriterRuntime.java index 148f087..28597a7 100644 --- a/algebricks/algebricks-runtime/src/main/java/edu/uci/ics/hyracks/algebricks/runtime/operators/std/SinkWriterRuntime.java +++ b/algebricks/algebricks-runtime/src/main/java/edu/uci/ics/hyracks/algebricks/runtime/operators/std/SinkWriterRuntime.java
@@ -70,6 +70,7 @@ for (int t = 0; t < nTuple; t++) { try { writer.printTuple(tAccess, t); + printStream.println(); } catch (AlgebricksException ae) { throw new HyracksDataException(ae); }
diff --git a/algebricks/algebricks-runtime/src/main/java/edu/uci/ics/hyracks/algebricks/runtime/writers/PrinterBasedWriterFactory.java b/algebricks/algebricks-runtime/src/main/java/edu/uci/ics/hyracks/algebricks/runtime/writers/PrinterBasedWriterFactory.java index 9c53241..762e133 100644 --- a/algebricks/algebricks-runtime/src/main/java/edu/uci/ics/hyracks/algebricks/runtime/writers/PrinterBasedWriterFactory.java +++ b/algebricks/algebricks-runtime/src/main/java/edu/uci/ics/hyracks/algebricks/runtime/writers/PrinterBasedWriterFactory.java
@@ -47,7 +47,6 @@ } printers[i].print(tAccess.getBuffer().array(), fldStart, fldLen, printStream); } - printStream.println(); } }; }