Merge pull request #166 from JuliaIO/mg/snappy-0.4

Add compat for `Snappy` v0.4

Author: giordano

.github/workflows/ci.yaml

@@ -6,6 +6,7 @@ on:
     tags: ['*']
 jobs:
   test:
+    timeout-minutes: 30
     name: Julia ${{ matrix.version }} - ${{ matrix.os }} - ${{ matrix.arch }} - ${{ github.event_name }}
     runs-on: ${{ matrix.os }}
     strategy:

Artifacts.toml

@@ -0,0 +1,15 @@
+[julia_parcompat]
+git-tree-sha1 = "066eb71b5392a8edb036e6a66a92d9b94a9e7eed"
+lazy = true
+
+    [[julia_parcompat.download]]
+    sha256 = "943ac718383a9bb1144e0edc88ec1c42f071e00d40728af7b18a213fd4da5d1c"
+    url = "https://github.com/JuliaIO/parquet-compatibility/archive/3f7586f1b7f2a0c6b048791fb5f97c0b3df52e39.tar.gz"
+
+[parcompat]
+git-tree-sha1 = "1e993c153d3df6b2039ea5df61aeea2cb5213753"
+lazy = true
+
+    [[parcompat.download]]
+    sha256 = "895f382e65e4684335d6cbd2d682172d0923660f5525e0682112361305f05b64"
+    url = "https://github.com/Parquet/parquet-compatibility/archive/2b47eac447c7a4a88247651a4065984db7b247ff.tar.gz"

Project.toml

@@ -3,7 +3,7 @@ uuid = "626c502c-15b0-58ad-a749-f091afb673ae"
 keywords = ["parquet", "julia", "columnar-storage"]
 license = "MIT"
 desc = "Julia implementation of parquet columnar file format reader and writer"
-version = "0.8.3"
+version = "0.8.4"
 
 [deps]
 CategoricalArrays = "324d7699-5711-5eae-9e2f-1d82baa6b597"
@@ -29,14 +29,16 @@ Decimals = "0.4"
 LittleEndianBase128 = "0.3"
 Missings = "0.3,0.4,1"
 SentinelArrays = "1"
-Snappy = "0.3"
+Snappy = "0.3, 0.4"
 Tables = "1.6"
 Thrift = "0.8"
 julia = "1.3"
 
 [extras]
+Artifacts = "56f22d72-fd6d-98f1-02f0-08ddc0907c33"
+LazyArtifacts = "4af54fe1-eca0-43a8-85a7-787d91b784e3"
 Random = "9a3f8284-a2c9-5f02-9a11-845980a1fd5c"
 Test = "8dfed614-e22c-5e08-85e1-65c5234f0b40"
 
 [targets]
-test = ["Test", "Random"]
+test = ["Artifacts", "LazyArtifacts", "Random", "Test"]

test/generate_artifacts.jl

@@ -0,0 +1,17 @@
+using ArtifactUtils, Artifacts
+
+add_artifact!(
+    joinpath(@__DIR__, "..", "Artifacts.toml"),
+    "parcompat",
+    "https://github.com/Parquet/parquet-compatibility/archive/2b47eac447c7a4a88247651a4065984db7b247ff.tar.gz",
+    force=true,
+    lazy=true,
+)
+
+add_artifact!(
+    joinpath(@__DIR__, "..", "Artifacts.toml"),
+    "julia_parcompat",
+    "https://github.com/JuliaIO/parquet-compatibility/archive/3f7586f1b7f2a0c6b048791fb5f97c0b3df52e39.tar.gz",
+    force=true,
+    lazy=true,
+)

test/get_parcompat.jl

@@ -1,4 +1,11 @@
-include("get_parcompat.jl")
+using Parquet
+using Test
+using LazyArtifacts, Artifacts
+
+# Note: readdir(...; join=true) requires Julia v1.4.
+const parcompat = joinpath(artifact"parcompat", readdir(artifact"parcompat")[1])
+const julia_parcompat = joinpath(artifact"julia_parcompat", readdir(artifact"julia_parcompat")[1])
+
 @testset "parquet tests" begin
     include("test_load.jl")
     include("test_codec.jl")

