diff --git a/.gitignore b/.gitignore index 37e5c60f..3ffb3f30 100644 --- a/.gitignore +++ b/.gitignore @@ -15,11 +15,13 @@ *.out # Dependency directories (remove the comment below to include it) -# vendor/ +vendor/ # Go workspace file go.work plugin-pb -.DS_Store \ No newline at end of file +.DS_Store + +.idea/ \ No newline at end of file diff --git a/go.mod b/go.mod index 19f89835..cbf891ca 100644 --- a/go.mod +++ b/go.mod @@ -3,7 +3,7 @@ module github.com/cloudquery/plugin-pb-go go 1.19 require ( - github.com/apache/arrow/go/v13 v13.0.0-20230731205701-112f94971882 + github.com/apache/arrow/go/v14 v14.0.0-20230826001106-a069d71cc1bcd github.com/avast/retry-go/v4 v4.3.4 github.com/docker/docker v20.10.25+incompatible github.com/docker/go-connections v0.4.0 @@ -20,6 +20,8 @@ require ( gopkg.in/yaml.v3 v3.0.1 ) +replace github.com/apache/arrow/go/v14 => github.com/cloudquery/arrow/go/v14 v14.0.0-20230826001106-a069d71cc1bc + require ( github.com/Microsoft/go-winio v0.6.1 // indirect github.com/docker/distribution v2.8.2+incompatible // indirect diff --git a/go.sum b/go.sum index d715d442..08d4590d 100644 --- a/go.sum +++ b/go.sum @@ -1,10 +1,10 @@ github.com/Azure/go-ansiterm v0.0.0-20210617225240-d185dfc1b5a1 h1:UQHMgLO+TxOElx5B5HZ4hJQsoJ/PvUvKRhJHDQXO8P8= github.com/Microsoft/go-winio v0.6.1 h1:9/kr64B9VUZrLm5YYwbGtUJnMgqWVOdUAXu6Migciow= github.com/Microsoft/go-winio v0.6.1/go.mod h1:LRdKpFKfdobln8UmuiYcKPot9D2v6svN5+sAH+4kjUM= -github.com/apache/arrow/go/v13 v13.0.0-20230731205701-112f94971882 h1:mFDZW1FQk9yndPvxScp7RpcOpdSHaqcgBWO7sDlx4S8= -github.com/apache/arrow/go/v13 v13.0.0-20230731205701-112f94971882/go.mod h1:W69eByFNO0ZR30q1/7Sr9d83zcVZmF2MiP3fFYAWJOc= github.com/avast/retry-go/v4 v4.3.4 h1:pHLkL7jvCvP317I8Ge+Km2Yhntv3SdkJm7uekkqbKhM= github.com/avast/retry-go/v4 v4.3.4/go.mod h1:rv+Nla6Vk3/ilU0H51VHddWHiwimzX66yZ0JT6T+UvE= +github.com/cloudquery/arrow/go/v14 v14.0.0-20230826001106-a069d71cc1bc h1:xNEmwt8TXE+Z5YdwmXpXDk6YgFxcffdmJeGFal1Ta9k= +github.com/cloudquery/arrow/go/v14 v14.0.0-20230826001106-a069d71cc1bc/go.mod h1:QQ18IZU2Y3BFqHtF2HyvrjEEmk8TyzzmXgUVjep3bCw= github.com/coreos/go-systemd/v22 v22.5.0/go.mod h1:Y58oyj3AT4RCenI/lSvhwexgC+NSVTIJ3seZv2GcEnc= github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= diff --git a/pb/destination/v1/arrow.go b/pb/destination/v1/arrow.go index 0c2f177a..de76de99 100644 --- a/pb/destination/v1/arrow.go +++ b/pb/destination/v1/arrow.go @@ -3,8 +3,8 @@ package destination import ( "bytes" - "github.com/apache/arrow/go/v13/arrow" - "github.com/apache/arrow/go/v13/arrow/ipc" + "github.com/apache/arrow/go/v14/arrow" + "github.com/apache/arrow/go/v14/arrow/ipc" ) func NewSchemasFromBytes(b [][]byte) ([]*arrow.Schema, error) { diff --git a/pb/plugin/v3/arrow.go b/pb/plugin/v3/arrow.go index f1516abd..6cf1e418 100644 --- a/pb/plugin/v3/arrow.go +++ b/pb/plugin/v3/arrow.go @@ -3,8 +3,8 @@ package plugin import ( "bytes" - "github.com/apache/arrow/go/v13/arrow" - "github.com/apache/arrow/go/v13/arrow/ipc" + "github.com/apache/arrow/go/v14/arrow" + "github.com/apache/arrow/go/v14/arrow/ipc" ) func SchemaToBytes(sc *arrow.Schema) ([]byte, error) { diff --git a/pb/plugin/v3/arrow_test.go b/pb/plugin/v3/arrow_test.go index 526c0237..b619ddec 100644 --- a/pb/plugin/v3/arrow_test.go +++ b/pb/plugin/v3/arrow_test.go @@ -3,9 +3,9 @@ package plugin import ( "testing" - "github.com/apache/arrow/go/v13/arrow" - "github.com/apache/arrow/go/v13/arrow/array" - "github.com/apache/arrow/go/v13/arrow/memory" + "github.com/apache/arrow/go/v14/arrow" + "github.com/apache/arrow/go/v14/arrow/array" + "github.com/apache/arrow/go/v14/arrow/memory" ) func TestSchemaRoundTrip(t *testing.T) { diff --git a/pb/source/v2/arrow.go b/pb/source/v2/arrow.go index 19152d51..c22e449b 100644 --- a/pb/source/v2/arrow.go +++ b/pb/source/v2/arrow.go @@ -3,8 +3,8 @@ package source import ( "bytes" - "github.com/apache/arrow/go/v13/arrow" - "github.com/apache/arrow/go/v13/arrow/ipc" + "github.com/apache/arrow/go/v14/arrow" + "github.com/apache/arrow/go/v14/arrow/ipc" ) func SchemasToBytes(schemas []*arrow.Schema) ([][]byte, error) {