Êþº¾4à
5y	4z	4{	4|	4}	4~	4€
	4‚	4ƒ„

…†‡ˆ
…‰‡Š‹
Œ
…Ž
‘’
“
”
•–
—
˜™
š
…›
4œ
žŸ ¡¢‡£¤
Œ¥¦
§	¨©
*ª«
.¬
.­
®¯
4°
4±²³
flightEndpoints
Ljava/util/List;
	Signature
:Ljava/util/List<Lorg/apache/arrow/flight/FlightEndpoint;>;
rpcCall
Ljava/util/function/Supplier;
YLjava/util/function/Supplier<Ljava/util/List<Lorg/apache/arrow/flight/FlightEndpoint;>;>;
nextEndpointIndex

I

currentStream
&Lorg/apache/arrow/flight/FlightStream;
RuntimeVisibleTypeAnnotations
5Lorg/checkerframework/checker/nullness/qual/Nullable;
schema
+Lorg/apache/arrow/vector/types/pojo/Schema;
	bytesRead

J
client
GLorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;
clientCache
1Lcom/github/benmanes/caffeine/cache/LoadingCache;
œLcom/github/benmanes/caffeine/cache/LoadingCache<Lorg/apache/arrow/flight/Location;Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;>;
<init>
Á(Lorg/apache/arrow/memory/BufferAllocator;Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;Lcom/github/benmanes/caffeine/cache/LoadingCache;Ljava/util/function/Supplier;)V
Code
LineNumberTable
LocalVariableTable
this
9Lorg/apache/arrow/adbc/driver/flightsql/BaseFlightReader;
	allocator
)Lorg/apache/arrow/memory/BufferAllocator;
LocalVariableTypeTable

h(Lorg/apache/arrow/memory/BufferAllocator;Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;Lcom/github/benmanes/caffeine/cache/LoadingCache<Lorg/apache/arrow/flight/Location;Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;>;Ljava/util/function/Supplier<Ljava/util/List<Lorg/apache/arrow/flight/FlightEndpoint;>;>;)V

loadNextBatch
()Z
endpoint
(Lorg/apache/arrow/flight/FlightEndpoint;

e
Ljava/io/IOException;
Ljava/lang/Exception;

StackMapTable‹‘™

Exceptions

readSchema
-()Lorg/apache/arrow/vector/types/pojo/Schema;
()J
closeReadSource
()V
processRootFromStream
-(Lorg/apache/arrow/vector/VectorSchemaRoot;)V
addBytesRead
(J)V
bytes
populateEndpointData
0Lorg/apache/arrow/flight/FlightRuntimeException;¤
loadRoot
root
*Lorg/apache/arrow/vector/VectorSchemaRoot;
unloader
(Lorg/apache/arrow/vector/VectorUnloader;
recordBatch
6Lorg/apache/arrow/vector/ipc/message/ArrowRecordBatch;

SourceFile
BaseFlightReader.javaL´=>?@CDEFGHIJ
java/util/ArrayListLg67:;
java/lang/IllegalStateExceptionµ¶X·¸¹ºg»¼
&org/apache/arrow/flight/FlightEndpoint½¾¿ÀdÁÂÃ
java/io/IOException
java/lang/StringBuilder
*Stream has inconsistent schema. Expected: ÄÅÄÆ

Found: ÇÈLÉ
java/lang/ExceptionLÊËÌhi
java/lang/AutoCloseableÍºÎÏ»Ð
java/util/CollectionÑÒ
.org/apache/arrow/flight/FlightRuntimeExceptionÓÔ
(org/apache/arrow/adbc/core/AdbcExceptionÕÈÖ×ØLÙ
&org/apache/arrow/vector/VectorUnloaderLiÚÛÜÝejkÞß
7org/apache/arrow/adbc/driver/flightsql/BaseFlightReader
'org/apache/arrow/vector/ipc/ArrowReader
,(Lorg/apache/arrow/memory/BufferAllocator;)V
$org/apache/arrow/flight/FlightStream
next
java/util/List
size
()I
close
get
(I)Ljava/lang/Object;
:org/apache/arrow/adbc/driver/flightsql/FlightSqlDriverUtil
tryLoadNextStream
È(Lorg/apache/arrow/flight/FlightEndpoint;Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;Lcom/github/benmanes/caffeine/cache/LoadingCache;)Lorg/apache/arrow/flight/FlightStream;
	getSchema
)org/apache/arrow/vector/types/pojo/Schema
equals
(Ljava/lang/Object;)Z
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
-(Ljava/lang/Object;)Ljava/lang/StringBuilder;
toString
()Ljava/lang/String;
(Ljava/lang/String;)V
(Ljava/lang/Throwable;)V
getRoot
,()Lorg/apache/arrow/vector/VectorSchemaRoot;
$org/apache/arrow/util/AutoCloseables
([Ljava/lang/AutoCloseable;)V
java/util/function/Supplier
()Ljava/lang/Object;
addAll
(Ljava/util/Collection;)Z
fromFlightException
\(Lorg/apache/arrow/flight/FlightRuntimeException;)Lorg/apache/arrow/adbc/core/AdbcException;

getMessage
)org/apache/arrow/adbc/core/AdbcStatusCode
IO
+Lorg/apache/arrow/adbc/core/AdbcStatusCode;
h(Ljava/lang/String;Ljava/lang/Throwable;Lorg/apache/arrow/adbc/core/AdbcStatusCode;Ljava/lang/String;I)V
getRecordBatch
8()Lorg/apache/arrow/vector/ipc/message/ArrowRecordBatch;
4org/apache/arrow/vector/ipc/message/ArrowRecordBatch
computeBodyLength
loadRecordBatch
9(Lorg/apache/arrow/vector/ipc/message/ArrowRecordBatch;)V!4567
89:;
8<=>?@
A
BCD
A
BEFGHIJ
8K	LMNÇ5*+·
*µ*
µ*
µ*	µ*,µ*-µ*»Y·	µ
*µ±O*
:.
/01;<#=.>4?P45QR5ST
5GH5IJ5:;U5IK5:<8V
WXN
ŒË*´Æ
*´Ç»Y·
¿*´¶š¡*´*´
¹
¡¬*´¶*´
*Y´Z`µ¹ÀL*+*´*´¸µ*´Ç»Y·
¿*´*´¶¶š0»Y»Y·¶*´¶¶*´¶¶¶·¿§L+¿L»Y+· ¿**´¶!¶"¬2®±2®´ORGHK L0M2P9QQRaShTpVW¡[®a±]²^´_µ`¾dÉeP*Q]YZ
²[\
µ	[]
ËQR^ü=_ú=B`Ba	b
cdNO
*´Ç»Y·
¿*´°OjkmP
QR^
b

Ee
N/
*´­O
rP
QRfgNu½#Y*´S¸$§
L»Y+· ¿±
Ox{yz|P	[]
QR^Qa	b
hijk
NC*Y´aµ±O

‚PQRlF
mgNéd*´
*´¹%
À&¹'W**´
*Y´Z`µ¹À*´*´¸µ**´¶µ§L+¸)¿L»*Y+¶++²,
·-¿±GJ(GPO*
†‡&ˆ<‰GŽJŠK‹PŒQcP K[n
Q[\
dQR^
÷JoE`b
*pi
Nt».Y+·/M,¶0N*-¶1¶2*-¶3±O’	“”•–P*QRqr
	stuv
wx