| commit | 1373c078a4e6511c982472a739ca50dd71bd418d | [log] [tgz] |
|---|---|---|
| author | madhusudancs@gmail.com <madhusudancs@gmail.com@123451ca-8445-de46-9d55-352943316053> | Sun Mar 10 08:01:52 2013 +0000 |
| committer | madhusudancs@gmail.com <madhusudancs@gmail.com@123451ca-8445-de46-9d55-352943316053> | Sun Mar 10 08:01:52 2013 +0000 |
| tree | 4030307e42095b4cb3e1d6b26c364adedff35961 | |
| parent | d4140eeda6ef5f4e1ad1d360293ce6335b0c88fa [diff] |
Move print newline back to PrinterBasedWriter because not all writers need this functionality. git-svn-id: https://hyracks.googlecode.com/svn/branches/fullstack_hyracks_result_distribution@3078 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 28597a7..148f087 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,7 +70,6 @@ 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 762e133..9c53241 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,6 +47,7 @@ } printers[i].print(tAccess.getBuffer().array(), fldStart, fldLen, printStream); } + printStream.println(); } }; }