org.apache.arrow.adapter.jdbc.consumer

Class BlobConsumer

java.lang.Object

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

org.apache.arrow.adapter.jdbc.consumer.BlobConsumer

All Implemented Interfaces:

AutoCloseable, JdbcConsumer<VarBinaryVector>

public class BlobConsumer
extends BaseConsumer<VarBinaryVector>

Consumer which consume blob 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
BlobConsumer(BinaryConsumer delegate, int index, boolean nullable) Instantiate a BlobConsumer.

Method Summary

Modifier and Type	Method and Description
void	close() Close this consumer, do some clean work such as clear reuse ArrowBuf.
void	consume(ResultSet resultSet) Consume a specific type value from ResultSet and write it to vector.
static BlobConsumer	createConsumer(BinaryConsumer delegate, int index, boolean nullable) Creates a consumer for VarBinaryVector.
void	resetValueVector(VarBinaryVector vector) Reset the vector within consumer for partial read purpose.

Methods inherited from class java.lang.Object

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

Constructor Detail

BlobConsumer

public BlobConsumer(BinaryConsumer delegate,
                    int index,
                    boolean nullable)

Instantiate a BlobConsumer.

Method Detail

createConsumer

public static BlobConsumer createConsumer(BinaryConsumer delegate,
                                          int index,
                                          boolean nullable)

Creates a consumer for VarBinaryVector.

consume

public void consume(ResultSet resultSet)
             throws SQLException,
                    IOException

Description copied from interface: JdbcConsumer

Consume a specific type value from ResultSet and write it to vector.

Throws:

SQLException

IOException

close

public void close()
           throws Exception

Description copied from interface: JdbcConsumer

Close this consumer, do some clean work such as clear reuse ArrowBuf.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface JdbcConsumer<VarBinaryVector>

Overrides:

close in class BaseConsumer<VarBinaryVector>

Throws:

Exception

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>