public class ArrowStreamWriter extends ArrowWriter
LOGGER, out, schema
Constructor and Description |
---|
ArrowStreamWriter(VectorSchemaRoot root,
DictionaryProvider provider,
OutputStream out)
Construct an ArrowStreamWriter with an optional DictionaryProvider for the OutputStream.
|
ArrowStreamWriter(VectorSchemaRoot root,
DictionaryProvider provider,
WritableByteChannel out)
Construct an ArrowStreamWriter with an optional DictionaryProvider for the WritableByteChannel.
|
Modifier and Type | Method and Description |
---|---|
protected void |
endInternal(WriteChannel out) |
static void |
writeEndOfStream(WriteChannel out)
Write an EOS identifier to the WriteChannel.
|
bytesWritten, close, end, start, startInternal, writeBatch, writeDictionaryBatch, writeRecordBatch
public ArrowStreamWriter(VectorSchemaRoot root, DictionaryProvider provider, OutputStream out)
root
- Existing VectorSchemaRoot with vectors to be written.provider
- DictionaryProvider for any vectors that are dictionary encoded.
(Optional, can be null)out
- OutputStream for writing.public ArrowStreamWriter(VectorSchemaRoot root, DictionaryProvider provider, WritableByteChannel out)
root
- Existing VectorSchemaRoot with vectors to be written.provider
- DictionaryProvider for any vectors that are dictionary encoded.
(Optional, can be null)out
- WritableByteChannel for writing.public static void writeEndOfStream(WriteChannel out) throws IOException
out
- Open WriteChannel with an active Arrow stream.IOException
- on errorprotected void endInternal(WriteChannel out) throws IOException
endInternal
in class ArrowWriter
IOException
Copyright © 2019 The Apache Software Foundation. All rights reserved.