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

Class CompositeJdbcConsumer

java.lang.Object

org.apache.arrow.adapter.jdbc.consumer.CompositeJdbcConsumer

All Implemented Interfaces:

AutoCloseable, JdbcConsumer

public class CompositeJdbcConsumer
extends Object
implements JdbcConsumer

Composite consumer which hold all consumers. It manages the consume and cleanup process.

Constructor Summary

Constructors

Constructor	Description
CompositeJdbcConsumer(JdbcConsumer[] consumers)	Construct an instance.

Method Summary

Modifier and Type	Method	Description
void	close()	Close this consumer, do some clean work such as clear reuse ArrowBuf.
void	consume(ResultSet rs)	Consume a specific type value from ResultSet and write it to vector.
void	resetValueVector(ValueVector vector)	Reset the vector within consumer for partial read purpose.
void	resetVectorSchemaRoot(VectorSchemaRoot root)	Reset inner consumers through vectors in the vector schema root.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CompositeJdbcConsumer

public CompositeJdbcConsumer(JdbcConsumer[] consumers)

Construct an instance.

Method Details

consume

public void consume(ResultSet rs)
             throws SQLException,
IOException

Description copied from interface: JdbcConsumer

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

Specified by:

consume in interface JdbcConsumer

Throws:

SQLException

IOException

close

public void close()

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

resetValueVector

public void resetValueVector(ValueVector vector)

Description copied from interface: JdbcConsumer

Reset the vector within consumer for partial read purpose.

Specified by:

resetValueVector in interface JdbcConsumer

resetVectorSchemaRoot

public void resetVectorSchemaRoot(VectorSchemaRoot root)

Reset inner consumers through vectors in the vector schema root.