org.apache.arrow.adapter.jdbc.consumer

Class ClobConsumer

java.lang.Object

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

org.apache.arrow.adapter.jdbc.consumer.ClobConsumer

All Implemented Interfaces:

AutoCloseable, JdbcConsumer<VarCharVector>

public abstract class ClobConsumer
extends BaseConsumer<VarCharVector>

Consumer which consume clob type values from ResultSet. Write the data to VarCharVector.

Field Summary

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

columnIndexInResultSet, currentIndex, vector

Constructor Summary

Constructors

Constructor and Description
ClobConsumer(VarCharVector vector, int index) Instantiate a ClobConsumer.

Method Summary

Modifier and Type	Method and Description
static ClobConsumer	createConsumer(VarCharVector vector, int index, boolean nullable) Creates a consumer for VarCharVector.
void	resetValueVector(VarCharVector vector) Reset the vector within consumer for partial read purpose.

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

close

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

Constructor Detail

ClobConsumer

public ClobConsumer(VarCharVector vector,
                    int index)

Instantiate a ClobConsumer.

Method Detail

createConsumer

public static ClobConsumer createConsumer(VarCharVector vector,
                                          int index,
                                          boolean nullable)

Creates a consumer for VarCharVector.

resetValueVector

public void resetValueVector(VarCharVector vector)

Description copied from interface: JdbcConsumer

Reset the vector within consumer for partial read purpose.

Specified by:

resetValueVector in interface JdbcConsumer<VarCharVector>

Overrides:

resetValueVector in class BaseConsumer<VarCharVector>