arrow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From w...@apache.org
Subject [03/12] arrow git commit: ARROW-1102: Make MessageSerializer.serializeMessage() public
Date Sun, 11 Jun 2017 15:13:51 GMT
ARROW-1102: Make MessageSerializer.serializeMessage() public

Author: Julien Le Dem <julien@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 <julien@apache.org>
Authored: Thu Jun 8 16:40:41 2017 -0400
Committer: Wes McKinney <wes.mckinney@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);


Mime
View raw message