Why Gemfury? Push, build, and install  RubyGems npm packages Python packages Maven artifacts PHP packages Go Modules Bower components Debian packages RPM packages NuGet packages

arrow-adbc-nightlies / org.apache.arrow.adbc/adbc-driver-flight-sql   maven

Repository URL to install this package:

Version: 1.0.0-20240522.011733-39 

/ org / apache / arrow / adbc / driver / flightsql / FlightSqlConnection.class

Êþº¾4´
UGH
I	£J	£K	£L	£MN	£OP
£Q

RS

T	£U
VW	XY
VZ`
Vae
Vf	£ghij
Skl
m
Øn
Øop
Øqrstutvx
&y
!z{|
Ø}
~
€
*‚
)ƒ„…†
2G‡
2ˆ
@‰
2Š
S‹
SŒ
Ž
:
‘
’“
”•–—
S˜h™š
›œ
2ž
2Ÿ	j 
¡¢£
£¤	£¥	j¦	£§	j¨	£©ª«¬­
¡®
i¯	°±
S²	³´	jµ
³¶¸
]G	£¹
£º»
aG¼
cG½¾¿sÀgÁÂÃÄ
iÅ
iÆ
iÇgÈ
cɽ
cÊË	°ÌÍ
uÎ
aÏ	ÐÑ	ÐÒ
ÓÔÕÖ
|×
{Ø
ÙÚ
aÛ»
ÓÜÝÞ
ƒz
Óßà
á
2âãäãå
2æ
2çè
Ž‚
2éê
2ë	jì
2í	jî
2ï
2ð
2ñ
Kòó
šô
šõ

ö÷
øù
øúû
¡üýþ	allocator)Lorg/apache/arrow/memory/BufferAllocator;counter+Ljava/util/concurrent/atomic/AtomicInteger;clientGLorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;quirks%Lorg/apache/arrow/adbc/sql/SqlQuirks;
parametersLjava/util/Map;	Signature5Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;clientCache1Lcom/github/benmanes/caffeine/cache/LoadingCache;œLcom/github/benmanes/caffeine/cache/LoadingCache<Lorg/apache/arrow/flight/Location;Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;>;cookieMiddlewareFactoryFactoryInnerClasses?Lorg/apache/arrow/flight/client/ClientCookieMiddleware$Factory;RuntimeVisibleTypeAnnotations5Lorg/checkerframework/checker/nullness/qual/Nullable;callOptions%[Lorg/apache/arrow/flight/CallOption;mtlsCertChainBytes[BmtlsPrivateKeyBytestlsRootCertsBytes<init>‚(Lorg/apache/arrow/memory/BufferAllocator;Lorg/apache/arrow/adbc/sql/SqlQuirks;Lorg/apache/arrow/flight/Location;Ljava/util/Map;)VCodeLineNumberTableLocalVariableTablethis<Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlConnection;location"Lorg/apache/arrow/flight/Location;flightSqlClient-Lorg/apache/arrow/flight/sql/FlightSqlClient;LocalVariableTypeTable
Exceptions¨(Lorg/apache/arrow/memory/BufferAllocator;Lorg/apache/arrow/adbc/sql/SqlQuirks;Lorg/apache/arrow/flight/Location;Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;)Vcommit()VcreateStatement,()Lorg/apache/arrow/adbc/core/AdbcStatement;
readPartition@(Ljava/nio/ByteBuffer;)Lorg/apache/arrow/vector/ipc/ArrowReader;
protoLocationLocation.Lorg/apache/arrow/flight/impl/Flight$Location;
protoEndpointÿFlightEndpoint4Lorg/apache/arrow/flight/impl/Flight$FlightEndpoint;	locations#[Lorg/apache/arrow/flight/Location;indexIendpoint(Lorg/apache/arrow/flight/FlightEndpoint;eLjava/lang/Exception;
descriptorLjava/nio/ByteBuffer;
StackMapTableýÿÜ–{
bulkIngesti(Ljava/lang/String;Lorg/apache/arrow/adbc/core/BulkIngestMode;)Lorg/apache/arrow/adbc/core/AdbcStatement;targetTableNameLjava/lang/String;mode+Lorg/apache/arrow/adbc/core/BulkIngestMode;
getObjectsGetObjectsDepthÁ(Lorg/apache/arrow/adbc/core/AdbcConnection$GetObjectsDepth;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;Ljava/lang/String;)Lorg/apache/arrow/vector/ipc/ArrowReader;depth;Lorg/apache/arrow/adbc/core/AdbcConnection$GetObjectsDepth;catalogPatterndbSchemaPatterntableNamePattern
tableTypes[Ljava/lang/String;columnNamePatterngetInfo-([I)Lorg/apache/arrow/vector/ipc/ArrowReader;	infoCodes[Irollback
getAutoCommit()Z
setAutoCommit(Z)VenableAutoCommitZclosetoString()Ljava/lang/String;createInitialConnectionJ(Lorg/apache/arrow/flight/Location;)Lorg/apache/arrow/flight/FlightClient;
mtlsCertChainLjava/io/InputStream;mtlsPrivateKeytlsRootCertsexLjava/io/IOException;useCookieMiddlewareuserHeaderName	parameterEntryLjava/util/Map$Entry;bearerTokenLjava/util/Optional;&Lorg/apache/arrow/flight/FlightClient;optionsLjava/util/ArrayList;callHeaders+Lorg/apache/arrow/flight/FlightCallHeaders;usernamepassword;Ljava/util/Map$Entry<Ljava/lang/String;Ljava/lang/Object;>;ILjava/util/Optional<Lorg/apache/arrow/flight/grpc/CredentialCallOption;>;;Ljava/util/ArrayList<Lorg/apache/arrow/flight/CallOption;>;£ªp»¼ÀÂHLorg/checkerframework/checker/initialization/qual/UnknownInitialization;buildClienthostnameOverridebuilderBuilder.Lorg/apache/arrow/flight/FlightClient$Builder;inputStreamToBytes(Ljava/io/InputStream;)[BstreambytesdataInputStreamLjava/io/DataInputStream;lambda$new$1k(Lorg/apache/arrow/flight/Location;)Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;loclambda$new$0(Lorg/apache/arrow/flight/Location;Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;Lcom/github/benmanes/caffeine/cache/RemovalCause;)Vkeyvaluecause1Lcom/github/benmanes/caffeine/cache/RemovalCause;
SourceFileFlightSqlConnection.javaÀÏ)java/util/concurrent/atomic/AtomicIntegerÀ§¨¥¦«¬­®"org/apache/arrow/flight/CallOptionº»+org/apache/arrow/flight/sql/FlightSqlClient
ÀEorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptionsÀ©ª	

BootstrapMethods@=±²2[Flight SQL] Transaction methods are not supported !9org/apache/arrow/adbc/driver/flightsql/FlightSqlStatementÀ"#$%& org/apache/arrow/flight/Location'()*+,-./,org/apache/arrow/flight/impl/Flight$Location0À1&org/apache/arrow/flight/FlightEndpointorg/apache/arrow/flight/Ticket24526789À:À;2com/google/protobuf/InvalidProtocolBufferExceptionjava/net/URISyntaxExceptionjava/lang/StringBuilder.[Flight SQL] Partition descriptor is invalid: <=>?!@A7org/apache/arrow/adbc/driver/flightsql/FlightInfoReaderBCDÀEFGHIJKLMjava/lang/Exception[Flight SQL] Failed to get infoN!OÏjava/lang/AutoCloseableP
QFlightSqlConnection{client=<R<STUVWXjava/io/InputStream67¼½YU¾½ZU¿½java/io/IOException(org/apache/arrow/adbc/core/AdbcException7Error reading stream for one of the options %s, %s, %s.java/lang/Object[\]^_`ÀabcdeUfgh=org/apache/arrow/flight/client/ClientCookieMiddleware$Factory´·/java/util/ArrayList)org/apache/arrow/flight/FlightCallHeadersijkljava/util/Map$Entry[.java/lang/StringDorg/apache/arrow/adbc/driver/flightsql/FlightSqlConnectionProperties adbc.flight.sql.rpc.call_header.mno&pqr.stsuBHeader values must be String or byte[]. The header failing was %s.v`(org/apache/arrow/flight/HeaderCallOptionÀwxgyzU{U|}1org/apache/arrow/flight/grpc/CredentialCallOption7org/apache/arrow/flight/auth2/BasicAuthCredentialWriterÀtÀ~€‚ƒ„java/lang/IllegalStateException-Internal error: allocator was not initialized1…adbc-flightclient-connection-†&<‡ˆ‰Š‹Œ¥ÇŽjava/io/ByteArrayInputStream9Must provide both %s and %s or neither. %s provided only.‘’“U”•–U—˜™›œ&java/io/DataInputStreamÀžŸ:
Ïjava/lang/InterruptedException ¡¢£Ïjava/lang/RuntimeExceptionÀ¤:org/apache/arrow/adbc/driver/flightsql/FlightSqlConnection)org/apache/arrow/adbc/core/AdbcConnection2org/apache/arrow/flight/impl/Flight$FlightEndpointjava/nio/ByteBufferjava/util/Iterator9org/apache/arrow/adbc/core/AdbcConnection$GetObjectsDepth$org/apache/arrow/flight/FlightClient,org/apache/arrow/flight/FlightClient$Builder(I)V)(Lorg/apache/arrow/flight/FlightClient;)VU(Lorg/apache/arrow/flight/sql/FlightSqlClient;[Lorg/apache/arrow/flight/CallOption;)V+com/github/benmanes/caffeine/cache/Caffeine
newBuilder/()Lcom/github/benmanes/caffeine/cache/Caffeine;java/util/concurrent/TimeUnitMINUTESLjava/util/concurrent/TimeUnit;expireAfterAccessO(JLjava/util/concurrent/TimeUnit;)Lcom/github/benmanes/caffeine/cache/Caffeine;
¥¦X(Ljava/lang/Object;Ljava/lang/Object;Lcom/github/benmanes/caffeine/cache/RemovalCause;)V
£§	onRemoval6()Lcom/github/benmanes/caffeine/cache/RemovalListener;removalListenerc(Lcom/github/benmanes/caffeine/cache/RemovalListener;)Lcom/github/benmanes/caffeine/cache/Caffeine;&(Ljava/lang/Object;)Ljava/lang/Object;
£¨loadn(Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlConnection;)Lcom/github/benmanes/caffeine/cache/CacheLoader;buildc(Lcom/github/benmanes/caffeine/cache/CacheLoader;)Lcom/github/benmanes/caffeine/cache/LoadingCache;/com/github/benmanes/caffeine/cache/LoadingCacheput'(Ljava/lang/Object;Ljava/lang/Object;)VnotImplemented>(Ljava/lang/String;)Lorg/apache/arrow/adbc/core/AdbcException;É(Lorg/apache/arrow/memory/BufferAllocator;Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;Lcom/github/benmanes/caffeine/cache/LoadingCache;Lorg/apache/arrow/adbc/sql/SqlQuirks;)V	parseFromK(Ljava/nio/ByteBuffer;)Lorg/apache/arrow/flight/impl/Flight$FlightEndpoint;getLocationCount()IgetLocationList()Ljava/util/List;java/util/Listiterator()Ljava/util/Iterator;hasNextnext()Ljava/lang/Object;#org/apache/arrow/flight/impl/FlightgetUri(Ljava/lang/String;)V	getTicketTicket.()Lorg/apache/arrow/flight/impl/Flight$Ticket;*org/apache/arrow/flight/impl/Flight$Ticket"()Lcom/google/protobuf/ByteString;com/google/protobuf/ByteStringtoByteArray()[B([B)VF(Lorg/apache/arrow/flight/Ticket;[Lorg/apache/arrow/flight/Location;)Vappend-(Ljava/lang/String;)Ljava/lang/StringBuilder;
getMessageinvalidArgument	withCauseA(Ljava/lang/Throwable;)Lorg/apache/arrow/adbc/core/AdbcException;java/util/Collections
singletonList$(Ljava/lang/Object;)Ljava/util/List;´(Lorg/apache/arrow/memory/BufferAllocator;Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;Lcom/github/benmanes/caffeine/cache/LoadingCache;Ljava/util/List;)V
ingestRoot@(Lorg/apache/arrow/memory/BufferAllocator;Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;Lcom/github/benmanes/caffeine/cache/LoadingCache;Lorg/apache/arrow/adbc/sql/SqlQuirks;Ljava/lang/String;Lorg/apache/arrow/adbc/core/BulkIngestMode;)Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlStatement;@org/apache/arrow/adbc/driver/flightsql/GetObjectsMetadataReadersCreateGetObjectsReaderb(Lorg/apache/arrow/memory/BufferAllocator;Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;Lcom/github/benmanes/caffeine/cache/LoadingCache;Lorg/apache/arrow/adbc/core/AdbcConnection$GetObjectsDepth;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;Ljava/lang/String;)Lorg/apache/arrow/vector/ipc/ArrowReader;<org/apache/arrow/adbc/driver/flightsql/GetInfoMetadataReaderCreateGetInfoMetadataReaderã(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;invalidState
invalidateAll$org/apache/arrow/util/AutoCloseables([Ljava/lang/AutoCloseable;)V-(Ljava/lang/Object;)Ljava/lang/StringBuilder;(C)Ljava/lang/StringBuilder;MTLS_CERT_CHAIN%Lorg/apache/arrow/adbc/core/TypedKey;#org/apache/arrow/adbc/core/TypedKeyget#(Ljava/util/Map;)Ljava/lang/Object;MTLS_PRIVATE_KEYTLS_ROOT_CERTSgetKeyformat9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;)org/apache/arrow/adbc/core/AdbcStatusCodeIO+Lorg/apache/arrow/adbc/core/AdbcStatusCode;h(Ljava/lang/String;Ljava/lang/Throwable;Lorg/apache/arrow/adbc/core/AdbcStatusCode;Ljava/lang/String;I)Vjava/lang/BooleanTRUELjava/lang/Boolean;WITH_COOKIE_MIDDLEWAREequals(Ljava/lang/Object;)Z5org/apache/arrow/flight/client/ClientCookieMiddleware
java/util/MapentrySet()Ljava/util/Set;
java/util/Set
startsWith(Ljava/lang/String;)Zlength	substring(I)Ljava/lang/String;getValueinsert'(Ljava/lang/String;Ljava/lang/String;)V(Ljava/lang/String;[B)VINVALID_ARGUMENT((Lorg/apache/arrow/flight/CallHeaders;)Vadd%org/apache/arrow/adbc/core/AdbcDriverPARAM_USERNAMEPARAM_PASSWORDauthenticateBasicToken:(Ljava/lang/String;Ljava/lang/String;)Ljava/util/Optional; (Ljava/util/function/Consumer;)Vjava/util/OptionalorElsetoArray(([Ljava/lang/Object;)[Ljava/lang/Object;	handshake(([Lorg/apache/arrow/flight/CallOption;)V0()Lorg/apache/arrow/flight/FlightClient$Builder;getAndIncrement(I)Ljava/lang/StringBuilder;'org/apache/arrow/memory/BufferAllocatorgetLimit()JnewChildAllocator?(Ljava/lang/String;JJ)Lorg/apache/arrow/memory/BufferAllocator;Y(Lorg/apache/arrow/memory/BufferAllocator;)Lorg/apache/arrow/flight/FlightClient$Builder;R(Lorg/apache/arrow/flight/Location;)Lorg/apache/arrow/flight/FlightClient$Builder;clientCertificateZ(Ljava/io/InputStream;Ljava/io/InputStream;)Lorg/apache/arrow/flight/FlightClient$Builder;trustedCertificatesE(Ljava/io/InputStream;)Lorg/apache/arrow/flight/FlightClient$Builder;TLS_SKIP_VERIFYverifyServer1(Z)Lorg/apache/arrow/flight/FlightClient$Builder;TLS_OVERRIDE_HOSTNAMEoverrideHostnameB(Ljava/lang/String;)Lorg/apache/arrow/flight/FlightClient$Builder;	interceptªh(Lorg/apache/arrow/flight/FlightClientMiddleware$Factory;)Lorg/apache/arrow/flight/FlightClient$Builder;(()Lorg/apache/arrow/flight/FlightClient;	available(Ljava/io/InputStream;)V	readFullyjava/lang/Thread
currentThread()Ljava/lang/Thread;	interrupt(Ljava/lang/Throwable;)V«¬¯?@<=°6org/apache/arrow/flight/FlightClientMiddleware$Factory"java/lang/invoke/LambdaMetafactorymetafactory²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;.org/apache/arrow/flight/FlightClientMiddleware³%java/lang/invoke/MethodHandles$Lookupjava/lang/invoke/MethodHandles!£U¤¥¦§¨©ª«¬­®¯°±²¯³´·¸¹º»¼½¸¹¾½¸¹¿½¸¹ÀÁÂw*·*»Y·µ*+µ*,µ*µ*½µ	»
Y*-··:*»
Y*´	·µ*¸²¶º¶*º¶µ*´-*´¹±Ã>S>TUV W(X6YGZH[Q\Y]bkhrvsÄ>wÅÆw¥¦w«¬wÇÈw­®6AÉÊËw­°ÌS¯ÍÎÏÂ0¸¿ÃwÄÅÆÌSÐÑÂB»Y*´*´*´*´·°Ã|ÄÅÆÌSÒÓ³	¢+¸N-¶ ½!:6-¶"¹#:¹$™*¹%À&:»!Y¶'·(:„S§ÿһ)Y»*Y-¶+¶,¶-·.·/M§"N»2Y·34¶5-¶6¶5¶7¸8-¶9¿»:Y*´*´*´,¸;·<°hk0hk1ÃJƒ„…†2‡@ˆJ‰M‹Vh’kŽly‚†‘Š“›”¡“Äf
@
ÇÈ2ÔÖc×ÚZÛÜWÝÞhßàláâ¢ÅÆ¢ãäŠßàå3ÿæçèéêú0ÿæçëüìÌSíîÂT*´*´*´*´+,¸=°ÃšÄ ÅÆïðñòÌSóöÂ	*´*´*´+,-¸>°Ã§ÄHÅÆ÷øùðúðûðüýþðÌSÿÂv*´*´*´+¸?°MA¸B,¶9¿@ö¸¹Ä 
áâÅÆåQëÌS¸	¹ÏÂ0¸¿Ã¿ÄÅÆÌSÂ,¬ÃÄÄÅÆÌSÂPš	¸¿±ÃÉÊ
ÌÄÅÆ	å
ÌS
ÏÂQ*´¹C½DY*´SY*´S¸E±ÃÐ	ÑÒÄÅÆÌ@ÂF»2Y·3F¶5*´¶G}¶H¶7°ÃÖÄÅÆ
Â*´ÆT²I*´¶JÀKM,Æ*,¸LµM²N*´¶JÀKN-Æ*-¸LµO²P*´¶JÀK:Æ*¸LµQ§6M»SYT½UY²I¶VSY²N¶VSY²P¶VS¸W,²X·Y¿*´Æ#²Z²[*´¶J¶\=™*»]Y·^µ_*+·`M»aY·bN»cY·d:*´¹e¹f:¹$™ž¹%Àg:¹hÀik¶l™}¹hÀik¶m¶n:¹oÁi™¹oÀi¶p§H¹oÁq™¹oÀqÀq¶r§$»SYs½UY¹hS¸W²t·Y¿§ÿ^-»uY·v¶wW²x*´¶JÀi:²y*´¶JÀi:Æ@Æ;,¶z:-»{Y»|Y·}·~¶¶wW*-½¶€Àµ	§*-½¶€Àµ	,*´	¶‚,°X[RÃÞ7áâãäå!è(é/ê3ë;îBïJðOñXÿ[ô\õkøtù}úöŽ•Ÿ¦ªµ
»
ÃÌò%9F]kq~%'*ž+­,·-¼.Á/Ö0Ù/Ý2ì3ï4þ58ĘC/)J\2¦	fðòŒÁ+ÅÆÇÈ»M©ÃEÌ< žj!ð­["ðË òŒ#Á+$ÃE%åJ
ü!&ü&ùB'2&ÿ&æ()*+êý\,-#ù úým--ÌS¸./Â'J*´Ç
»ƒY„·…¿¸†*´»2Y·3‡¶5*´¶ˆ¶‰¶7	*´¹Š¹‹¶Œ+¶M*´MÆ(*´OÆ!,»ŽY*´M·»ŽY*´O·¶W§u*´MÆ5»SY‘½UY²I¶VSY²N¶VSY²I¶VS¸W²t·Y¿*´OÆ5»SY‘½UY²N¶VSY²I¶VSY²N¶VS¸W²t·Y¿*´QÆ,»ŽY*´Q·¶’W*´Æ4²Z²“*´¶J¶\™	,¶”W²•*´¶JÀiN-Æ	,-¶–W*´_Æ,*´_¶—W,¶˜°Æ!>?B(E6G;D@CDHHKVLtO{PŠS“TœU Q­Z´[Ã^Ì_Õ`Ù\ægíhýklmp+q/r5w<xE{Ä*+
0ðJÅÆJÇÈH14åüb588ÌS¸.
67Âa*¶™¼L»šY*·›M,+¶œ+°Ã€‚Ä 89½:;ÌR<=Âh"*+·`M,*´	¶‚»
Y»
Y,·*´	·°ÃmnoÄ "ÅÆ">È©Ì@
?@¦$+DZ+¶§N-Áž™	¸Ÿ¶ »¡Y-·¢¿±	@Ã"ac	id
efh#jÄ*
â$AÈ$Bª$CDåFëü
ëú¸¹¹EF¶J	]·µ	&wÕØwÙô¤õ@g½	2Ó3~w3š©µ	­±®[\]^_\bcd