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, 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 and Description
protected int	columnIndexInResultSet
protected int	currentIndex
protected V	vector

Constructor Summary

Constructors

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

Method Summary

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

vector

protected V extends ValueVector vector

columnIndexInResultSet

protected final int columnIndexInResultSet

currentIndex

protected int currentIndex

Constructor Detail

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 Detail

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>