Package | Description |
---|---|
org.apache.arrow.vector.ipc | |
org.apache.arrow.vector.ipc.message |
Modifier and Type | Method and Description |
---|---|
protected ArrowBlock |
ArrowWriter.writeDictionaryBatch(ArrowDictionaryBatch batch) |
protected ArrowBlock |
ArrowFileWriter.writeDictionaryBatch(ArrowDictionaryBatch batch) |
protected ArrowBlock |
ArrowWriter.writeRecordBatch(ArrowRecordBatch batch) |
protected ArrowBlock |
ArrowFileWriter.writeRecordBatch(ArrowRecordBatch batch) |
Modifier and Type | Method and Description |
---|---|
List<ArrowBlock> |
ArrowFileWriter.getDictionaryBlocks() |
List<ArrowBlock> |
ArrowFileReader.getDictionaryBlocks() |
List<ArrowBlock> |
ArrowFileWriter.getRecordBlocks() |
List<ArrowBlock> |
ArrowFileReader.getRecordBlocks()
Returns the
ArrowBlock metadata from the file. |
Modifier and Type | Method and Description |
---|---|
boolean |
ArrowFileReader.loadRecordBatch(ArrowBlock block)
Loads record batch for the given block.
|
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.
|
Modifier and Type | Method and Description |
---|---|
List<ArrowBlock> |
ArrowFooter.getDictionaries() |
List<ArrowBlock> |
ArrowFooter.getRecordBatches() |
Modifier and Type | Method and Description |
---|---|
static ArrowDictionaryBatch |
MessageSerializer.deserializeDictionaryBatch(ReadChannel in,
ArrowBlock block,
BufferAllocator alloc)
Deserializes a DictionaryBatch knowing the size of the entire message up front.
|
static ArrowRecordBatch |
MessageSerializer.deserializeRecordBatch(ReadChannel in,
ArrowBlock block,
BufferAllocator alloc)
Deserializes an ArrowRecordBatch knowing the size of the entire message up front.
|
Constructor and Description |
---|
ArrowFooter(Schema schema,
List<ArrowBlock> dictionaries,
List<ArrowBlock> recordBatches) |
ArrowFooter(Schema schema,
List<ArrowBlock> dictionaries,
List<ArrowBlock> recordBatches) |
ArrowFooter(Schema schema,
List<ArrowBlock> dictionaries,
List<ArrowBlock> recordBatches,
Map<String,String> metaData)
Constructs a new instance.
|
ArrowFooter(Schema schema,
List<ArrowBlock> dictionaries,
List<ArrowBlock> recordBatches,
Map<String,String> metaData)
Constructs a new instance.
|
ArrowFooter(Schema schema,
List<ArrowBlock> dictionaries,
List<ArrowBlock> recordBatches,
Map<String,String> metaData,
MetadataVersion metadataVersion)
Constructs a new instance.
|
ArrowFooter(Schema schema,
List<ArrowBlock> dictionaries,
List<ArrowBlock> recordBatches,
Map<String,String> metaData,
MetadataVersion metadataVersion)
Constructs a new instance.
|
Copyright © 2024 The Apache Software Foundation. All rights reserved.