Repository URL to install this package:
Êþº¾ 4 P QR S T U V W X P Z[ \] ^_`a ^b c de f g hi m /no p q r s t uv w xy x ^z {|} #~ # G 0 / 2i ì ì ì ò / ò C C I¡¢£ I¤¥ ¦ ò§ ì¨ § © ª« g¬ VS® h¯ h° Y± ²³ X´ µ¶ ·¸¹º» c¼ \½ ¾¿ NÀÁÂà jÄÅ NÆÇ ìÈ NÉÊËÌ ìÍ cÎ ÏÐ ÑÒÓÔ NÕ Ö× ÏØÙ ÖÚ ZÛÜ ÝÞ Öß Zàáãåæèê cëìíîï Öðñ ìò óôõö ÷øù úû üýþ S I / GetTablesMetadataReader InnerClasses TableDefinition ColumnDefinition catalogPattern Ljava/lang/String; dbSchemaPattern compiledColumnNamePattern Ljava/util/regex/Pattern; RuntimeVisibleTypeAnnotations 5Lorg/checkerframework/checker/nullness/qual/Nullable; shouldGetColumns Z tablePathToColumnsMap Ljava/util/Map; Signature ÓLjava/util/Map<Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Lorg/apache/arrow/adbc/driver/flightsql/GetObjectsMetadataReaders$GetTablesMetadataReader$TableDefinition;>;>;>; <init> í(Lorg/apache/arrow/memory/BufferAllocator;Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;Lcom/github/benmanes/caffeine/cache/LoadingCache;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;)V Code LineNumberTable LocalVariableTable this ZLorg/apache/arrow/adbc/driver/flightsql/GetObjectsMetadataReaders$GetTablesMetadataReader; allocator )Lorg/apache/arrow/memory/BufferAllocator; client GLorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions; clientCache 1Lcom/github/benmanes/caffeine/cache/LoadingCache; schemaPattern tablePattern tableTypes [Ljava/lang/String; LocalVariableTypeTable Lcom/github/benmanes/caffeine/cache/LoadingCache<Lorg/apache/arrow/flight/Location;Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;>; ExceptionsX(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/lang/String;Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;)V ÿ(Lorg/apache/arrow/memory/BufferAllocator;Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;Lcom/github/benmanes/caffeine/cache/LoadingCache;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;Ljava/lang/String;)V columnPattern StackMapTable ¿j(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/lang/String;Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;Ljava/lang/String;)V processRootFromStream -(Lorg/apache/arrow/vector/VectorSchemaRoot;)V catalog schema tableType columns Ljava/util/List; table i I root *Lorg/apache/arrow/vector/VectorSchemaRoot; catalogVector 'Lorg/apache/arrow/vector/VarCharVector; schemaVector tableVector tableTypeVector tableSchemaVector )Lorg/apache/arrow/vector/VarBinaryVector; }Ljava/util/List<Lorg/apache/arrow/adbc/driver/flightsql/GetObjectsMetadataReaders$GetTablesMetadataReader$ColumnDefinition;>;`aa finish ()V columnDefinitionWriter StructWriter @Lorg/apache/arrow/vector/complex/writer/BaseWriter$StructWriter; columnDefinition kLorg/apache/arrow/adbc/driver/flightsql/GetObjectsMetadataReaders$GetTablesMetadataReader$ColumnDefinition; columnListWriter ListWriter >Lorg/apache/arrow/vector/complex/writer/BaseWriter$ListWriter; tableStructWriter Entry Ljava/util/Map$Entry; tables schemaStructAsMap schemaNameObj Ljava/lang/Object; schemaName schemaStructWriter tableWriter schemaToTableMap schemaStructObj outputCatalogColumn outputSchemaStructList ,Lorg/apache/arrow/vector/complex/ListVector; sourceSchemaStructList catalogColumn schemaListWriter 6Lorg/apache/arrow/vector/complex/impl/UnionListWriter; schemaReader GetDbSchemasMetadataReader ]Lorg/apache/arrow/adbc/driver/flightsql/GetObjectsMetadataReaders$GetDbSchemasMetadataReader; Ljava/util/Map$Entry<Ljava/lang/String;Lorg/apache/arrow/adbc/driver/flightsql/GetObjectsMetadataReaders$GetTablesMetadataReader$TableDefinition;>; Ljava/util/Map<Ljava/lang/String;Lorg/apache/arrow/adbc/driver/flightsql/GetObjectsMetadataReaders$GetTablesMetadataReader$TableDefinition;>; 5Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>; °Ljava/util/Map<Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Lorg/apache/arrow/adbc/driver/flightsql/GetObjectsMetadataReaders$GetTablesMetadataReader$TableDefinition;>;>;ovy getColumnDefinitions <(Lorg/apache/arrow/vector/VarBinaryVector;I)Ljava/util/List; field *Lorg/apache/arrow/vector/types/pojo/Field; fieldIndex result tableSchema +Lorg/apache/arrow/vector/types/pojo/Schema; fields e Ljava/io/IOException; index <Ljava/util/List<Lorg/apache/arrow/vector/types/pojo/Field;>;a»Â ©(Lorg/apache/arrow/vector/VarBinaryVector;I)Ljava/util/List<Lorg/apache/arrow/adbc/driver/flightsql/GetObjectsMetadataReaders$GetTablesMetadataReader$ColumnDefinition;>; writeColumnDefinition ®(Lorg/apache/arrow/adbc/driver/flightsql/GetObjectsMetadataReaders$GetTablesMetadataReader$ColumnDefinition;Lorg/apache/arrow/vector/complex/writer/BaseWriter$StructWriter;)V fieldType .Lorg/apache/arrow/vector/types/pojo/ArrowType; typeName columnSize Ljava/lang/Integer; decimalDigits¥ doRequest £(Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;Z)Ljava/util/List; Í(Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;Z)Ljava/util/List<Lorg/apache/arrow/flight/FlightEndpoint;>; lambda$processRootFromStream$3 x(Ljava/lang/String;Ljava/lang/String;Ljava/util/List;Ljava/lang/String;Ljava/lang/String;Ljava/util/Map;)Ljava/util/Map; catalogEntryKey catalogEntryValue lambda$null$2 f(Ljava/lang/String;Ljava/util/List;Ljava/lang/String;Ljava/lang/String;Ljava/util/Map;)Ljava/util/Map; schemaEntryKey schemaEntryValue tableDefinition jLorg/apache/arrow/adbc/driver/flightsql/GetObjectsMetadataReaders$GetTablesMetadataReader$TableDefinition; lambda$new$1 ¢(Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;)Ljava/util/List; lambda$new$0 SourceFile GetObjectsMetadataReaders.java BootstrapMethods ¯ java/util/LinkedHashMap ¯ ê « ¬ ¢ £ ¤ £ ¥ ¦ © ª !"#$%&' %org/apache/arrow/vector/VarCharVector 'org/apache/arrow/vector/VarBinaryVector()*+ ,-./0123456789 [org/apache/arrow/adbc/driver/flightsql/GetObjectsMetadataReaders$GetDbSchemasMetadataReader ¶ · ¸ ¹ º » ¯:;<= ê java/lang/Throwable>?@A *org/apache/arrow/vector/complex/ListVectorBCDEFG êHIJ êK êLM NOP<Q java/util/Map java/lang/IllegalStateException IError in catalog %s: Null schema encountered when schemas were requested. java/lang/ObjectRS ¯T db_schema_nameU 5Error in catalog %s: Schema with no name encountered.VCWXY êZ[\T db_schema_tables]^_`a java/util/Map$Entry table_nameb java/lang/Stringc horg/apache/arrow/adbc/driver/flightsql/GetObjectsMetadataReaders$GetTablesMetadataReader$TableDefinition Ô £ table_type table_columnsd Ö iorg/apache/arrow/adbc/driver/flightsql/GetObjectsMetadataReaders$GetTablesMetadataReader$ColumnDefinition+,e êf êgChi java/util/ArrayList 'org/apache/arrow/vector/ipc/ReadChannel java/io/ByteArrayInputStreamjklm ¯nopq ¯rstuvw)x (org/apache/arrow/vector/types/pojo/Fieldy2z{|}<~ java/io/IOException java/lang/RuntimeException ¯? column_name ordinal_position Ù C xdbc_data_type2 xdbc_type_name xdbc_column_size) xdbc_decimal_digits 4org/apache/arrow/vector/types/pojo/ArrowType$Decimal Decimal xdbc_num_prec_radix 0org/apache/arrow/vector/types/pojo/ArrowType$Int Int :org/apache/arrow/vector/types/pojo/ArrowType$FloatingPoint FloatingPoint xdbc_nullable < xdbc_sql_data_type xdbc_is_nullable YES NO¡¢ xdbc_auto_increment£¤¥¦<§C¨©ª "org/apache/arrow/flight/CallOption «¬® java/util/HashMap¯6° ¯±²39: Xorg/apache/arrow/adbc/driver/flightsql/GetObjectsMetadataReaders$GetTablesMetadataReader Xorg/apache/arrow/adbc/driver/flightsql/GetObjectsMetadataReaders$GetObjectMetadataReader GetObjectMetadataReader (org/apache/arrow/adbc/core/AdbcException 'org/apache/arrow/memory/BufferAllocator Eorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions /com/github/benmanes/caffeine/cache/LoadingCache java/util/regex/Pattern (org/apache/arrow/vector/VectorSchemaRoot java/util/List³ >org/apache/arrow/vector/complex/writer/BaseWriter$StructWriter <org/apache/arrow/vector/complex/writer/BaseWriter$ListWriter 4org/apache/arrow/vector/complex/impl/UnionListWriter java/util/Iterator )org/apache/arrow/vector/types/pojo/Schema ,org/apache/arrow/vector/types/pojo/ArrowType java/lang/Integer 5org/apache/arrow/vector/complex/writer/SmallIntWriter 4org/apache/arrow/vector/complex/writer/VarCharWriter 0org/apache/arrow/vector/complex/writer/BitWriter ´µ ()Ljava/lang/Object; ¶ ()Ljava/util/List; get ¯(Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;)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 · @org/apache/arrow/adbc/driver/flightsql/GetObjectsMetadataReaders sqlToRegexLike &(Ljava/lang/String;)Ljava/lang/String; compile -(Ljava/lang/String;)Ljava/util/regex/Pattern; getVector ((I)Lorg/apache/arrow/vector/FieldVector; getRowCount ()I isNull (I)Z buffer #Lorg/apache/arrow/vector/util/Text; read ,(ILorg/apache/arrow/memory/ReusableBuffer;)V !org/apache/arrow/vector/util/Text toString ()Ljava/lang/String; 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; ¸ 2(Ljava/lang/String;Ljava/util/Map;)Ljava/util/Map; apply g(Ljava/lang/String;Ljava/lang/String;Ljava/util/List;Ljava/lang/String;)Ljava/util/function/BiFunction; compute E(Ljava/lang/Object;Ljava/util/function/BiFunction;)Ljava/lang/Object; È(Lorg/apache/arrow/memory/BufferAllocator;Lorg/apache/arrow/adbc/driver/flightsql/FlightSqlClientWithCallOptions;Lcom/github/benmanes/caffeine/cache/LoadingCache;Ljava/lang/String;Ljava/lang/String;)V loadNextBatch ()Z close addSuppressed (Ljava/lang/Throwable;)V getAggregateRoot ,()Lorg/apache/arrow/vector/VectorSchemaRoot; setRowCount (I)V makeTransferPair R(Lorg/apache/arrow/vector/ValueVector;)Lorg/apache/arrow/vector/util/TransferPair; )org/apache/arrow/vector/util/TransferPair transfer getWriter 8()Lorg/apache/arrow/vector/complex/impl/UnionListWriter; allocate startList getObject (I)Ljava/util/List; iterator ()Ljava/util/Iterator; hasNext next format 9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String; (Ljava/lang/String;)V &(Ljava/lang/Object;)Ljava/lang/Object; setPosition struct B()Lorg/apache/arrow/vector/complex/writer/BaseWriter$StructWriter; start varChar J(Ljava/lang/String;)Lorg/apache/arrow/vector/complex/writer/VarCharWriter; writeVarChar list R(Ljava/lang/String;)Lorg/apache/arrow/vector/complex/writer/BaseWriter$ListWriter; entrySet ()Ljava/util/Set; java/util/Set getKey getValue columnDefinitions endList end setValueCount java/util/Collections emptyList getBytes ()[B getLength ()J ([BII)V java/nio/channels/Channels newChannel >(Ljava/io/InputStream;)Ljava/nio/channels/ReadableByteChannel; *(Ljava/nio/channels/ReadableByteChannel;)V 5org/apache/arrow/vector/ipc/message/MessageSerializer deserializeSchema V(Lorg/apache/arrow/vector/ipc/ReadChannel;)Lorg/apache/arrow/vector/types/pojo/Schema; getFields size (I)Ljava/lang/Object; getName matcher 3(Ljava/lang/CharSequence;)Ljava/util/regex/Matcher; java/util/regex/Matcher matches from (Lorg/apache/arrow/vector/types/pojo/Field;I)Lorg/apache/arrow/adbc/driver/flightsql/GetObjectsMetadataReaders$GetTablesMetadataReader$ColumnDefinition; add (Ljava/lang/Object;)Z integer F(Ljava/lang/String;)Lorg/apache/arrow/vector/complex/writer/IntWriter; ordinal 0org/apache/arrow/vector/complex/writer/IntWriter writeInt smallInt K(Ljava/lang/String;)Lorg/apache/arrow/vector/complex/writer/SmallIntWriter; getType 0()Lorg/apache/arrow/vector/types/pojo/ArrowType; +org/apache/arrow/driver/jdbc/utils/SqlTypes getSqlTypeIdFromArrowType 1(Lorg/apache/arrow/vector/types/pojo/ArrowType;)I #com/google/common/primitives/Shorts saturatedCast (J)S writeSmallInt (S)V metadata 5Lorg/apache/arrow/flight/sql/FlightSqlColumnMetadata; 3org/apache/arrow/flight/sql/FlightSqlColumnMetadata getTypeName getSqlTypeNameFromArrowType B(Lorg/apache/arrow/vector/types/pojo/ArrowType;)Ljava/lang/String; getPrecision ()Ljava/lang/Integer; getColumnSize C(Lorg/apache/arrow/vector/types/pojo/ArrowType;)Ljava/lang/Integer; intValue getScale getDecimalDigits isNullable isAutoIncrement ()Ljava/lang/Boolean; bit F(Ljava/lang/String;)Lorg/apache/arrow/vector/complex/writer/BitWriter; java/lang/Boolean booleanValue writeBit java/util/Arrays asList %([Ljava/lang/Object;)Ljava/util/List; getTables (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/util/List;Z[Lorg/apache/arrow/flight/CallOption;)Lorg/apache/arrow/flight/FlightInfo; "org/apache/arrow/flight/FlightInfo getEndpoints ¹ U(Ljava/lang/String;Ljava/util/List;Ljava/lang/String;)Ljava/util/function/BiFunction; %(Ljava/lang/String;Ljava/util/List;)V put 1org/apache/arrow/vector/complex/writer/BaseWriterº»¾HGFG<=@A "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;Á %java/lang/invoke/MethodHandles$Lookup java/lang/invoke/MethodHandles ¢ £ ¤ £ ¥ ¦ § ¨ © ª « ¬ ® ¯ ° ± Ñ 7*+,-,º · *» Y· µ *µ *µ *µ *µ ± ² n b s &t ,u 1v 6w ³ R 7 ´ µ 7 ¶ · 7 ¸ ¹ 7 º » 7 ¢ £ 7 ¼ £ 7 ½ £ 7 ¾ ¿ À 7 º Á Â Ã Ä ¯ Å ± D G*+,-,º · *» Y· µ *µ *µ *Æ ¸ ¸ § µ *µ ± ² " b & , 4 A F ³ \ G ´ µ G ¶ · G ¸ ¹ G º » G ¢ £ G ¼ £ G ½ £ G ¾ ¿ G Æ £ À G º Á Ç O ÿ = È É Ê Ë Ì Ì Ì Í Ì Èÿ È É Ê Ë Ì Ì Ì Í Ì È Î Â Ã Ï Ð Ñ ± ï+¶ À M+¶ À N+¶ À :+¶ À :*´ +¶ À § :6+¶ ¢ ª*· :,¶ : § ,*´ ¶ *´ ¶ : -¶ : § -*´ ¶ *´ ¶ : ¶ :§ *´ ¶ *´ ¶ :*´ ¶ *´ ¶ :*´ º ¹ W§ÿS± ² f & / ; G Q Z a k t£ }¤ ¦ § « ¡¬ §® ²¯ »² Ƴ Ï´ è îÊ ³ ¢ ^ Ò £ Ó £ ¤ Ô £ Q Õ Ö t t Ò £ Q Ó £ » - Ô £ Ï × £ >