Repository URL to install this package:
Êþº¾ 4´ UGH I £J £K £L £MN £OP £Q RS T £U VW XY VZ ` Va e Vf £ghij Skl m Øn Øop Øqrstutvx &y !z{| Ø} ~ * ) 2G 2 @ 2 S S : Sh 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; client GLorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions; quirks %Lorg/apache/arrow/adbc/sql/SqlQuirks; parameters Ljava/util/Map; Signature 5Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>; 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;>; cookieMiddlewareFactory Factory InnerClasses ?Lorg/apache/arrow/flight/client/ClientCookieMiddleware$Factory; RuntimeVisibleTypeAnnotations 5Lorg/checkerframework/checker/nullness/qual/Nullable; callOptions %[Lorg/apache/arrow/flight/CallOption; mtlsCertChainBytes [B mtlsPrivateKeyBytes tlsRootCertsBytes <init> (Lorg/apache/arrow/memory/BufferAllocator;Lorg/apache/arrow/adbc/sql/SqlQuirks;Lorg/apache/arrow/flight/Location;Ljava/util/Map;)V Code LineNumberTable LocalVariableTable this <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;>;)V commit ()V createStatement ,()Lorg/apache/arrow/adbc/core/AdbcStatement; readPartition @(Ljava/nio/ByteBuffer;)Lorg/apache/arrow/vector/ipc/ArrowReader; protoLocation Location .Lorg/apache/arrow/flight/impl/Flight$Location; protoEndpointÿ FlightEndpoint 4Lorg/apache/arrow/flight/impl/Flight$FlightEndpoint; locations #[Lorg/apache/arrow/flight/Location; index I endpoint (Lorg/apache/arrow/flight/FlightEndpoint; e Ljava/lang/Exception; descriptor Ljava/nio/ByteBuffer; StackMapTableý ÿ Ü{ bulkIngest i(Ljava/lang/String;Lorg/apache/arrow/adbc/core/BulkIngestMode;)Lorg/apache/arrow/adbc/core/AdbcStatement; targetTableName Ljava/lang/String; mode +Lorg/apache/arrow/adbc/core/BulkIngestMode; getObjects GetObjectsDepth Á(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; catalogPattern dbSchemaPattern tableNamePattern tableTypes [Ljava/lang/String; columnNamePattern getInfo -([I)Lorg/apache/arrow/vector/ipc/ArrowReader; infoCodes [I rollback getAutoCommit ()Z setAutoCommit (Z)V enableAutoCommit Z close toString ()Ljava/lang/String; createInitialConnection J(Lorg/apache/arrow/flight/Location;)Lorg/apache/arrow/flight/FlightClient; mtlsCertChain Ljava/io/InputStream; mtlsPrivateKey tlsRootCerts ex Ljava/io/IOException; useCookieMiddleware userHeaderName parameter Entry Ljava/util/Map$Entry; bearerToken Ljava/util/Optional; &Lorg/apache/arrow/flight/FlightClient; options Ljava/util/ArrayList; callHeaders +Lorg/apache/arrow/flight/FlightCallHeaders; username password ;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; buildClient hostnameOverride builder Builder .Lorg/apache/arrow/flight/FlightClient$Builder; inputStreamToBytes (Ljava/io/InputStream;)[B stream bytes dataInputStream Ljava/io/DataInputStream; lambda$new$1 k(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;)V key value cause 1Lcom/github/benmanes/caffeine/cache/RemovalCause; SourceFile FlightSqlConnection.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$Location0 À1 &org/apache/arrow/flight/FlightEndpoint org/apache/arrow/flight/Ticket24526789 À: À; 2com/google/protobuf/InvalidProtocolBufferException java/net/URISyntaxException java/lang/StringBuilder .[Flight SQL] Partition descriptor is invalid: <=>?!@A 7org/apache/arrow/adbc/driver/flightsql/FlightInfoReaderBCD ÀEFGHIJKLM java/lang/Exception [Flight SQL] Failed to get infoN!O Ï java/lang/AutoCloseableP Q FlightSqlConnection{client=<R<STUVWX java/io/InputStream67 ¼ ½YU ¾ ½ZU ¿ ½ java/io/IOException (org/apache/arrow/adbc/core/AdbcException 7Error reading stream for one of the options %s, %s, %s. java/lang/Object[\]^_` ÀabcdeUfgh =org/apache/arrow/flight/client/ClientCookieMiddleware$Factory ´ ·/ java/util/ArrayList )org/apache/arrow/flight/FlightCallHeadersijkl java/util/Map$Entry[. java/lang/String Dorg/apache/arrow/adbc/driver/flightsql/FlightSqlConnectionProperties adbc.flight.sql.rpc.call_header.mno&pqr.stsu BHeader values must be String or byte[]. The header failing was %s.v` (org/apache/arrow/flight/HeaderCallOption ÀwxgyzU{U|} 1org/apache/arrow/flight/grpc/CredentialCallOption 7org/apache/arrow/flight/auth2/BasicAuthCredentialWriter Àt À~ java/lang/IllegalStateException -Internal error: allocator was not initialized1 adbc-flightclient-connection-&< ¥ Ç java/io/ByteArrayInputStream 9Must provide both %s and %s or neither. %s provided only.UU& java/io/DataInputStream À: Ï java/lang/InterruptedException ¡¢£ Ï java/lang/RuntimeException À¤ :org/apache/arrow/adbc/driver/flightsql/FlightSqlConnection )org/apache/arrow/adbc/core/AdbcConnection 2org/apache/arrow/flight/impl/Flight$FlightEndpoint java/nio/ByteBuffer java/util/Iterator 9org/apache/arrow/adbc/core/AdbcConnection$GetObjectsDepth $org/apache/arrow/flight/FlightClient ,org/apache/arrow/flight/FlightClient$Builder (I)V )(Lorg/apache/arrow/flight/FlightClient;)V U(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/TimeUnit MINUTES Ljava/util/concurrent/TimeUnit; expireAfterAccess O(JLjava/util/concurrent/TimeUnit;)Lcom/github/benmanes/caffeine/cache/Caffeine; ¥¦ X(Ljava/lang/Object;Ljava/lang/Object;Lcom/github/benmanes/caffeine/cache/RemovalCause;)V £§ onRemoval 6()Lcom/github/benmanes/caffeine/cache/RemovalListener; removalListener c(Lcom/github/benmanes/caffeine/cache/RemovalListener;)Lcom/github/benmanes/caffeine/cache/Caffeine; &(Ljava/lang/Object;)Ljava/lang/Object; £¨ load n(Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlConnection;)Lcom/github/benmanes/caffeine/cache/CacheLoader; build c(Lcom/github/benmanes/caffeine/cache/CacheLoader;)Lcom/github/benmanes/caffeine/cache/LoadingCache; /com/github/benmanes/caffeine/cache/LoadingCache put '(Ljava/lang/Object;Ljava/lang/Object;)V notImplemented >(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 parseFrom K(Ljava/nio/ByteBuffer;)Lorg/apache/arrow/flight/impl/Flight$FlightEndpoint; getLocationCount ()I getLocationList ()Ljava/util/List; java/util/List iterator ()Ljava/util/Iterator; hasNext next ()Ljava/lang/Object; #org/apache/arrow/flight/impl/Flight getUri (Ljava/lang/String;)V getTicket Ticket .()Lorg/apache/arrow/flight/impl/Flight$Ticket; *org/apache/arrow/flight/impl/Flight$Ticket "()Lcom/google/protobuf/ByteString; com/google/protobuf/ByteString toByteArray ()[B ([B)V F(Lorg/apache/arrow/flight/Ticket;[Lorg/apache/arrow/flight/Location;)V append -(Ljava/lang/String;)Ljava/lang/StringBuilder; getMessage invalidArgument withCause A(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/GetObjectsMetadataReaders CreateGetObjectsReaderb(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/GetInfoMetadataReader 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; 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/TypedKey get #(Ljava/util/Map;)Ljava/lang/Object; MTLS_PRIVATE_KEY TLS_ROOT_CERTS getKey format 9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String; )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 java/lang/Boolean TRUE Ljava/lang/Boolean; WITH_COOKIE_MIDDLEWARE equals (Ljava/lang/Object;)Z 5org/apache/arrow/flight/client/ClientCookieMiddleware java/util/Map entrySet ()Ljava/util/Set; java/util/Set startsWith (Ljava/lang/String;)Z length substring (I)Ljava/lang/String; getValue insert '(Ljava/lang/String;Ljava/lang/String;)V (Ljava/lang/String;[B)V INVALID_ARGUMENT ((Lorg/apache/arrow/flight/CallHeaders;)V add %org/apache/arrow/adbc/core/AdbcDriver PARAM_USERNAME PARAM_PASSWORD authenticateBasicToken :(Ljava/lang/String;Ljava/lang/String;)Ljava/util/Optional; (Ljava/util/function/Consumer;)V java/util/Optional orElse toArray (([Ljava/lang/Object;)[Ljava/lang/Object; handshake (([Lorg/apache/arrow/flight/CallOption;)V 0()Lorg/apache/arrow/flight/FlightClient$Builder; getAndIncrement (I)Ljava/lang/StringBuilder; 'org/apache/arrow/memory/BufferAllocator getLimit ()J newChildAllocator ?(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; clientCertificate Z(Ljava/io/InputStream;Ljava/io/InputStream;)Lorg/apache/arrow/flight/FlightClient$Builder; trustedCertificates E(Ljava/io/InputStream;)Lorg/apache/arrow/flight/FlightClient$Builder; TLS_SKIP_VERIFY verifyServer 1(Z)Lorg/apache/arrow/flight/FlightClient$Builder; TLS_OVERRIDE_HOSTNAME overrideHostname B(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 readFully java/lang/Thread currentThread ()Ljava/lang/Thread; interrupt (Ljava/lang/Throwable;)V«¬¯?@<=° 6org/apache/arrow/flight/FlightClientMiddleware$Factory "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; .org/apache/arrow/flight/FlightClientMiddleware³ %java/lang/invoke/MethodHandles$Lookup java/lang/invoke/MethodHandles ! £ U ¤ ¥ ¦ § ¨ © ª « ¬ ® ¯ ° ± ² ¯ ³ ´ · ¸ ¹ º » ¼ ½ ¸ ¹ ¾ ½ ¸ ¹ ¿ ½ ¸ ¹ À Á  w*· *» Y· µ *+µ *,µ *µ *½ µ » Y*-· · :*» Y*´ · µ *¸ ² ¶ º ¶ *º ¶ µ *´ -*´ ¹ ± à >