org.apache.arrow.adapter.jdbc.consumer

Class BinaryConsumer

java.lang.Object

org.apache.arrow.adapter.jdbc.consumer.BaseConsumer<VarBinaryVector>

org.apache.arrow.adapter.jdbc.consumer.BinaryConsumer

All Implemented Interfaces:

AutoCloseable, JdbcConsumer<VarBinaryVector>

public abstract class BinaryConsumer
extends BaseConsumer<VarBinaryVector>

Consumer which consume binary type values from ResultSet. Write the data to VarBinaryVector.

Field Summary

Fields inherited from class org.apache.arrow.adapter.jdbc.consumer.BaseConsumer

columnIndexInResultSet, currentIndex, vector

Constructor Summary

Constructors

Constructor and Description
BinaryConsumer(VarBinaryVector vector, int index) Instantiate a BinaryConsumer.

Method Summary

Modifier and Type	Method and Description
void	consume(InputStream is) consume a InputStream.
static BinaryConsumer	createConsumer(VarBinaryVector vector, int index, boolean nullable) Creates a consumer for VarBinaryVector.
void	moveWriterPosition()
void	resetValueVector(VarBinaryVector vector) Reset the vector within consumer for partial read purpose.

Methods inherited from class org.apache.arrow.adapter.jdbc.consumer.BaseConsumer

close

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.arrow.adapter.jdbc.consumer.JdbcConsumer

consume

Constructor Detail

BinaryConsumer

public BinaryConsumer(VarBinaryVector vector,
                      int index)

Instantiate a BinaryConsumer.

Method Detail

createConsumer

public static BinaryConsumer createConsumer(VarBinaryVector vector,
                                            int index,
                                            boolean nullable)

Creates a consumer for VarBinaryVector.

consume

public void consume(InputStream is)
             throws IOException

consume a InputStream.

Throws:

IOException

moveWriterPosition

public void moveWriterPosition()

resetValueVector

public void resetValueVector(VarBinaryVector vector)

Description copied from interface: JdbcConsumer

Reset the vector within consumer for partial read purpose.

Specified by:

resetValueVector in interface JdbcConsumer<VarBinaryVector>

Overrides:

resetValueVector in class BaseConsumer<VarBinaryVector>