From 37f91c757c98e996ba54a5fa611236445899912d Mon Sep 17 00:00:00 2001 From: Wang Fenjin Date: Sat, 10 Sep 2022 11:45:33 +0800 Subject: [PATCH] add parquet example (#80) Change-Id: Id642fcfdf4cd2e8a8bc7a1f01d596082bad0ca59 --- examples/int32_decimal.parquet | Bin 0 -> 478 bytes examples/parquet.rs | 16 ++++++++++++++++ 2 files changed, 16 insertions(+) create mode 100644 examples/int32_decimal.parquet create mode 100644 examples/parquet.rs diff --git a/examples/int32_decimal.parquet b/examples/int32_decimal.parquet new file mode 100644 index 0000000000000000000000000000000000000000..5bf2d4ea3845820abb3c5e89b486d0211d2c1804 GIT binary patch literal 478 zcmZ9JPfpuV5XL7a32w!b7uk{*){}yWWGvgn`6m{z1BnIds!~;z7yB6^o|E7|X;G9N z2SBViKo8IZZ~zu8I6x1;0a&u=mndv1%};u7zR`R$nzN%XJ|p&AK{(9Av(9wOsGff! zGO95VH2`VAt1Q1yz^M@3fj96K(j%}ph;G3vIIR->0oygAU*In|tP}kP`X-SAFQBax zJ%D$xG-R6T9B<`QkzM`Bqf40zrXktXjM_}7QZ_%cD$}XqnU-no=oacjy-wy@W>6aU z8e&I3_-_T%!fNP+>6axQnU>L-WEZZO3OKndQ#Zd>F5It6S-9Ecr<=+`#G(*}nDgRh zD*1rtMOH=ycX%?AD$e=f+nkR@x|CKkLRnYFG8&~q?Y5nuh3vRgN(>bW(Lp-=qc Result<()> { + let db = Connection::open_in_memory()?; + db.execute_batch("INSTALL parquet; LOAD parquet;")?; + let rbs: Vec = db + .prepare("SELECT * FROM read_parquet('./examples/int32_decimal.parquet');")? + .query_arrow([])? + .collect(); + assert!(print_batches(&rbs).is_ok()); + Ok(()) +}