diff --git a/go.mod b/go.mod index 0921f16a..74051d8c 100644 --- a/go.mod +++ b/go.mod @@ -3,7 +3,7 @@ module github.com/xitongsys/parquet-go go 1.13 require ( - github.com/apache/thrift v0.0.0-20181112125854-24918abba929 + github.com/apache/thrift v0.13.1-0.20201008052519-daf620915714 github.com/golang/snappy v0.0.1 github.com/klauspost/compress v1.10.5 github.com/xitongsys/parquet-go-source v0.0.0-20200817004010-026bad9b25d0 diff --git a/go.sum b/go.sum index 33edf3a7..0dd6c8d4 100644 --- a/go.sum +++ b/go.sum @@ -24,6 +24,8 @@ github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03 github.com/BurntSushi/xgb v0.0.0-20160522181843-27f122750802/go.mod h1:IVnqGOEym/WlBOVXweHU+Q+/VP0lqqI8lqeDx9IjBqo= github.com/apache/thrift v0.0.0-20181112125854-24918abba929 h1:ubPe2yRkS6A/X37s0TVGfuN42NV2h0BlzWj0X76RoUw= github.com/apache/thrift v0.0.0-20181112125854-24918abba929/go.mod h1:cp2SuWMxlEZw2r+iP2GNCdIi4C1qmUzdZFSVb+bacwQ= +github.com/apache/thrift v0.13.1-0.20201008052519-daf620915714 h1:Jz3KVLYY5+JO7rDiX0sAuRGtuv2vG01r17Y9nLMWNUw= +github.com/apache/thrift v0.13.1-0.20201008052519-daf620915714/go.mod h1:cp2SuWMxlEZw2r+iP2GNCdIi4C1qmUzdZFSVb+bacwQ= github.com/aws/aws-sdk-go v1.30.19/go.mod h1:5zCpMtNQVjRREroY7sYe8lOMRSxkhG6MZveU8YkpAk0= github.com/census-instrumentation/opencensus-proto v0.2.1/go.mod h1:f6KPmirojxKA12rnyqOA5BBL4O983OfeGPqjHWSTneU= github.com/chzyer/logex v1.1.10/go.mod h1:+Ywpsq7O8HXn0nuIou7OrIPyXbp3wmkHB+jjWRnGsAI= diff --git a/reader/reader.go b/reader/reader.go index 3f0d897d..a3f6696d 100644 --- a/reader/reader.go +++ b/reader/reader.go @@ -1,6 +1,7 @@ package reader import ( + "context" "encoding/binary" "io" "reflect" @@ -142,7 +143,7 @@ func (self *ParquetReader) ReadFooter() error { self.Footer = parquet.NewFileMetaData() pf := thrift.NewTCompactProtocolFactory() protocol := pf.GetProtocol(thrift.NewStreamTransportR(self.PFile)) - return self.Footer.Read(protocol) + return self.Footer.Read(context.TODO(), protocol) } //Skip rows of parquet file