Package org.apache.arrow.adbc.driver.jdbc

Class JdbcArrowReader

java.lang.Object

org.apache.arrow.vector.ipc.ArrowReader

org.apache.arrow.adbc.driver.jdbc.JdbcArrowReader

All Implemented Interfaces:

AutoCloseable, org.apache.arrow.vector.dictionary.DictionaryProvider

public class JdbcArrowReader
extends org.apache.arrow.vector.ipc.ArrowReader

An ArrowReader that wraps a JDBC ResultSet.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.arrow.vector.dictionary.DictionaryProvider

org.apache.arrow.vector.dictionary.DictionaryProvider.MapDictionaryProvider

Field Summary

Fields inherited from class org.apache.arrow.vector.ipc.ArrowReader

allocator, dictionaries

Method Summary

Modifier and Type	Method	Description
long	bytesRead()
protected void	closeReadSource()
boolean	loadNextBatch()
protected org.apache.arrow.vector.types.pojo.Schema	readSchema()

Methods inherited from class org.apache.arrow.vector.ipc.ArrowReader

close, close, ensureInitialized, getDictionaryIds, getDictionaryVectors, getVectorSchemaRoot, initialize, loadDictionary, loadRecordBatch, lookup, prepareLoadNextBatch

Methods inherited from class java.lang.Object

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

Method Detail

loadNextBatch

public boolean loadNextBatch()

Specified by:

loadNextBatch in class org.apache.arrow.vector.ipc.ArrowReader

bytesRead

public long bytesRead()

Specified by:

bytesRead in class org.apache.arrow.vector.ipc.ArrowReader

closeReadSource

protected void closeReadSource()

Specified by:

closeReadSource in class org.apache.arrow.vector.ipc.ArrowReader

readSchema

protected org.apache.arrow.vector.types.pojo.Schema readSchema()

Specified by:

readSchema in class org.apache.arrow.vector.ipc.ArrowReader