public class VectorAccessibleSerializable extends AbstractStreamSerializable
logger
Constructor and Description |
---|
VectorAccessibleSerializable(BufferAllocator allocator) |
VectorAccessibleSerializable(WritableBatch batch,
BufferAllocator allocator) |
VectorAccessibleSerializable(WritableBatch batch,
SelectionVector2 sv2,
BufferAllocator allocator)
Creates a wrapper around batch and sv2 for writing to a stream.
|
Modifier and Type | Method and Description |
---|---|
void |
clear() |
VectorContainer |
get() |
SelectionVector2 |
getSv2() |
long |
getTimeNs() |
void |
read(DataInput input) |
void |
readExternal(ObjectInput in) |
void |
readFromStream(InputStream input)
Reads from an InputStream and parses a RecordBatchDef.
|
void |
readFromStreamWithContainer(VectorContainer myContainer,
InputStream input) |
void |
write(DataOutput output) |
void |
writeExternal(ObjectOutput out) |
void |
writeToStream(OutputStream output)
Serializes the VectorAccessible va and writes it to an output stream
|
void |
writeToStreamAndRetain(OutputStream output) |
public VectorAccessibleSerializable(BufferAllocator allocator)
public VectorAccessibleSerializable(WritableBatch batch, BufferAllocator allocator)
public VectorAccessibleSerializable(WritableBatch batch, SelectionVector2 sv2, BufferAllocator allocator)
batch
- sv2
- allocator
- public void readFromStream(InputStream input) throws IOException
readFromStream
in interface DrillSerializable
readFromStream
in class AbstractStreamSerializable
input
- the InputStream to read fromIOException
public void readFromStreamWithContainer(VectorContainer myContainer, InputStream input) throws IOException
IOException
public void writeToStreamAndRetain(OutputStream output) throws IOException
IOException
public void writeToStream(OutputStream output) throws IOException
writeToStream
in interface DrillSerializable
writeToStream
in class AbstractStreamSerializable
output
- the OutputStream to write toIOException
public void clear()
public VectorContainer get()
public SelectionVector2 getSv2()
public long getTimeNs()
public void writeExternal(ObjectOutput out) throws IOException
writeExternal
in interface Externalizable
IOException
public void read(DataInput input) throws IOException
read
in interface DrillSerializable
IOException
public void write(DataOutput output) throws IOException
write
in interface DrillSerializable
IOException
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
readExternal
in interface Externalizable
IOException
ClassNotFoundException
Copyright © 1970 The Apache Software Foundation. All rights reserved.