| commit | a157789686b4a0927a1937628df0b5299bd586d0 | [log] [tgz] |
|---|---|---|
| author | vinayakb <vinayakb@123451ca-8445-de46-9d55-352943316053> | Mon May 16 16:39:04 2011 +0000 |
| committer | vinayakb <vinayakb@123451ca-8445-de46-9d55-352943316053> | Mon May 16 16:39:04 2011 +0000 |
| tree | 7a2bc96acbff1eec89a4608a41c18ec8039d823f | |
| parent | d3972d64f3840f37f47c4c11f369d568a667fc93 [diff] |
Removed a println. Changed code to use FrameUtils.makeReadable() instead of ByteBuffer.flip() git-svn-id: https://hyracks.googlecode.com/svn/branches/hyracks_scheduling@456 123451ca-8445-de46-9d55-352943316053
diff --git a/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/join/NestedLoopJoin.java b/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/join/NestedLoopJoin.java index e92d787..3e0b3ea 100644 --- a/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/join/NestedLoopJoin.java +++ b/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/join/NestedLoopJoin.java
@@ -64,7 +64,6 @@ public void cache(ByteBuffer buffer) throws HyracksDataException { runFileWriter.nextFrame(buffer); - System.out.println(runFileWriter.getFileSize()); } public void join(ByteBuffer outerBuffer, IFrameWriter writer) throws HyracksDataException {
diff --git a/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/join/NestedLoopJoinOperatorDescriptor.java b/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/join/NestedLoopJoinOperatorDescriptor.java index 5b5ace1..9e69e4b 100644 --- a/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/join/NestedLoopJoinOperatorDescriptor.java +++ b/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/join/NestedLoopJoinOperatorDescriptor.java
@@ -92,7 +92,7 @@ public void nextFrame(ByteBuffer buffer) throws HyracksDataException { ByteBuffer copyBuffer = ctx.allocateFrame(); FrameUtils.copy(buffer, copyBuffer); - copyBuffer.flip(); + FrameUtils.makeReadable(copyBuffer); joiner.cache(copyBuffer); } @@ -150,4 +150,4 @@ return op; } } -} +} \ No newline at end of file