org.apache.arrow.adapter.jdbc.consumer

Class ArrayConsumer

java.lang.Object

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

org.apache.arrow.adapter.jdbc.consumer.ArrayConsumer

All Implemented Interfaces:

AutoCloseable, JdbcConsumer<ListVector>

public abstract class ArrayConsumer
extends BaseConsumer<ListVector>

Consumer which consume array type values from ResultSet. Write the data to ListVector.

Field Summary

Fields

Modifier and Type	Field and Description
protected JdbcConsumer	delegate
protected int	innerVectorIndex

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

columnIndexInResultSet, currentIndex, vector

Constructor Summary

Constructors

Constructor and Description
ArrayConsumer(ListVector vector, JdbcConsumer delegate, int index) Instantiate a ArrayConsumer.

Method Summary

Modifier and Type	Method and Description
void	close() Close this consumer, do some clean work such as clear reuse ArrowBuf.
static ArrayConsumer	createConsumer(ListVector vector, JdbcConsumer delegate, int index, boolean nullable) Creates a consumer for ListVector.
void	resetValueVector(ListVector 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

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

consume

Field Detail

delegate

protected final JdbcConsumer delegate

innerVectorIndex

protected int innerVectorIndex

Constructor Detail

ArrayConsumer

public ArrayConsumer(ListVector vector,
                     JdbcConsumer delegate,
                     int index)

Instantiate a ArrayConsumer.

Method Detail

createConsumer

public static ArrayConsumer createConsumer(ListVector vector,
                                           JdbcConsumer delegate,
                                           int index,
                                           boolean nullable)

Creates a consumer for ListVector.

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<ListVector>

Overrides:

close in class BaseConsumer<ListVector>

Throws:

Exception

resetValueVector

public void resetValueVector(ListVector vector)

Description copied from interface: JdbcConsumer

Reset the vector within consumer for partial read purpose.

Specified by:

resetValueVector in interface JdbcConsumer<ListVector>

Overrides:

resetValueVector in class BaseConsumer<ListVector>