Skip to content

Commit

Permalink
Merge pull request #97 from EpsilonPrime/typeof_testing
Browse files Browse the repository at this point in the history
feat: add tests showing the result of iceberg conversion to DuckDB
  • Loading branch information
samansmink authored Feb 14, 2025
2 parents 5756233 + c8f5476 commit 80c1211
Showing 1 changed file with 60 additions and 0 deletions.
60 changes: 60 additions & 0 deletions test/sql/local/iceberg_scan.test
Original file line number Diff line number Diff line change
Expand Up @@ -118,3 +118,63 @@ query I
SELECT count(*) FROM ICEBERG_SCAN('data/iceberg/lineitem_iceberg_gz_no_hint', ALLOW_MOVED_PATHS=TRUE, METADATA_COMPRESSION_CODEC="gzip", version='2', version_name_format='v%s%s.metadata.json');
----
111968

query I
SELECT typeof(l_orderkey_bool) FROM ICEBERG_SCAN('data/iceberg/generated_spec1_0_001/pyspark_iceberg_table', ALLOW_MOVED_PATHS=TRUE) LIMIT 1;
----
BOOLEAN

query I
SELECT typeof(l_partkey_int) FROM ICEBERG_SCAN('data/iceberg/generated_spec1_0_001/pyspark_iceberg_table', ALLOW_MOVED_PATHS=TRUE) LIMIT 1;
----
INTEGER

query I
SELECT typeof(l_suppkey_long) FROM ICEBERG_SCAN('data/iceberg/generated_spec1_0_001/pyspark_iceberg_table', ALLOW_MOVED_PATHS=TRUE) LIMIT 1;
----
BIGINT

query I
SELECT typeof(l_extendedprice_float) FROM ICEBERG_SCAN('data/iceberg/generated_spec1_0_001/pyspark_iceberg_table', ALLOW_MOVED_PATHS=TRUE) LIMIT 1;
----
FLOAT

query I
SELECT typeof(l_extendedprice_double) FROM ICEBERG_SCAN('data/iceberg/generated_spec1_0_001/pyspark_iceberg_table', ALLOW_MOVED_PATHS=TRUE) LIMIT 1;
----
DOUBLE

query I
SELECT typeof(l_extendedprice_dec9_2) FROM ICEBERG_SCAN('data/iceberg/generated_spec1_0_001/pyspark_iceberg_table', ALLOW_MOVED_PATHS=TRUE) LIMIT 1;
----
DECIMAL(9,2)

query I
SELECT typeof(l_shipdate_date) FROM ICEBERG_SCAN('data/iceberg/generated_spec1_0_001/pyspark_iceberg_table', ALLOW_MOVED_PATHS=TRUE) LIMIT 1;
----
DATE

query I
SELECT typeof(l_partkey_time) FROM ICEBERG_SCAN('data/iceberg/generated_spec1_0_001/pyspark_iceberg_table', ALLOW_MOVED_PATHS=TRUE) LIMIT 1;
----
INTEGER

query I
SELECT typeof(l_commitdate_timestamp) FROM ICEBERG_SCAN('data/iceberg/generated_spec1_0_001/pyspark_iceberg_table', ALLOW_MOVED_PATHS=TRUE) LIMIT 1;
----
TIMESTAMP

query I
SELECT typeof(l_commitdate_timestamp_tz) FROM ICEBERG_SCAN('data/iceberg/generated_spec1_0_001/pyspark_iceberg_table', ALLOW_MOVED_PATHS=TRUE) LIMIT 1;
----
TIMESTAMP WITH TIME ZONE

query I
SELECT typeof(l_comment_string) FROM ICEBERG_SCAN('data/iceberg/generated_spec1_0_001/pyspark_iceberg_table', ALLOW_MOVED_PATHS=TRUE) LIMIT 1;
----
VARCHAR

query I
SELECT typeof(l_comment_blob) FROM ICEBERG_SCAN('data/iceberg/generated_spec1_0_001/pyspark_iceberg_table', ALLOW_MOVED_PATHS=TRUE) LIMIT 1;
----
BLOB

0 comments on commit 80c1211

Please sign in to comment.