Repository URL to install this package:
Êþº¾ 4V S R R R R R R ¡ ¢ { £ ¤ ¥ ¤ ¦ § } ¤ ¨ © ª « R ¬ ® ¯ ° ± ² ± ³ ´ µ # ¶ # · # ¸ $ ¶ $ ¸ ¹ º » ¼ ½ $ ¾ ¿ À ± Á Â Ã Ä Å Æ Ç Æ È Æ É Ê 8 Ë Ä Ì Í ; Î ; Ï ; Ð Æ Ñ Æ Ò t Ó Ô Õ Ö × Ø Ù Ú F Û Ä Ü Ý Þ Ô ß à á Ý â ã ä å æ Ý É Ä É ± É ç è quirks <Lorg/apache/arrow/adbc/driver/testsuite/SqlValidationQuirks; database )Lorg/apache/arrow/adbc/core/AdbcDatabase; connection +Lorg/apache/arrow/adbc/core/AdbcConnection; allocator )Lorg/apache/arrow/memory/BufferAllocator; util 4Lorg/apache/arrow/adbc/driver/testsuite/SqlTestUtil; tableName Ljava/lang/String; schema +Lorg/apache/arrow/vector/types/pojo/Schema; <init> ()V Code LineNumberTable LocalVariableTable this HLorg/apache/arrow/adbc/driver/testsuite/AbstractPartitionDescriptorTest; beforeEach Exceptions é RuntimeVisibleAnnotations "Lorg/junit/jupiter/api/BeforeEach; afterEach !Lorg/junit/jupiter/api/AfterEach; serializeDeserializeQuery stmt *Lorg/apache/arrow/adbc/core/AdbcStatement; partitionResult ê PartitionResult InnerClasses :Lorg/apache/arrow/adbc/core/AdbcStatement$PartitionResult; reader )Lorg/apache/arrow/vector/ipc/ArrowReader; connection2 ints &Lorg/apache/arrow/vector/BigIntVector; strs 'Lorg/apache/arrow/vector/VarCharVector; root *Lorg/apache/arrow/vector/VectorSchemaRoot; StackMapTable ç ë Ê ´ µ ì ê í î Lorg/junit/jupiter/api/Test; SourceFile $AbstractPartitionDescriptorTest.java b c T U 2Must initialize quirks in subclass with @BeforeAll ï ð ñ %org/apache/arrow/memory/RootAllocator Z [ ò ó ô V W õ ö ÷ X Y 2org/apache/arrow/adbc/driver/testsuite/SqlTestUtil b ø \ ] bulktable ù ú ^ _ )org/apache/arrow/vector/types/pojo/Schema (org/apache/arrow/vector/types/pojo/Field û ú ý ÿ b ` a java/lang/AutoCloseable ë $org/apache/arrow/vector/BigIntVector %org/apache/arrow/vector/VarCharVector foo asdf !" í#$ ì%&'* c java/lang/Throwable+,-. java/lang/StringBuilder SELECT * FROM /0123456789:;<=>?@ .org/apache/arrow/adbc/core/PartitionDescriptorABCD îEF9GHIJKLMNPQRS Forg/apache/arrow/adbc/driver/testsuite/AbstractPartitionDescriptorTest java/lang/Object java/lang/Exception 8org/apache/arrow/adbc/core/AdbcStatement$PartitionResult (org/apache/arrow/vector/VectorSchemaRoot (org/apache/arrow/adbc/core/AdbcStatement )org/apache/arrow/adbc/core/AdbcConnection 'org/apache/arrow/vector/ipc/ArrowReader #org/apache/arrow/util/Preconditions checkNotNull 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; :org/apache/arrow/adbc/driver/testsuite/SqlValidationQuirks initDatabase T(Lorg/apache/arrow/memory/BufferAllocator;)Lorg/apache/arrow/adbc/core/AdbcDatabase; 'org/apache/arrow/adbc/core/AdbcDatabase connect -()Lorg/apache/arrow/adbc/core/AdbcConnection; ?(Lorg/apache/arrow/adbc/driver/testsuite/SqlValidationQuirks;)V caseFoldTableName &(Ljava/lang/String;)Ljava/lang/String; caseFoldColumnNameT -org/apache/arrow/vector/types/Types$MinorType MinorType BIGINT /Lorg/apache/arrow/vector/types/Types$MinorType; getType 0()Lorg/apache/arrow/vector/types/pojo/ArrowType; nullable l(Ljava/lang/String;Lorg/apache/arrow/vector/types/pojo/ArrowType;)Lorg/apache/arrow/vector/types/pojo/Field; VARCHAR java/util/Arrays asList %([Ljava/lang/Object;)Ljava/util/List; (Ljava/lang/Iterable;)V cleanupTable (Ljava/lang/String;)V $org/apache/arrow/util/AutoCloseables close ([Ljava/lang/AutoCloseable;)V create (Lorg/apache/arrow/vector/types/pojo/Schema;Lorg/apache/arrow/memory/BufferAllocator;)Lorg/apache/arrow/vector/VectorSchemaRoot; getVector ((I)Lorg/apache/arrow/vector/FieldVector; allocateNew (I)V setSafe (IJ)V setNull !java/nio/charset/StandardCharsets UTF_8 Ljava/nio/charset/Charset; java/lang/String getBytes (Ljava/nio/charset/Charset;)[B (I[B)V setRowCount )org/apache/arrow/adbc/core/BulkIngestMode CREATE +Lorg/apache/arrow/adbc/core/BulkIngestMode; bulkIngest i(Ljava/lang/String;Lorg/apache/arrow/adbc/core/BulkIngestMode;)Lorg/apache/arrow/adbc/core/AdbcStatement; bind -(Lorg/apache/arrow/vector/VectorSchemaRoot;)V executeUpdateU UpdateResult 9()Lorg/apache/arrow/adbc/core/AdbcStatement$UpdateResult; addSuppressed (Ljava/lang/Throwable;)V createStatement ,()Lorg/apache/arrow/adbc/core/AdbcStatement; append -(Ljava/lang/String;)Ljava/lang/StringBuilder; toString ()Ljava/lang/String; setSqlQuery executePartitioned <()Lorg/apache/arrow/adbc/core/AdbcStatement$PartitionResult; getPartitionDescriptors ()Ljava/util/List; org/assertj/core/api/Assertions assertThat 3(Ljava/util/List;)Lorg/assertj/core/api/ListAssert; org/assertj/core/api/ListAssert hasSize 0(I)Lorg/assertj/core/api/AbstractIterableAssert; java/util/List get (I)Ljava/lang/Object; getDescriptor ()Ljava/nio/ByteBuffer; readPartition @(Ljava/nio/ByteBuffer;)Lorg/apache/arrow/vector/ipc/ArrowReader; loadNextBatch ()Z /(Z)Lorg/assertj/core/api/AbstractBooleanAssert; *org/assertj/core/api/AbstractBooleanAssert isTrue .()Lorg/assertj/core/api/AbstractBooleanAssert; getVectorSchemaRoot ,()Lorg/apache/arrow/vector/VectorSchemaRoot; 6org/apache/arrow/adbc/driver/testsuite/ArrowAssertions assertRoot VectorSchemaRootAssert {(Lorg/apache/arrow/vector/VectorSchemaRoot;)Lorg/apache/arrow/adbc/driver/testsuite/ArrowAssertions$VectorSchemaRootAssert; Morg/apache/arrow/adbc/driver/testsuite/ArrowAssertions$VectorSchemaRootAssert isEqualTo c(Ljava/lang/Object;)Lorg/apache/arrow/adbc/driver/testsuite/ArrowAssertions$VectorSchemaRootAssert; #org/apache/arrow/vector/types/Types 5org/apache/arrow/adbc/core/AdbcStatement$UpdateResult! R S T U V W X Y Z [ \ ] ^ _ ` a b c d / *· ± e , f g h i c d è ² ¸ W*» Y· µ *² *´ ¶ µ **´ ¹ µ *» Y² · µ *² ¶ µ *» Y½ Y² ¶ ² ¶ ¸ SY² ¶ ² ¶ ¸ S¸ · µ ² *´ ¶ ± e 6 9 : ; " <