Class FlightInfoReader
java.lang.Object
org.apache.arrow.vector.ipc.ArrowReader
org.apache.arrow.adbc.driver.flightsql.BaseFlightReader
org.apache.arrow.adbc.driver.flightsql.FlightInfoReader
- All Implemented Interfaces:
AutoCloseable,org.apache.arrow.vector.dictionary.DictionaryProvider
An ArrowReader that wraps a FlightInfo.
-
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.adbc.driver.flightsql.BaseFlightReader
client, clientCacheFields inherited from class org.apache.arrow.vector.ipc.ArrowReader
allocator, dictionaries -
Method Summary
Modifier and TypeMethodDescriptionprotected voidprocessRootFromStream(org.apache.arrow.vector.VectorSchemaRoot root) Methods inherited from class org.apache.arrow.adbc.driver.flightsql.BaseFlightReader
addBytesRead, bytesRead, closeReadSource, loadNextBatch, loadRoot, populateEndpointData, readSchemaMethods inherited from class org.apache.arrow.vector.ipc.ArrowReader
close, close, ensureInitialized, getDictionaryIds, getDictionaryVectors, getVectorSchemaRoot, initialize, loadDictionary, loadRecordBatch, lookup, prepareLoadNextBatch
-
Method Details
-
processRootFromStream
protected void processRootFromStream(org.apache.arrow.vector.VectorSchemaRoot root) - Specified by:
processRootFromStreamin classBaseFlightReader
-