>From Ali Alsuliman <[email protected]>:
Ali Alsuliman has uploaded this change for review. (
https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/17501 )
Change subject: WIP: test result tuples printing
......................................................................
WIP: test result tuples printing
Change-Id: Ibaaac339065a30f58e2bc7f39800a506f959549d
---
M
hyracks-fullstack/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/result/ResultWriterOperatorDescriptor.java
1 file changed, 10 insertions(+), 6 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/01/17501/1
diff --git
a/hyracks-fullstack/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/result/ResultWriterOperatorDescriptor.java
b/hyracks-fullstack/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/result/ResultWriterOperatorDescriptor.java
index a4cfa13..20ac626 100644
---
a/hyracks-fullstack/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/result/ResultWriterOperatorDescriptor.java
+++
b/hyracks-fullstack/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/result/ResultWriterOperatorDescriptor.java
@@ -103,12 +103,7 @@
frameTupleAccessor.reset(buffer);
for (int tIndex = 0; tIndex <
frameTupleAccessor.getTupleCount(); tIndex++) {
resultSerializer.appendTuple(frameTupleAccessor, tIndex);
- if (!frameOutputStream.appendTuple()) {
- frameOutputStream.flush(resultPartitionWriter);
-
- resultSerializer.appendTuple(frameTupleAccessor,
tIndex);
- frameOutputStream.appendTuple();
- }
+ frameOutputStream.reset();
}
}
--
To view, visit https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/17501
To unsubscribe, or for help writing mail filters, visit
https://asterix-gerrit.ics.uci.edu/settings
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Change-Id: Ibaaac339065a30f58e2bc7f39800a506f959549d
Gerrit-Change-Number: 17501
Gerrit-PatchSet: 1
Gerrit-Owner: Ali Alsuliman <[email protected]>
Gerrit-MessageType: newchange
