Êþº¾4
ÐÐ	ÑÒÓ

Ô	ÕÖ
Õ×
LØ

Ù	ÕÚÛÜÛÝÛÞä
åæçèé
ê
í
bî	ï	ð	ñ	ò	ó	ô	õö÷	øöù
úûÿç
	


&

&




&






	














&

/
	



	














:



 
!
>
"
b
#	
$
%


&
/
'Ò
(
)E
*
+
G
,ö
-
.
/
.
0
1
L
2	
3
4Ù
5

6
7

8
9

:
;
T
,	Õ
<


=	Õ
>
?
Y
,
@	
A
B

A
CÒ
D	
A
E
H
H
J
AddInfo
InnerClasses
STRING_VALUE_TYPE_ID

B

ConstantValue
ADBC_TO_FLIGHT_SQL_CODES
Ljava/util/Map;
	Signature
7Ljava/util/Map<Ljava/lang/Integer;Ljava/lang/Integer;>;
SUPPORTED_CODES
jLjava/util/Map<Ljava/lang/Integer;Lorg/apache/arrow/adbc/driver/flightsql/GetInfoMetadataReader$AddInfo;>;
DRIVER_NAME
[B
	allocator
)Lorg/apache/arrow/memory/BufferAllocator;
requestedCodes
Ljava/util/Collection;
+Ljava/util/Collection<Ljava/lang/Integer;>;
	infoCodes
%Lorg/apache/arrow/vector/UInt4Vector;
RuntimeVisibleTypeAnnotations
5Lorg/checkerframework/checker/nullness/qual/Nullable;

infoValues
2Lorg/apache/arrow/vector/complex/DenseUnionVector;
stringValues
'Lorg/apache/arrow/vector/VarCharVector;
hasInMemoryDataBeenWritten

