Skip to content

Commit

Permalink
upgrade thrift to 18.1
Browse files Browse the repository at this point in the history
  • Loading branch information
cswank committed Jul 20, 2023
1 parent 6899565 commit 01cf62f
Show file tree
Hide file tree
Showing 8 changed files with 8,749 additions and 9,593 deletions.
10 changes: 8 additions & 2 deletions go.mod
Original file line number Diff line number Diff line change
@@ -1,11 +1,17 @@
module github.com/parsyl/parquet

go 1.13
go 1.20

require (
github.com/apache/thrift v0.13.0
github.com/apache/thrift v0.18.1
github.com/bxcodec/faker/v3 v3.6.0
github.com/golang/snappy v0.0.2
github.com/stretchr/testify v1.7.0
github.com/valyala/bytebufferpool v1.0.0
)

require (
github.com/davecgh/go-spew v1.1.0 // indirect
github.com/pmezard/go-difflib v1.0.0 // indirect
gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c // indirect
)
4 changes: 2 additions & 2 deletions go.sum
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
github.com/apache/thrift v0.13.0 h1:5hryIiq9gtn+MiLVn0wP37kb/uTeRZgN08WoCsAhIhI=
github.com/apache/thrift v0.13.0/go.mod h1:cp2SuWMxlEZw2r+iP2GNCdIi4C1qmUzdZFSVb+bacwQ=
github.com/apache/thrift v0.18.1 h1:lNhK/1nqjbwbiOPDBPFJVKxgDEGSepKuTh6OLiXW8kg=
github.com/apache/thrift v0.18.1/go.mod h1:rdQn/dCcDKEWjjylUeueum4vQEjG2v8v2PqriUnbr+I=
github.com/bxcodec/faker/v3 v3.6.0 h1:Meuh+M6pQJsQJwxVALq6H5wpDzkZ4pStV9pmH7gbKKs=
github.com/bxcodec/faker/v3 v3.6.0/go.mod h1:gF31YgnMSMKgkvl+fyEo1xuSMbEuieyqfeslGYFjneM=
github.com/davecgh/go-spew v1.1.0 h1:ZDRjVQ15GmhC3fiQ8ni8+OwkZQO4DARzQgrnXU1Liz8=
Expand Down
4 changes: 2 additions & 2 deletions parquet.go
Original file line number Diff line number Diff line change
Expand Up @@ -368,7 +368,7 @@ func ReadMetaData(r io.ReadSeeker) (*sch.FileMetaData, error) {
}

m := sch.NewFileMetaData()
return m, m.Read(p)
return m, m.Read(context.TODO(), p)
}

// ReadFooter reads the parquet metadata
Expand All @@ -382,7 +382,7 @@ func (m *Metadata) ReadFooter(r io.ReadSeeker) error {
func PageHeader(r io.Reader) (*sch.PageHeader, error) {
p := thrift.NewTCompactProtocol(&thrift.StreamTransport{Reader: r})
pg := &sch.PageHeader{}
err := pg.Read(p)
err := pg.Read(context.TODO(), p)
return pg, err
}

Expand Down
7 changes: 4 additions & 3 deletions schema/GoUnusedProtection__.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

30 changes: 30 additions & 0 deletions schema/parquet-consts.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Loading

0 comments on commit 01cf62f

Please sign in to comment.