Skip to content

Commit

Permalink
update to latest thrift
Browse files Browse the repository at this point in the history
  • Loading branch information
xitongsys committed Oct 10, 2020
1 parent cfbbf14 commit f51647f
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 2 deletions.
2 changes: 1 addition & 1 deletion go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
2 changes: 2 additions & 0 deletions go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -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=
Expand Down
3 changes: 2 additions & 1 deletion reader/reader.go
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
package reader

import (
"context"
"encoding/binary"
"io"
"reflect"
Expand Down Expand Up @@ -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
Expand Down

0 comments on commit f51647f

Please sign in to comment.