Z
hasInMemoryData
hasSupportedCodes
hasRequestBeenIssued
CreateGetInfoMetadataReader
ã(Lorg/apache/arrow/memory/BufferAllocator;Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;Lcom/github/benmanes/caffeine/cache/LoadingCache;[I)Lorg/apache/arrow/adbc/driver/flightsql/GetInfoMetadataReader;
Code
LineNumberTable
LocalVariableTable
Ljava/util/LinkedHashSet;
client
GLorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;
clientCache
1Lcom/github/benmanes/caffeine/cache/LoadingCache;
[I
LocalVariableTypeTable
.Ljava/util/LinkedHashSet<Ljava/lang/Integer;>;
œLcom/github/benmanes/caffeine/cache/LoadingCache<Lorg/apache/arrow/flight/Location;Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;>;

StackMapTableÐ

N(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;>;[I)Lorg/apache/arrow/adbc/driver/flightsql/GetInfoMetadataReader;
<init>
º(Lorg/apache/arrow/memory/BufferAllocator;Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;Lcom/github/benmanes/caffeine/cache/LoadingCache;Ljava/util/Collection;)V
this
>Lorg/apache/arrow/adbc/driver/flightsql/GetInfoMetadataReader;é
K
L
M
N

:(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/Collection<Ljava/lang/Integer;>;)V
setStringValue
(I[B)V
index

I
value
RuntimeVisibleAnnotations
)Lorg/checkerframework/dataflow/qual/Pure;

loadNextBatch
()Z
root
*Lorg/apache/arrow/vector/VectorSchemaRoot;
dstIndex

e
*Lorg/apache/arrow/adbc/core/AdbcException;
O

 

Exceptions

readSchema
-()Lorg/apache/arrow/vector/types/pojo/Schema;
processRootFromStream
-(Lorg/apache/arrow/vector/VectorSchemaRoot;)V
addInfo
FLorg/apache/arrow/adbc/driver/flightsql/GetInfoMetadataReader$AddInfo;
srcIndex
sqlCode
sqlInfo
tmpRoot


issueGetSqlInfoRequest
o(Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;Ljava/util/Collection;)Ljava/util/List;
translatedCode
Ljava/lang/Integer;
code
translatedCodes
Ljava/util/List;
%Ljava/util/List<Ljava/lang/Integer;>;
P
Q
®(Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;Ljava/util/Collection<Ljava/lang/Integer;>;)Ljava/util/List<Lorg/apache/arrow/flight/FlightEndpoint;>;
lambda$new$2
lambda$static$1
u(Lorg/apache/arrow/adbc/driver/flightsql/GetInfoMetadataReader;Lorg/apache/arrow/vector/complex/DenseUnionVector;II)V

b
lambda$static$0
<clinit>
()V

SourceFile
GetInfoMetadataReader.java
java/util/LinkedHashSetmj
R
S
T”
U
Vo
W
X
Y
Z
[
\
]
^
W
_
`
a
b
c
d
e
BootstrapMethods
f
g
h
i
j
k
l
m
n
o
p
q
<org/apache/arrow/adbc/driver/flightsql/GetInfoMetadataReader”•
r
s
j
t”
uvwz{|}~‚stqr
N
v
]€
w
e
x
y
z
]	
{
|
}
~

€

‚
ƒ
„
…
†Ÿ
‡
ˆ
0org/apache/arrow/vector/complex/DenseUnionVector
‰
Y
Š
‹
Œ°±
O

Ž
Í

‘
#org/apache/arrow/vector/UInt4Vector
’
“
†
”opžŸ
0.0.1
•
–
—
˜
™
š
›
‚
œ³
Í
java/lang/Throwable
ž
Ÿ
 Í
(org/apache/arrow/adbc/core/AdbcException
java/io/IOException”
Ÿ¥¦
¡
¢
£
¤
Y
j
¥
j
¦
Dorg/apache/arrow/adbc/driver/flightsql/GetInfoMetadataReader$AddInfo
§É
java/util/ArrayList”Í
¨
©
Q
ª¦
«
g
java/lang/Integer
¬
Yij
P
"org/apache/arrow/flight/CallOption
L
­
®
¯
°
s¼½
java/lang/IllegalStateException
±
W
j
²
³
W
java/util/HashMap
ADBC Flight SQL Driver
µ
·
¸
¹
Y
º
»
¼
¸É
½
§
¾
¿
7org/apache/arrow/adbc/driver/flightsql/BaseFlightReader
'org/apache/arrow/memory/BufferAllocator
Eorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions
/com/github/benmanes/caffeine/cache/LoadingCache
java/util/Collection
(org/apache/arrow/vector/VectorSchemaRoot
java/util/List
java/util/Iterator

java/util/Map
keySet
()Ljava/util/Set;
(Ljava/util/Collection;)V
'org/apache/arrow/adbc/core/AdbcInfoCode
)Lorg/apache/arrow/adbc/core/AdbcInfoCode;
getValue
()I
valueOf
(I)Ljava/lang/Integer;
add
(Ljava/lang/Object;)Z
DRIVER_VERSION
java/util/stream/IntStream
of
 ([I)Ljava/util/stream/IntStream;
sorted
()Ljava/util/stream/IntStream;
boxed
()Ljava/util/stream/Stream;

À
Á
()Ljava/lang/Object;


,
()Ljava/util/LinkedHashSet;
get
()Ljava/util/function/Supplier;
java/util/stream/Collectors
toCollection
;(Ljava/util/function/Supplier;)Ljava/util/stream/Collector;
java/util/stream/Stream
collect
0(Ljava/util/stream/Collector;)Ljava/lang/Object;

Â
()Ljava/util/List;
|(Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;Ljava/util/Collection;)Ljava/util/function/Supplier;
Á(Lorg/apache/arrow/memory/BufferAllocator;Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;Lcom/github/benmanes/caffeine/cache/LoadingCache;Ljava/util/function/Supplier;)V
contains
stream
java/lang/Object
getClass
()Ljava/lang/Class;Ò
Ã
(Ljava/lang/Integer;)Z
test
/(Ljava/util/Map;)Ljava/util/function/Predicate;
anyMatch
!(Ljava/util/function/Predicate;)Z

setValueCount
(I)V
	setTypeId
(IB)V
%org/apache/arrow/vector/VarCharVector
setSafe
getOffsetBuffer
$()Lorg/apache/arrow/memory/ArrowBuf;

getLastSet
 org/apache/arrow/memory/ArrowBuf
setInt
(JI)V
create
€(Lorg/apache/arrow/vector/types/pojo/Schema;Lorg/apache/arrow/memory/BufferAllocator;)Lorg/apache/arrow/vector/VectorSchemaRoot;
allocateNew
	getVector
((I)Lorg/apache/arrow/vector/FieldVector;
getVarCharVector
*(B)Lorg/apache/arrow/vector/VarCharVector;
(II)V
!java/nio/charset/StandardCharsets
UTF_8
Ljava/nio/charset/Charset;
java/lang/String
getBytes
(Ljava/nio/charset/Charset;)[B
setRowCount
loadRoot
close

addSuppressed
(Ljava/lang/Throwable;)V
populateEndpointData
*org/apache/arrow/adbc/core/StandardSchemas
GET_INFO_SCHEMA
+Lorg/apache/arrow/vector/types/pojo/Schema;
getRowCount
(I)I
&(Ljava/lang/Object;)Ljava/lang/Object;
accept
iterator
()Ljava/util/Iterator;
hasNext
next
intValue

getSqlInfo
_(Ljava/lang/Iterable;[Lorg/apache/arrow/flight/CallOption;)Lorg/apache/arrow/flight/FlightInfo;
"org/apache/arrow/flight/FlightInfo
getEndpoints
VENDOR_VERSION
(I)[B
VENDOR_NAME
Ä
2org/apache/arrow/flight/sql/impl/FlightSql$SqlInfo
SqlInfo
FLIGHT_SQL_SERVER_NAME
4Lorg/apache/arrow/flight/sql/impl/FlightSql$SqlInfo;
	getNumber
put
8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
FLIGHT_SQL_SERVER_VERSION

Å
H()Lorg/apache/arrow/adbc/driver/flightsql/GetInfoMetadataReader$AddInfo;

Æ
Ç
È
Ëǽ
Ì
]
*org/apache/arrow/flight/sql/impl/FlightSqlËÉÈÉ
"java/lang/invoke/LambdaMetafactory
metafactory
Î
Lookup
Ì(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
containsKey
Ï
%java/lang/invoke/MethodHandles$Lookup
java/lang/invoke/MethodHandles0b
ef
ghij
klmj
knopqrst
kuvw
x
yz{
x
y|}
x
y~€‚ƒ„…
c-Ç5»
Y²¹
·:²¶¸¶W²	¶¸¶W§#-¸
¹
¹
º
¸¹À
:»Y*+,·°†*
fgh$i6k7l:m?nIoVr‡>!sˆcqrc‰Š
c‹ŒcvV
sˆŽ !sc‹V
s‘	6ü’k“x	
y”•…
]€*+,-,º·*
µ*
µ*
µ*µ*µ*µ*+µ*²¶¸¹š²	¶¸¹™§µ*¹
²Y¶Wº¹ µ!±†6
z789:#=({.|3}9~Lb€‡4€–—€qr
€‰Š€‹Œ€stŽ€‹€su‘9ÿZ˜™š›œ
˜C˜ÿ˜™š›œ˜
kžŸ…Š4*´`¶"*´¶#*´,¶$*´¶%…'i*´¶)¶*±†ˆ
‰Š‹ Œ-3Ž‡ 4–—4 ¡
4¢p£
¤
¥¦…‰
0*´™

*´šú*µ<*¶+*´¸,M
N,¶-*,¶.À/µ*,¶.À&µ**´¶0µ*´²¶¸¹™*´²¶¶1*„

²2¶3*´²	¶¸¹™!*´²	¶¶1*„

4²5¶6¶3,¶7*,¶86,Æ-Æ,¶9§:-¶;§,¶9¬:N¿:,Æ-Æ,¶9§:-¶;§,¶9¿*´!™%*´š*µ*¶<§
L»>Y+·?¿*·@¬¬ÁÅÈ:#¹Ú:#¹âìðó:Úäâ


=†z–š›œ#'ž3Ÿ? K¢`£n¤y§Ž¨œª¬¬±­¶®¹¯×®Úœâ¯
²
³
´
¶
¹
·
 ¸
)»
.¾‡*!䧨ð©¡

 	ª«

0–—‘gþy
¬­2ÿ˜
¬­

­
ÿ˜
¬­
­G­ÿ˜
¬­­
­
ÿ
˜Y®	¯
>°±
….

²A°†
Ç
–—²³
…7ä*¶+*´¸,M
N+¶-*,¶.À/µ*,¶.À&µ**´¶0µ6+¶.À/:+¶.À&:6+¶B¢6²¶C¸¹DÀE:Æ*„
¹F„
§ÿÇ,¶7*,¶8,ÆK-Æ,¶9§@:-¶;§5,¶9§.:N¿:	,Æ-Æ,¶9§:
-
¶;§,¶9	¿±Ÿ£¦:—¸:—ÀÊÎÑ:¸ÂÀ†NÈÉÊË*Ì6Î9ÏCÐMÑYÒpÓuԆьؒٗڸÈÀÚãۇRp´µP<¶¡9^©¡CT·wMJ¸{×¹¨䖗䧨
‘mÿP˜¬¬­
º»
5úÿ˜¬¬­
­
F­G­ÿ
˜¬¬­­
­
ÿ˜¬
¼½…ñV»GY·HM+¹I
N-¹J
™4-¹K
ÀL¶M6²N¸¹DÀL:Æ,¹OW§ÿÉ*,½P¶Q¶R°†ßà&á8â=ãFåIç‡48¾¿& À¡V‰ŠVst
NÁÂŽVsu
NÁÑýÄÅ6úkÆ
ǽ
…:*+¸S°†
z‡‰Šst

ÈÉ
…,*´Ç»TY·U¿*´²V¶¶1*+¶0¶W¶3±†XY[\+]‡*,ʗ,¸{
,¶¡,©¡‘

ËÉ
…,*´Ç»TY·U¿*´²X¶¶1*+¶0¶W¶3±†OPRS+T‡*,ʗ,¸{
,¶¡,©¡‘
ÌÍ
…à„»YY·Z³N»YY·Z³[²5¶6³2²N²X¶¸²\¶]¸¹^W²N²V¶¸²_¶]¸¹^W²²\¶]¸º`¹^W²²_¶]¸ºa¹^W±
†J0
123F%G4F:H@IIJOHUL[MfLlUrV}Uƒ^ÎÏdEc
A
´
¶@
É
Í
Êß4àáâãàáëìàüýþà
F
G
Fà
F
I
F