Package org.apache.drill.exec.cache

Class VectorAccessibleSerializable

java.lang.Object

org.apache.drill.exec.cache.AbstractStreamSerializable

org.apache.drill.exec.cache.VectorAccessibleSerializable

All Implemented Interfaces:

Externalizable, Serializable, DrillSerializable

public class VectorAccessibleSerializable
extends AbstractStreamSerializable

A wrapper around a VectorAccessible. Will serialize a VectorAccessible and write to an OutputStream, or can read from an InputStream and construct a new VectorContainer.

See Also:

• Serialized Form

Field Summary

Fields inherited from interface org.apache.drill.exec.cache.DrillSerializable

logger

Constructor Summary

Constructors

Constructor	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.

Method Summary

Modifier and Type	Method	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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

VectorAccessibleSerializable

public VectorAccessibleSerializable(BufferAllocator allocator)

VectorAccessibleSerializable

public VectorAccessibleSerializable(WritableBatch batch,
 BufferAllocator allocator)

VectorAccessibleSerializable

public VectorAccessibleSerializable(WritableBatch batch,
 SelectionVector2 sv2,
 BufferAllocator allocator)

Creates a wrapper around batch and sv2 for writing to a stream. sv2 will never be released by this class, and ownership is maintained by caller.

Parameters:

batch -

sv2 -

allocator -

Method Details

readFromStream

public void readFromStream(InputStream input)
                    throws IOException

Reads from an InputStream and parses a RecordBatchDef. From this, we construct a SelectionVector2 if it exits and construct the vectors and add them to a vector container

Specified by:

readFromStream in interface DrillSerializable

Specified by:

readFromStream in class AbstractStreamSerializable

Parameters:

input - the InputStream to read from

Throws:

IOException

readFromStreamWithContainer

public void readFromStreamWithContainer(VectorContainer myContainer,
 InputStream input)
                                 throws IOException

Throws:

IOException

writeToStreamAndRetain

public void writeToStreamAndRetain(OutputStream output)
                            throws IOException

Throws:

IOException

writeToStream

public void writeToStream(OutputStream output)
                   throws IOException

Serializes the VectorAccessible va and writes it to an output stream

Specified by:

writeToStream in interface DrillSerializable

Specified by:

writeToStream in class AbstractStreamSerializable

Parameters:

output - the OutputStream to write to

Throws:

IOException

clear

public void clear()

get

public VectorContainer get()

getSv2

public SelectionVector2 getSv2()

getTimeNs

public long getTimeNs()

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

read

public void read(DataInput input)
          throws IOException

Specified by:

read in interface DrillSerializable

Throws:

IOException

write

public void write(DataOutput output)
           throws IOException

Specified by:

write in interface DrillSerializable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException