org.apache.arrow.adapter.jdbc.consumer

Interface JdbcConsumer<T extends ValueVector>

Type Parameters:

T - The vector within consumer or its delegate, used for partially consume purpose.

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

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

public interface JdbcConsumer<T extends ValueVector>
extends AutoCloseable

An abstraction that is used to consume values from ResultSet.

Method Summary

Modifier and Type	Method and Description
void	close() Close this consumer, do some clean work such as clear reuse ArrowBuf.
void	consume(ResultSet resultSet) Consume a specific type value from ResultSet and write it to vector.
void	resetValueVector(T vector) Reset the vector within consumer for partial read purpose.

Method Detail

consume

void consume(ResultSet resultSet)
      throws SQLException,
             IOException

Consume a specific type value from ResultSet and write it to vector.

Throws:

SQLException

IOException

close

void close()
    throws Exception

Close this consumer, do some clean work such as clear reuse ArrowBuf.

Specified by:

close in interface AutoCloseable

Throws:

Exception

resetValueVector

void resetValueVector(T vector)

Reset the vector within consumer for partial read purpose.