| commit | 94c3683a2669afaa1b04413eb138cb5b809e0189 | [log] [tgz] |
|---|---|---|
| author | madhusudancs@gmail.com <madhusudancs@gmail.com@123451ca-8445-de46-9d55-352943316053> | Fri Mar 08 07:01:17 2013 +0000 |
| committer | madhusudancs@gmail.com <madhusudancs@gmail.com@123451ca-8445-de46-9d55-352943316053> | Fri Mar 08 07:01:17 2013 +0000 |
| tree | 2e4e676f2e4f019888006175b26f07bb34662f50 | |
| parent | 7acfa1e05d1a5faa01c387122d9fa32a597eeb07 [diff] |
Provide the functionality to set byte array size in the frame output stream and its parent classes. git-svn-id: https://hyracks.googlecode.com/svn/branches/fullstack_hyracks_result_distribution@3059 123451ca-8445-de46-9d55-352943316053
diff --git a/hyracks/hyracks-data/hyracks-data-std/src/main/java/edu/uci/ics/hyracks/data/std/util/ByteArrayAccessibleOutputStream.java b/hyracks/hyracks-data/hyracks-data-std/src/main/java/edu/uci/ics/hyracks/data/std/util/ByteArrayAccessibleOutputStream.java index 8508287..c0ba163 100644 --- a/hyracks/hyracks-data/hyracks-data-std/src/main/java/edu/uci/ics/hyracks/data/std/util/ByteArrayAccessibleOutputStream.java +++ b/hyracks/hyracks-data/hyracks-data-std/src/main/java/edu/uci/ics/hyracks/data/std/util/ByteArrayAccessibleOutputStream.java
@@ -21,6 +21,14 @@ public class ByteArrayAccessibleOutputStream extends ByteArrayOutputStream { private static final Logger LOGGER = Logger.getLogger(ByteArrayAccessibleOutputStream.class.getName()); + public ByteArrayAccessibleOutputStream() { + super(); + } + + public ByteArrayAccessibleOutputStream(int size) { + super(size); + } + public byte[] getByteArray() { return buf; }
diff --git a/hyracks/hyracks-dataflow-common/src/main/java/edu/uci/ics/hyracks/dataflow/common/comm/io/FrameOutputStream.java b/hyracks/hyracks-dataflow-common/src/main/java/edu/uci/ics/hyracks/dataflow/common/comm/io/FrameOutputStream.java index 95833b1..07f6ba2 100644 --- a/hyracks/hyracks-dataflow-common/src/main/java/edu/uci/ics/hyracks/dataflow/common/comm/io/FrameOutputStream.java +++ b/hyracks/hyracks-dataflow-common/src/main/java/edu/uci/ics/hyracks/dataflow/common/comm/io/FrameOutputStream.java
@@ -27,6 +27,7 @@ private final FrameTupleAppender frameTupleAppender; public FrameOutputStream(int frameSize) { + super(frameSize); this.frameTupleAppender = new FrameTupleAppender(frameSize); }