Package org.apache.arrow.adapter.jdbc.consumer

Class BaseConsumer<V extends ValueVector>

java.lang.Object

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

Type Parameters:

V - vector type.

All Implemented Interfaces:

AutoCloseable, JdbcConsumer<V>

Direct Known Subclasses:

ArrayConsumer, BinaryConsumer, BlobConsumer, ClobConsumer, Decimal256Consumer, DecimalConsumer, MapConsumer, NullConsumer

public abstract class BaseConsumer<V extends ValueVector>
extends Object
implements JdbcConsumer<V>

Base class for all consumers.

Field Summary

Fields

Modifier and Type	Field	Description
protected final int	columnIndexInResultSet
protected int	currentIndex
protected V	vector

Constructor Summary

Constructors

Constructor	Description
BaseConsumer(V vector, int index)	Constructs a new consumer.

Method Summary

Modifier and Type	Method	Description
void	close()	Close this consumer, do some clean work such as clear reuse ArrowBuf.
void	resetValueVector(V 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

vector

protected V extends ValueVector vector

columnIndexInResultSet

protected final int columnIndexInResultSet

currentIndex

protected int currentIndex

Constructor Details

BaseConsumer

public BaseConsumer(V vector,
 int index)

Constructs a new consumer.

Parameters:

vector - the underlying vector for the consumer.

index - the column id for the consumer.

Method Details

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<V extends ValueVector>

Throws:

Exception

resetValueVector

public void resetValueVector(V vector)

Description copied from interface: JdbcConsumer

Reset the vector within consumer for partial read purpose.

Specified by:

resetValueVector in interface JdbcConsumer<V extends ValueVector>