From ce01bff17452b5db4fd271ae46526b8da030498d Mon Sep 17 00:00:00 2001 From: Joe Elliott Date: Wed, 13 Dec 2023 17:34:33 -0500 Subject: [PATCH] update parquet-go Signed-off-by: Joe Elliott --- go.mod | 2 +- go.sum | 4 ++-- pkg/inspect/col_stats.go | 5 ++++- 3 files changed, 7 insertions(+), 4 deletions(-) diff --git a/go.mod b/go.mod index 33ccda5..3d136ac 100644 --- a/go.mod +++ b/go.mod @@ -4,7 +4,7 @@ go 1.21 require ( github.com/alecthomas/kong v0.8.0 - github.com/parquet-go/parquet-go v0.17.0 + github.com/parquet-go/parquet-go v0.20.1-0.20231211122939-bec192ac8b06 github.com/segmentio/encoding v0.3.6 github.com/stretchr/testify v1.8.4 ) diff --git a/go.sum b/go.sum index 6a5a8a1..a0b6445 100644 --- a/go.sum +++ b/go.sum @@ -19,8 +19,8 @@ github.com/mattn/go-runewidth v0.0.15 h1:UNAjwbU9l54TA3KzvqLGxwWjHmMgBUVhBiTjelZ github.com/mattn/go-runewidth v0.0.15/go.mod h1:Jdepj2loyihRzMpdS35Xk/zdY8IAYHsh153qUoGf23w= github.com/olekukonko/tablewriter v0.0.5 h1:P2Ga83D34wi1o9J6Wh1mRuqd4mF/x/lgBS7N7AbDhec= github.com/olekukonko/tablewriter v0.0.5/go.mod h1:hPp6KlRPjbx+hW8ykQs1w3UBbZlj6HuIJcUGPhkA7kY= -github.com/parquet-go/parquet-go v0.17.0 h1:CCtKYt02AkjmGchk5pw4uWzzN0XRWU7f8sKUWpdqHZo= -github.com/parquet-go/parquet-go v0.17.0/go.mod h1:6pu/Ca02WRyWyF6jbY1KceESGBZMsRMSijjLbajXaG8= +github.com/parquet-go/parquet-go v0.20.1-0.20231211122939-bec192ac8b06 h1:IERPFFXg0xUx3eX/IEtWkLUh8GtPSLS6gVF7ho7LmwU= +github.com/parquet-go/parquet-go v0.20.1-0.20231211122939-bec192ac8b06/go.mod h1:4YfUo8TkoGoqwzhA/joZKZ8f77wSMShOLHESY4Ys0bY= github.com/pierrec/lz4/v4 v4.1.18 h1:xaKrnTkyoqfh1YItXl56+6KJNVYWlEEPuAQW9xsplYQ= github.com/pierrec/lz4/v4 v4.1.18/go.mod h1:gZWDp/Ze/IJXGXf23ltt2EXimqmTUXEy0GFuRQyBid4= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= diff --git a/pkg/inspect/col_stats.go b/pkg/inspect/col_stats.go index b31271e..1b464a7 100644 --- a/pkg/inspect/col_stats.go +++ b/pkg/inspect/col_stats.go @@ -125,7 +125,10 @@ func (cc *ColStatCalculator) NextRow() (output.TableRow, error) { for _, rg := range cc.file.RowGroups() { chunk := rg.ColumnChunks()[col.Index()] - index := chunk.OffsetIndex() + index, err := chunk.OffsetIndex() + if err != nil { + return nil, fmt.Errorf("unable to read offset index from column '%s': %w", col.Name(), err) + } if index != nil { for i := 0; i < index.NumPages(); i++ { stats.CompressedSize += index.CompressedPageSize(i)