You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by we...@apache.org on 2017/06/08 20:41:16 UTC
arrow git commit: ARROW-1102: Make
MessageSerializer.serializeMessage() public
Repository: arrow
Updated Branches:
refs/heads/master 81c4bd695 -> 8acc14c0b
ARROW-1102: Make MessageSerializer.serializeMessage() public
Author: Julien Le Dem <ju...@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/8acc14c0
Tree: http://git-wip-us.apache.org/repos/asf/arrow/tree/8acc14c0
Diff: http://git-wip-us.apache.org/repos/asf/arrow/diff/8acc14c0
Branch: refs/heads/master
Commit: 8acc14c0b0cfa2f8a923e2a395ce7e4270af538a
Parents: 81c4bd6
Author: Julien Le Dem <ju...@apache.org>
Authored: Thu Jun 8 16:40:41 2017 -0400
Committer: Wes McKinney <we...@twosigma.com>
Committed: Thu Jun 8 16:40:41 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/8acc14c0/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);