test/runtests.jl

@@ -50,21 +50,21 @@ end
 function test_row_cursor_all_files()
     for encformat in ("SNAPPY", "GZIP", "NONE")
         for fname in ("nation", "customer")
-            test_row_cursor(joinpath(@__DIR__, "parquet-compatibility", "parquet-testdata", "impala", "1.1.1-$encformat/$fname.impala.parquet"))
+            test_row_cursor(joinpath(parcompat, "parquet-testdata", "impala", "1.1.1-$encformat/$fname.impala.parquet"))
         end
     end
 end
 
 function test_batchedcols_cursor_all_files()
     for encformat in ("SNAPPY", "GZIP", "NONE")
         for fname in ("nation", "customer")
-            test_batchedcols_cursor(joinpath(@__DIR__, "parquet-compatibility", "parquet-testdata", "impala", "1.1.1-$encformat/$fname.impala.parquet"))
+            test_batchedcols_cursor(joinpath(parcompat, "parquet-testdata", "impala", "1.1.1-$encformat/$fname.impala.parquet"))
         end
     end
 end
 
 function test_col_cursor_length()
-    path = joinpath(@__DIR__, "parquet-compatibility", "parquet-testdata", "impala", "1.1.1-SNAPPY/nation.impala.parquet")
+    path = joinpath(parcompat, "parquet-testdata", "impala", "1.1.1-SNAPPY/nation.impala.parquet")
     pq_file = Parquet.File(path)
     col_name = pq_file |> colnames |> first
     col_cursor = Parquet.ColCursor(pq_file, col_name)

test/test_cursors.jl

@@ -97,7 +97,7 @@ end
 
 function test_decode_all_pages()
     @testset "decode parquet-compatibility test files" begin
-        testfolder = joinpath(@__DIR__, "parquet-compatibility")
+        testfolder = parcompat
         for encformat in ("SNAPPY", "GZIP", "NONE")
             for fname in ("nation", "customer")
                 testfile = joinpath(testfolder, "parquet-testdata", "impala", "1.1.1-$encformat", "$fname.impala.parquet")
@@ -107,7 +107,7 @@ function test_decode_all_pages()
     end
 
     @testset "decode julia-parquet-compatibility test files" begin
-        testfolder = joinpath(@__DIR__, "julia-parquet-compatibility")
+        testfolder = julia_parcompat
         for encformat in ("ZSTD", "SNAPPY", "GZIP", "NONE")
             for fname in ("nation", "customer")
                 testfile = joinpath(testfolder, "Parquet_Files", "$(encformat)_pandas_pyarrow_$(fname).parquet")
@@ -123,7 +123,7 @@ end
 
 function test_load_all_pages()
     @testset "load parquet-compatibility test files" begin
-        testfolder = joinpath(@__DIR__, "parquet-compatibility")
+        testfolder = parcompat
         for encformat in ("SNAPPY", "GZIP", "NONE")
             for fname in ("nation", "customer")
                 testfile = joinpath(testfolder, "parquet-testdata", "impala", "1.1.1-$encformat", "$fname.impala.parquet")
@@ -133,7 +133,7 @@ function test_load_all_pages()
     end
 
     @testset "load julia-parquet-compatibility test files" begin
-        testfolder = joinpath(@__DIR__, "julia-parquet-compatibility")
+        testfolder = julia_parcompat
         for encformat in ("ZSTD", "SNAPPY", "GZIP", "NONE")
             for fname in ("nation", "customer")
                 testfile = joinpath(testfolder, "Parquet_Files", "$(encformat)_pandas_pyarrow_$(fname).parquet")
@@ -323,7 +323,7 @@ end
 
 function test_load_at_offset()
     @testset "load file at offset" begin
-        testfolder = joinpath(@__DIR__, "parquet-compatibility")
+        testfolder = parcompat
         testfile = joinpath(testfolder, "parquet-testdata", "impala", "1.1.1-NONE", "customer.impala.parquet")
         parquet_file = Parquet.File(testfile)