Module org.apache.arrow.adapter.jdbc

Package 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	Description
protected final JdbcConsumer	delegate
protected int	innerVectorIndex

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

columnIndexInResultSet, currentIndex, vector

Constructor Summary

Constructors

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

Method Summary

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

delegate

protected final JdbcConsumer delegate

innerVectorIndex

protected int innerVectorIndex

Constructor Details

ArrayConsumer

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

Instantiate a ArrayConsumer.

Method Details

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>