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

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

public class FlightInfoReader
extends BaseFlightReader

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, clientCache

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

allocator, dictionaries

Method Summary

Modifier and Type	Method	Description
protected void	processRootFromStream(org.apache.arrow.vector.VectorSchemaRoot root)

Methods inherited from class org.apache.arrow.adbc.driver.flightsql.BaseFlightReader

addBytesRead, bytesRead, closeReadSource, loadNextBatch, loadRoot, populateEndpointData, 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

processRootFromStream

protected void processRootFromStream(org.apache.arrow.vector.VectorSchemaRoot root)

Specified by:

processRootFromStream in class BaseFlightReader