Package org.apache.arrow.adbc.driver.flightsql

Class BaseFlightReader

java.lang.Object

org.apache.arrow.vector.ipc.ArrowReader

org.apache.arrow.adbc.driver.flightsql.BaseFlightReader

All Implemented Interfaces:

AutoCloseable, DictionaryProvider

Direct Known Subclasses:

FlightInfoReader

public abstract class BaseFlightReader
extends ArrowReader

Base class for ArrowReaders based on consuming data from FlightEndpoints.

Nested Class Summary

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

DictionaryProvider.MapDictionaryProvider

Method Summary

Modifier and Type	Method	Description
long	bytesRead()
boolean	loadNextBatch()

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

close, close, getDictionaryIds, getDictionaryVectors, getVectorSchemaRoot, lookup

Methods inherited from class java.lang.Object

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

Method Details

loadNextBatch

public boolean loadNextBatch()
                      throws IOException

Specified by:

loadNextBatch in class ArrowReader

Throws:

IOException

bytesRead

public long bytesRead()

Specified by:

bytesRead in class ArrowReader