Package | Description |
---|---|
org.apache.arrow.vector.ipc | |
org.apache.arrow.vector.ipc.message |
Modifier and Type | Field and Description |
---|---|
protected WriteChannel |
ArrowWriter.out |
Modifier and Type | Method and Description |
---|---|
protected void |
ArrowFileWriter.endInternal(WriteChannel out) |
protected void |
ArrowWriter.endInternal(WriteChannel out) |
protected void |
ArrowStreamWriter.endInternal(WriteChannel out) |
protected void |
ArrowFileWriter.startInternal(WriteChannel out) |
protected void |
ArrowWriter.startInternal(WriteChannel out) |
static void |
ArrowStreamWriter.writeEndOfStream(WriteChannel out,
IpcOption option)
Write an EOS identifier to the WriteChannel.
|
Modifier and Type | Method and Description |
---|---|
static ArrowBlock |
MessageSerializer.serialize(WriteChannel out,
ArrowDictionaryBatch batch) |
static ArrowBlock |
MessageSerializer.serialize(WriteChannel out,
ArrowDictionaryBatch batch,
IpcOption option)
Serializes a dictionary ArrowRecordBatch.
|
static ArrowBlock |
MessageSerializer.serialize(WriteChannel out,
ArrowRecordBatch batch)
Serializes an ArrowRecordBatch.
|
static ArrowBlock |
MessageSerializer.serialize(WriteChannel out,
ArrowRecordBatch batch,
IpcOption option)
Serializes an ArrowRecordBatch.
|
static long |
MessageSerializer.serialize(WriteChannel out,
Schema schema)
Serialize a schema object.
|
static long |
MessageSerializer.serialize(WriteChannel out,
Schema schema,
IpcOption option)
Serialize a schema object.
|
static long |
MessageSerializer.writeBatchBuffers(WriteChannel out,
ArrowRecordBatch batch)
Write the Arrow buffers of the record batch to the output channel.
|
static int |
MessageSerializer.writeMessageBuffer(WriteChannel out,
int messageLength,
ByteBuffer messageBuffer) |
static int |
MessageSerializer.writeMessageBuffer(WriteChannel out,
int messageLength,
ByteBuffer messageBuffer,
IpcOption option)
Write the serialized Message metadata, prefixed by the length, to the output Channel.
|
Copyright © 2023 The Apache Software Foundation. All rights reserved.