ARROW-1102: Make MessageSerializer.serializeMessage() public Author: Julien Le Dem <jul...@apache.org>
Closes #741 from julienledem/ARROW-1102 and squashes the following commits: 284eaaf1 [Julien Le Dem] ARROW-1102: Make MessageSerializer.serializeMessage() public Project: http://git-wip-us.apache.org/repos/asf/arrow/repo Commit: http://git-wip-us.apache.org/repos/asf/arrow/commit/a44d5842 Tree: http://git-wip-us.apache.org/repos/asf/arrow/tree/a44d5842 Diff: http://git-wip-us.apache.org/repos/asf/arrow/diff/a44d5842 Branch: refs/heads/master Commit: a44d5842ce372d787050dc7aca535ccaa9c5fe3b Parents: a382034 Author: Julien Le Dem <jul...@apache.org> Authored: Thu Jun 8 16:40:41 2017 -0400 Committer: Wes McKinney <wes.mckin...@twosigma.com> Committed: Sun Jun 11 11:13:25 2017 -0400 ---------------------------------------------------------------------- .../org/apache/arrow/vector/stream/MessageSerializer.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/arrow/blob/a44d5842/java/vector/src/main/java/org/apache/arrow/vector/stream/MessageSerializer.java ---------------------------------------------------------------------- diff --git a/java/vector/src/main/java/org/apache/arrow/vector/stream/MessageSerializer.java b/java/vector/src/main/java/org/apache/arrow/vector/stream/MessageSerializer.java index 2fd9374..05ad92d 100644 --- a/java/vector/src/main/java/org/apache/arrow/vector/stream/MessageSerializer.java +++ b/java/vector/src/main/java/org/apache/arrow/vector/stream/MessageSerializer.java @@ -142,7 +142,7 @@ public class MessageSerializer { return new ArrowBlock(start, metadataLength + 4, bufferLength); } - private static long writeBatchBuffers(WriteChannel out, ArrowRecordBatch batch) throws IOException { + public static long writeBatchBuffers(WriteChannel out, ArrowRecordBatch batch) throws IOException { long bufferStart = out.getCurrentPosition(); List<ArrowBuf> buffers = batch.getBuffers(); List<ArrowBuffer> buffersLayout = batch.getBuffersLayout(); @@ -171,7 +171,7 @@ public class MessageSerializer { * @return the deserialized object * @throws IOException if something went wrong */ - private static ArrowRecordBatch deserializeRecordBatch(ReadChannel in, Message message, BufferAllocator alloc) + public static ArrowRecordBatch deserializeRecordBatch(ReadChannel in, Message message, BufferAllocator alloc) throws IOException { RecordBatch recordBatchFB = (RecordBatch) message.header(new RecordBatch()); @@ -222,7 +222,7 @@ public class MessageSerializer { } // Deserializes a record batch given the Flatbuffer metadata and in-memory body - private static ArrowRecordBatch deserializeRecordBatch(RecordBatch recordBatchFB, + public static ArrowRecordBatch deserializeRecordBatch(RecordBatch recordBatchFB, ArrowBuf body) throws IOException { // Now read the body int nodesLength = recordBatchFB.nodesLength(); @@ -296,7 +296,7 @@ public class MessageSerializer { * @return the corresponding dictionary batch * @throws IOException if something went wrong */ - private static ArrowDictionaryBatch deserializeDictionaryBatch(ReadChannel in, + public static ArrowDictionaryBatch deserializeDictionaryBatch(ReadChannel in, Message message, BufferAllocator alloc) throws IOException { DictionaryBatch dictionaryBatchFB = (DictionaryBatch) message.header(new DictionaryBatch()); @@ -373,7 +373,7 @@ public class MessageSerializer { * @param bodyLength body length field * @return the corresponding ByteBuffer */ - private static ByteBuffer serializeMessage(FlatBufferBuilder builder, byte headerType, + public static ByteBuffer serializeMessage(FlatBufferBuilder builder, byte headerType, int headerOffset, int bodyLength) { Message.startMessage(builder); Message.addHeaderType(builder, headerType);
