Skip to content

Commit f9ade89

Browse files
cq-botcq-bot
authored
fix(deps): Update module github.com/cloudquery/plugin-sdk/v4 to v4.93.1 (#697)
This PR contains the following updates: | Package | Type | Update | Change | |---|---|---|---| | [github.com/cloudquery/plugin-sdk/v4](https://redirect.github.com/cloudquery/plugin-sdk) | require | patch | `v4.93.0` -> `v4.93.1` | --- ### Release Notes <details> <summary>cloudquery/plugin-sdk (github.com/cloudquery/plugin-sdk/v4)</summary> ### [`v4.93.1`](https://redirect.github.com/cloudquery/plugin-sdk/releases/tag/v4.93.1) [Compare Source](https://redirect.github.com/cloudquery/plugin-sdk/compare/v4.93.0...v4.93.1) ##### Bug Fixes - **deps:** Update module github.com/cloudquery/cloudquery-api-go to v1.14.7 ([#&#8203;2365](https://redirect.github.com/cloudquery/plugin-sdk/issues/2365)) ([1953885](https://redirect.github.com/cloudquery/plugin-sdk/commit/19538857776889bba19f91f5acbaa103703768b4)) - **deps:** Update module github.com/cloudquery/plugin-pb-go to v1.27.1 ([#&#8203;2367](https://redirect.github.com/cloudquery/plugin-sdk/issues/2367)) ([985d54a](https://redirect.github.com/cloudquery/plugin-sdk/commit/985d54ace1f535e9c8afb7f6f9e87e6921fe9ef2)) - **deps:** Update module github.com/cloudquery/plugin-pb-go to v1.27.2 ([#&#8203;2368](https://redirect.github.com/cloudquery/plugin-sdk/issues/2368)) ([d54cb52](https://redirect.github.com/cloudquery/plugin-sdk/commit/d54cb521324ded7593cf9add421bb38c280166b0)) - **deps:** Update module github.com/spf13/cobra to v1.10.2 ([#&#8203;2353](https://redirect.github.com/cloudquery/plugin-sdk/issues/2353)) ([8c37fb4](https://redirect.github.com/cloudquery/plugin-sdk/commit/8c37fb478994612422dc4b83ef7eec10a249e019)) - **deps:** Update module golang.org/x/oauth2 to v0.34.0 ([#&#8203;2364](https://redirect.github.com/cloudquery/plugin-sdk/issues/2364)) ([d8a6cff](https://redirect.github.com/cloudquery/plugin-sdk/commit/d8a6cffc93620ce623e809451b9a659ccf649f80)) - **deps:** Update module golang.org/x/sync to v0.19.0 ([#&#8203;2355](https://redirect.github.com/cloudquery/plugin-sdk/issues/2355)) ([72f27ac](https://redirect.github.com/cloudquery/plugin-sdk/commit/72f27ac9573dcf3e00ecfe557b8519bac6d70610)) </details> --- ### Configuration 📅 **Schedule**: Branch creation - At any time (no schedule defined), Automerge - At any time (no schedule defined). 🚦 **Automerge**: Disabled by config. Please merge this manually once you are satisfied. ♻ **Rebasing**: Whenever PR becomes conflicted, or you tick the rebase/retry checkbox. 🔕 **Ignore**: Close this PR and you won't be reminded about this update again. --- - [ ] <!-- rebase-check -->If you want to rebase/retry this PR, check this box --- This PR has been generated by [Renovate Bot](https://redirect.github.com/renovatebot/renovate). <!--renovate-debug:eyJjcmVhdGVkSW5WZXIiOiI0MC4yMi4xIiwidXBkYXRlZEluVmVyIjoiNDAuMjIuMSIsInRhcmdldEJyYW5jaCI6Im1haW4iLCJsYWJlbHMiOlsiYXV0b21lcmdlIl19-->
1 parent 0efbf96 commit f9ade89

22 files changed

Lines changed: 106 additions & 106 deletions

‎csv/read.go‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ import (
1111
"github.com/cloudquery/plugin-sdk/v4/schema"
1212
)
1313

14-
func (cl *Client) Read(r types.ReaderAtSeeker, table *schema.Table, res chan<- arrow.Record) error {
14+
func (cl *Client) Read(r types.ReaderAtSeeker, table *schema.Table, res chan<- arrow.RecordBatch) error {
1515
arrowSchema := table.ToArrowSchema()
1616
newSchema := convertSchema(arrowSchema)
1717
reader := csv.NewReader(r, newSchema,
@@ -23,7 +23,7 @@ func (cl *Client) Read(r types.ReaderAtSeeker, table *schema.Table, res chan<- a
2323
if reader.Err() != nil {
2424
return reader.Err()
2525
}
26-
rec := reader.Record()
26+
rec := reader.RecordBatch()
2727
castRec, err := castFromString(rec, arrowSchema)
2828
if err != nil {
2929
return fmt.Errorf("failed to cast extension types: %w", err)
@@ -34,7 +34,7 @@ func (cl *Client) Read(r types.ReaderAtSeeker, table *schema.Table, res chan<- a
3434
}
3535

3636
// castFromString casts extension columns to string.
37-
func castFromString(rec arrow.Record, arrowSchema *arrow.Schema) (arrow.Record, error) {
37+
func castFromString(rec arrow.RecordBatch, arrowSchema *arrow.Schema) (arrow.RecordBatch, error) {
3838
cols := make([]arrow.Array, rec.NumCols())
3939
for c, f := range arrowSchema.Fields() {
4040
col := rec.Column(c)
@@ -55,5 +55,5 @@ func castFromString(rec arrow.Record, arrowSchema *arrow.Schema) (arrow.Record,
5555
}
5656
cols[c] = sb.NewArray()
5757
}
58-
return array.NewRecord(arrowSchema, cols, rec.NumRows()), nil
58+
return array.NewRecordBatch(arrowSchema, cols, rec.NumRows()), nil
5959
}

‎csv/testdata/TestWriteRead-default.csv‎

Lines changed: 2 additions & 2 deletions
Large diffs are not rendered by default.

‎csv/testdata/TestWriteRead-with_delimiter.csv‎

Lines changed: 2 additions & 2 deletions
Large diffs are not rendered by default.

‎csv/testdata/TestWriteRead-with_delimiter_headers.csv‎

Lines changed: 2 additions & 2 deletions
Large diffs are not rendered by default.

‎csv/testdata/TestWriteRead-with_headers.csv‎

Lines changed: 2 additions & 2 deletions
Large diffs are not rendered by default.

‎csv/write.go‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ func (cl *Client) WriteHeader(w io.Writer, t *schema.Table) (types.Handle, error
3636
}, nil
3737
}
3838

39-
func (h *Handle) WriteContent(records []arrow.Record) error {
39+
func (h *Handle) WriteContent(records []arrow.RecordBatch) error {
4040
for _, record := range records {
4141
castRec := h.castToString(record)
4242
if err := h.w.Write(castRec); err != nil {
@@ -91,7 +91,7 @@ func isTypeSupported(t arrow.DataType) bool {
9191
}
9292

9393
// castToString casts extension columns or unsupported columns to string. It does not release the original record.
94-
func (h *Handle) castToString(rec arrow.Record) arrow.Record {
94+
func (h *Handle) castToString(rec arrow.RecordBatch) arrow.RecordBatch {
9595
cols := make([]arrow.Array, h.schema.NumFields())
9696
for c := 0; c < h.schema.NumFields(); c++ {
9797
col := rec.Column(c)
@@ -110,7 +110,7 @@ func (h *Handle) castToString(rec arrow.Record) arrow.Record {
110110
}
111111
cols[c] = sb.NewArray()
112112
}
113-
return array.NewRecord(h.schema, cols, rec.NumRows())
113+
return array.NewRecordBatch(h.schema, cols, rec.NumRows())
114114
}
115115

116116
func stripCQExtensionMetadata(md arrow.Metadata) arrow.Metadata {

‎csv/write_read_test.go‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ func TestWriteRead(t *testing.T) {
5050
writer := bufio.NewWriter(&b)
5151
reader := bufio.NewReader(&b)
5252

53-
if err := types.WriteAll(cl, writer, table, []arrow.Record{record}); err != nil {
53+
if err := types.WriteAll(cl, writer, table, []arrow.RecordBatch{record}); err != nil {
5454
t.Fatal(err)
5555
}
5656
writer.Flush()
@@ -67,17 +67,17 @@ func TestWriteRead(t *testing.T) {
6767

6868
byteReader := bytes.NewReader(rawBytes)
6969

70-
ch := make(chan arrow.Record)
70+
ch := make(chan arrow.RecordBatch)
7171
var readErr error
7272
go func() {
7373
readErr = cl.Read(byteReader, table, ch)
7474
close(ch)
7575
}()
76-
received := make([]arrow.Record, 0, tc.outputCount)
76+
received := make([]arrow.RecordBatch, 0, tc.outputCount)
7777
for got := range ch {
7878
received = append(received, got)
7979
}
80-
require.Empty(t, plugin.RecordsDiff(table.ToArrowSchema(), []arrow.Record{record}, received))
80+
require.Empty(t, plugin.RecordsDiff(table.ToArrowSchema(), []arrow.RecordBatch{record}, received))
8181
require.NoError(t, readErr)
8282
require.Equalf(t, tc.outputCount, len(received), "got %d row(s), want %d", len(received), tc.outputCount)
8383
})
@@ -104,7 +104,7 @@ func BenchmarkWrite(b *testing.B) {
104104
writer := bufio.NewWriter(&buf)
105105
b.ResetTimer()
106106
for i := 0; i < b.N; i++ {
107-
if err := types.WriteAll(cl, writer, table, []arrow.Record{record}); err != nil {
107+
if err := types.WriteAll(cl, writer, table, []arrow.RecordBatch{record}); err != nil {
108108
b.Fatal(err)
109109
}
110110

‎go.mod‎

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -3,10 +3,10 @@ module github.com/cloudquery/filetypes/v4
33
go 1.25.1
44

55
require (
6-
github.com/apache/arrow-go/v18 v18.4.0
6+
github.com/apache/arrow-go/v18 v18.5.0
77
github.com/bradleyjkemp/cupaloy/v2 v2.8.0
88
github.com/cloudquery/codegen v0.3.33
9-
github.com/cloudquery/plugin-sdk/v4 v4.93.0
9+
github.com/cloudquery/plugin-sdk/v4 v4.93.1
1010
github.com/goccy/go-json v0.10.5
1111
github.com/invopop/jsonschema v0.13.0
1212
github.com/stretchr/testify v1.11.1
@@ -20,16 +20,16 @@ require (
2020
github.com/bahlo/generic-list-go v0.2.0 // indirect
2121
github.com/buger/jsonparser v1.1.1 // indirect
2222
github.com/cespare/xxhash/v2 v2.3.0 // indirect
23-
github.com/cloudquery/cloudquery-api-go v1.14.6 // indirect
23+
github.com/cloudquery/cloudquery-api-go v1.14.7 // indirect
2424
github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc // indirect
2525
github.com/golang/snappy v1.0.0 // indirect
26-
github.com/google/flatbuffers v25.2.10+incompatible // indirect
26+
github.com/google/flatbuffers v25.9.23+incompatible // indirect
2727
github.com/google/uuid v1.6.0 // indirect
2828
github.com/hashicorp/go-cleanhttp v0.5.2 // indirect
2929
github.com/hashicorp/go-retryablehttp v0.7.8 // indirect
3030
github.com/klauspost/asmfmt v1.3.2 // indirect
31-
github.com/klauspost/compress v1.18.0 // indirect
32-
github.com/klauspost/cpuid/v2 v2.2.11 // indirect
31+
github.com/klauspost/compress v1.18.2 // indirect
32+
github.com/klauspost/cpuid/v2 v2.3.0 // indirect
3333
github.com/mailru/easyjson v0.7.7 // indirect
3434
github.com/mattn/go-colorable v0.1.13 // indirect
3535
github.com/mattn/go-isatty v0.0.20 // indirect
@@ -43,18 +43,18 @@ require (
4343
github.com/santhosh-tekuri/jsonschema/v6 v6.0.2 // indirect
4444
github.com/thoas/go-funk v0.9.3 // indirect
4545
github.com/zeebo/xxh3 v1.0.2 // indirect
46-
golang.org/x/exp v0.0.0-20251023183803-a4bb9ffd2546 // indirect
47-
golang.org/x/mod v0.29.0 // indirect
48-
golang.org/x/net v0.47.0 // indirect
49-
golang.org/x/sync v0.18.0 // indirect
46+
golang.org/x/exp v0.0.0-20251209150349-8475f28825e9 // indirect
47+
golang.org/x/mod v0.31.0 // indirect
48+
golang.org/x/net v0.48.0 // indirect
49+
golang.org/x/sync v0.19.0 // indirect
5050
golang.org/x/sys v0.39.0 // indirect
51-
golang.org/x/telemetry v0.0.0-20251008203120-078029d740a8 // indirect
52-
golang.org/x/text v0.31.0 // indirect
53-
golang.org/x/tools v0.38.0 // indirect
51+
golang.org/x/telemetry v0.0.0-20251203150158-8fff8a5912fc // indirect
52+
golang.org/x/text v0.32.0 // indirect
53+
golang.org/x/tools v0.40.0 // indirect
5454
golang.org/x/xerrors v0.0.0-20240903120638-7835f813f4da // indirect
5555
google.golang.org/genproto/googleapis/rpc v0.0.0-20251202230838-ff82c1b0f217 // indirect
5656
google.golang.org/grpc v1.77.0 // indirect
57-
google.golang.org/protobuf v1.36.10 // indirect
57+
google.golang.org/protobuf v1.36.11 // indirect
5858
gopkg.in/yaml.v3 v3.0.1 // indirect
5959
)
6060

‎go.sum‎

Lines changed: 28 additions & 28 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
11
github.com/RaveNoX/go-jsoncommentstrip v1.0.0/go.mod h1:78ihd09MekBnJnxpICcwzCMzGrKSKYe4AqU6PDYYpjk=
22
github.com/andybalholm/brotli v1.2.0 h1:ukwgCxwYrmACq68yiUqwIWnGY0cTPox/M94sVwToPjQ=
33
github.com/andybalholm/brotli v1.2.0/go.mod h1:rzTDkvFWvIrjDXZHkuS16NPggd91W3kUSvPlQ1pLaKY=
4-
github.com/apache/arrow-go/v18 v18.4.0 h1:/RvkGqH517iY8bZKc4FD5/kkdwXJGjxf28JIXbJ/oB0=
5-
github.com/apache/arrow-go/v18 v18.4.0/go.mod h1:Aawvwhj8x2jURIzD9Moy72cF0FyJXOpkYpdmGRHcw14=
4+
github.com/apache/arrow-go/v18 v18.5.0 h1:rmhKjVA+MKVnQIMi/qnM0OxeY4tmHlN3/Pvu+Itmd6s=
5+
github.com/apache/arrow-go/v18 v18.5.0/go.mod h1:F1/wPb3bUy6ZdP4kEPWC7GUZm+yDmxXFERK6uDSkhr8=
66
github.com/apache/thrift v0.22.0 h1:r7mTJdj51TMDe6RtcmNdQxgn9XcyfGDOzegMDRg47uc=
77
github.com/apache/thrift v0.22.0/go.mod h1:1e7J/O1Ae6ZQMTYdy9xa3w9k+XHWPfRvdPyJeynQ+/g=
88
github.com/apapsch/go-jsonmerge/v2 v2.0.0 h1:axGnT1gRIfimI7gJifB699GoE/oq+F2MU7Dml6nw9rQ=
@@ -16,14 +16,14 @@ github.com/buger/jsonparser v1.1.1 h1:2PnMjfWD7wBILjqQbt530v576A/cAbQvEW9gGIpYMU
1616
github.com/buger/jsonparser v1.1.1/go.mod h1:6RYKKt7H4d4+iWqouImQ9R2FZql3VbhNgx27UK13J/0=
1717
github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs=
1818
github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
19-
github.com/cloudquery/cloudquery-api-go v1.14.6 h1:lY0ndk5XAe84EronTCg8AnB40FwHCbAYpM4QEPzEb9E=
20-
github.com/cloudquery/cloudquery-api-go v1.14.6/go.mod h1:d+I8E+z3vmvTvCNXZ5YNhxV9InY/i1siXa0vCYq+ABk=
19+
github.com/cloudquery/cloudquery-api-go v1.14.7 h1:j8XkwY7YMtZnXi655BTFLqadCs9PJtISkw9Au2+/8QY=
20+
github.com/cloudquery/cloudquery-api-go v1.14.7/go.mod h1:d+I8E+z3vmvTvCNXZ5YNhxV9InY/i1siXa0vCYq+ABk=
2121
github.com/cloudquery/codegen v0.3.33 h1:EsQjaiupoTgUvwYNmeHy2Wj3XWrpXXojnGZmnV9GpLM=
2222
github.com/cloudquery/codegen v0.3.33/go.mod h1:abfJ0HDW4Elh+ppwbKrCuAsXfZUmaWyY+4SgUyfQndg=
2323
github.com/cloudquery/jsonschema v0.0.0-20240220124159-92878faa2a66 h1:OZLPSIBYEfvkAUeOeM8CwTgVQy5zhayI99ishCrsFV0=
2424
github.com/cloudquery/jsonschema v0.0.0-20240220124159-92878faa2a66/go.mod h1:0SoZ/U7yJlNOR+fWsBSeTvTbGXB6DK01tzJ7m2Xfg34=
25-
github.com/cloudquery/plugin-sdk/v4 v4.93.0 h1:JJSH8q8d0bMdm7aU2zBM4t2lBim5kyAs2Nr1c0ZRN7I=
26-
github.com/cloudquery/plugin-sdk/v4 v4.93.0/go.mod h1:aTEk8USXw57jW8dnsEwIZgF0T2e3SsifAqjUK1dIZZQ=
25+
github.com/cloudquery/plugin-sdk/v4 v4.93.1 h1:doZ1CA6LYgatqsJvfcOE7PNOaIbvktsWi4vEGyNnqQw=
26+
github.com/cloudquery/plugin-sdk/v4 v4.93.1/go.mod h1:1gs7aC8I7QAHu5FPffFUSHC/TjFv6V8w1gRLvd/U93g=
2727
github.com/coreos/go-systemd/v22 v22.5.0/go.mod h1:Y58oyj3AT4RCenI/lSvhwexgC+NSVTIJ3seZv2GcEnc=
2828
github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
2929
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
@@ -44,8 +44,8 @@ github.com/golang/protobuf v1.5.4 h1:i7eJL8qZTpSEXOPTxNKhASYpMn+8e5Q6AdndVa1dWek
4444
github.com/golang/protobuf v1.5.4/go.mod h1:lnTiLA8Wa4RWRcIUkrtSVa5nRhsEGBg48fD6rSs7xps=
4545
github.com/golang/snappy v1.0.0 h1:Oy607GVXHs7RtbggtPBnr2RmDArIsAefDwvrdWvRhGs=
4646
github.com/golang/snappy v1.0.0/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
47-
github.com/google/flatbuffers v25.2.10+incompatible h1:F3vclr7C3HpB1k9mxCGRMXq6FdUalZ6H/pNX4FP1v0Q=
48-
github.com/google/flatbuffers v25.2.10+incompatible/go.mod h1:1AeVuKshWv4vARoZatz6mlQ0JxURH0Kv5+zNeJKJCa8=
47+
github.com/google/flatbuffers v25.9.23+incompatible h1:rGZKv+wOb6QPzIdkM2KxhBZCDrA0DeN6DNmRDrqIsQU=
48+
github.com/google/flatbuffers v25.9.23+incompatible/go.mod h1:1AeVuKshWv4vARoZatz6mlQ0JxURH0Kv5+zNeJKJCa8=
4949
github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8=
5050
github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX3N/iU=
5151
github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
@@ -60,10 +60,10 @@ github.com/josharian/intern v1.0.0/go.mod h1:5DoeVV0s6jJacbCEi61lwdGj/aVlrQvzHFF
6060
github.com/juju/gnuflag v0.0.0-20171113085948-2ce1bb71843d/go.mod h1:2PavIy+JPciBPrBUjwbNvtwB6RQlve+hkpll6QSNmOE=
6161
github.com/klauspost/asmfmt v1.3.2 h1:4Ri7ox3EwapiOjCki+hw14RyKk201CN4rzyCJRFLpK4=
6262
github.com/klauspost/asmfmt v1.3.2/go.mod h1:AG8TuvYojzulgDAMCnYn50l/5QV3Bs/tp6j0HLHbNSE=
63-
github.com/klauspost/compress v1.18.0 h1:c/Cqfb0r+Yi+JtIEq73FWXVkRonBlf0CRNYc8Zttxdo=
64-
github.com/klauspost/compress v1.18.0/go.mod h1:2Pp+KzxcywXVXMr50+X0Q/Lsb43OQHYWRCY2AiWywWQ=
65-
github.com/klauspost/cpuid/v2 v2.2.11 h1:0OwqZRYI2rFrjS4kvkDnqJkKHdHaRnCm68/DY4OxRzU=
66-
github.com/klauspost/cpuid/v2 v2.2.11/go.mod h1:hqwkgyIinND0mEev00jJYCxPNVRVXFQeu1XKlok6oO0=
63+
github.com/klauspost/compress v1.18.2 h1:iiPHWW0YrcFgpBYhsA6D1+fqHssJscY/Tm/y2Uqnapk=
64+
github.com/klauspost/compress v1.18.2/go.mod h1:R0h/fSBs8DE4ENlcrlib3PsXS61voFxhIs2DeRhCvJ4=
65+
github.com/klauspost/cpuid/v2 v2.3.0 h1:S4CRMLnYUhGeDFDqkGriYKdfoFlDnMtqTiI/sFzhA9Y=
66+
github.com/klauspost/cpuid/v2 v2.3.0/go.mod h1:hqwkgyIinND0mEev00jJYCxPNVRVXFQeu1XKlok6oO0=
6767
github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
6868
github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
6969
github.com/mailru/easyjson v0.7.7 h1:UGYAvKxe3sBsEDzO8ZeWOSlIQfWFlxbzLZe7hwFURr0=
@@ -127,25 +127,25 @@ go.opentelemetry.io/otel/sdk/metric v1.39.0 h1:cXMVVFVgsIf2YL6QkRF4Urbr/aMInf+2W
127127
go.opentelemetry.io/otel/sdk/metric v1.39.0/go.mod h1:xq9HEVH7qeX69/JnwEfp6fVq5wosJsY1mt4lLfYdVew=
128128
go.opentelemetry.io/otel/trace v1.39.0 h1:2d2vfpEDmCJ5zVYz7ijaJdOF59xLomrvj7bjt6/qCJI=
129129
go.opentelemetry.io/otel/trace v1.39.0/go.mod h1:88w4/PnZSazkGzz/w84VHpQafiU4EtqqlVdxWy+rNOA=
130-
golang.org/x/exp v0.0.0-20251023183803-a4bb9ffd2546 h1:mgKeJMpvi0yx/sU5GsxQ7p6s2wtOnGAHZWCHUM4KGzY=
131-
golang.org/x/exp v0.0.0-20251023183803-a4bb9ffd2546/go.mod h1:j/pmGrbnkbPtQfxEe5D0VQhZC6qKbfKifgD0oM7sR70=
132-
golang.org/x/mod v0.29.0 h1:HV8lRxZC4l2cr3Zq1LvtOsi/ThTgWnUk/y64QSs8GwA=
133-
golang.org/x/mod v0.29.0/go.mod h1:NyhrlYXJ2H4eJiRy/WDBO6HMqZQ6q9nk4JzS3NuCK+w=
134-
golang.org/x/net v0.47.0 h1:Mx+4dIFzqraBXUugkia1OOvlD6LemFo1ALMHjrXDOhY=
135-
golang.org/x/net v0.47.0/go.mod h1:/jNxtkgq5yWUGYkaZGqo27cfGZ1c5Nen03aYrrKpVRU=
136-
golang.org/x/sync v0.18.0 h1:kr88TuHDroi+UVf+0hZnirlk8o8T+4MrK6mr60WkH/I=
137-
golang.org/x/sync v0.18.0/go.mod h1:9KTHXmSnoGruLpwFjVSX0lNNA75CykiMECbovNTZqGI=
130+
golang.org/x/exp v0.0.0-20251209150349-8475f28825e9 h1:MDfG8Cvcqlt9XXrmEiD4epKn7VJHZO84hejP9Jmp0MM=
131+
golang.org/x/exp v0.0.0-20251209150349-8475f28825e9/go.mod h1:EPRbTFwzwjXj9NpYyyrvenVh9Y+GFeEvMNh7Xuz7xgU=
132+
golang.org/x/mod v0.31.0 h1:HaW9xtz0+kOcWKwli0ZXy79Ix+UW/vOfmWI5QVd2tgI=
133+
golang.org/x/mod v0.31.0/go.mod h1:43JraMp9cGx1Rx3AqioxrbrhNsLl2l/iNAvuBkrezpg=
134+
golang.org/x/net v0.48.0 h1:zyQRTTrjc33Lhh0fBgT/H3oZq9WuvRR5gPC70xpDiQU=
135+
golang.org/x/net v0.48.0/go.mod h1:+ndRgGjkh8FGtu1w1FGbEC31if4VrNVMuKTgcAAnQRY=
136+
golang.org/x/sync v0.19.0 h1:vV+1eWNmZ5geRlYjzm2adRgW2/mcpevXNg50YZtPCE4=
137+
golang.org/x/sync v0.19.0/go.mod h1:9KTHXmSnoGruLpwFjVSX0lNNA75CykiMECbovNTZqGI=
138138
golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
139139
golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
140140
golang.org/x/sys v0.12.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
141141
golang.org/x/sys v0.39.0 h1:CvCKL8MeisomCi6qNZ+wbb0DN9E5AATixKsvNtMoMFk=
142142
golang.org/x/sys v0.39.0/go.mod h1:OgkHotnGiDImocRcuBABYBEXf8A9a87e/uXjp9XT3ks=
143-
golang.org/x/telemetry v0.0.0-20251008203120-078029d740a8 h1:LvzTn0GQhWuvKH/kVRS3R3bVAsdQWI7hvfLHGgh9+lU=
144-
golang.org/x/telemetry v0.0.0-20251008203120-078029d740a8/go.mod h1:Pi4ztBfryZoJEkyFTI5/Ocsu2jXyDr6iSdgJiYE/uwE=
145-
golang.org/x/text v0.31.0 h1:aC8ghyu4JhP8VojJ2lEHBnochRno1sgL6nEi9WGFGMM=
146-
golang.org/x/text v0.31.0/go.mod h1:tKRAlv61yKIjGGHX/4tP1LTbc13YSec1pxVEWXzfoeM=
147-
golang.org/x/tools v0.38.0 h1:Hx2Xv8hISq8Lm16jvBZ2VQf+RLmbd7wVUsALibYI/IQ=
148-
golang.org/x/tools v0.38.0/go.mod h1:yEsQ/d/YK8cjh0L6rZlY8tgtlKiBNTL14pGDJPJpYQs=
143+
golang.org/x/telemetry v0.0.0-20251203150158-8fff8a5912fc h1:bH6xUXay0AIFMElXG2rQ4uiE+7ncwtiOdPfYK1NK2XA=
144+
golang.org/x/telemetry v0.0.0-20251203150158-8fff8a5912fc/go.mod h1:hKdjCMrbv9skySur+Nek8Hd0uJ0GuxJIoIX2payrIdQ=
145+
golang.org/x/text v0.32.0 h1:ZD01bjUt1FQ9WJ0ClOL5vxgxOI/sVCNgX1YtKwcY0mU=
146+
golang.org/x/text v0.32.0/go.mod h1:o/rUWzghvpD5TXrTIBuJU77MTaN0ljMWE47kxGJQ7jY=
147+
golang.org/x/tools v0.40.0 h1:yLkxfA+Qnul4cs9QA3KnlFu0lVmd8JJfoq+E41uSutA=
148+
golang.org/x/tools v0.40.0/go.mod h1:Ik/tzLRlbscWpqqMRjyWYDisX8bG13FrdXp3o4Sr9lc=
149149
golang.org/x/xerrors v0.0.0-20240903120638-7835f813f4da h1:noIWHXmPHxILtqtCOPIhSt0ABwskkZKjD3bXGnZGpNY=
150150
golang.org/x/xerrors v0.0.0-20240903120638-7835f813f4da/go.mod h1:NDW/Ps6MPRej6fsCIbMTohpP40sJ/P/vI1MoTEGwX90=
151151
gonum.org/v1/gonum v0.16.0 h1:5+ul4Swaf3ESvrOnidPp4GZbzf0mxVQpDCYUQE7OJfk=
@@ -154,8 +154,8 @@ google.golang.org/genproto/googleapis/rpc v0.0.0-20251202230838-ff82c1b0f217 h1:
154154
google.golang.org/genproto/googleapis/rpc v0.0.0-20251202230838-ff82c1b0f217/go.mod h1:7i2o+ce6H/6BluujYR+kqX3GKH+dChPTQU19wjRPiGk=
155155
google.golang.org/grpc v1.77.0 h1:wVVY6/8cGA6vvffn+wWK5ToddbgdU3d8MNENr4evgXM=
156156
google.golang.org/grpc v1.77.0/go.mod h1:z0BY1iVj0q8E1uSQCjL9cppRj+gnZjzDnzV0dHhrNig=
157-
google.golang.org/protobuf v1.36.10 h1:AYd7cD/uASjIL6Q9LiTjz8JLcrh/88q5UObnmY3aOOE=
158-
google.golang.org/protobuf v1.36.10/go.mod h1:HTf+CrKn2C3g5S8VImy6tdcUvCska2kB7j23XfzDpco=
157+
google.golang.org/protobuf v1.36.11 h1:fV6ZwhNocDyBLK0dj+fg8ektcVegBBuEolpbTQyBNVE=
158+
google.golang.org/protobuf v1.36.11/go.mod h1:HTf+CrKn2C3g5S8VImy6tdcUvCska2kB7j23XfzDpco=
159159
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
160160
gopkg.in/check.v1 v1.0.0-20200902074654-038fdea0a05b h1:QRR6H1YWRnHb4Y/HeNFCTJLFVxaq6wH4YuVdsUOr75U=
161161
gopkg.in/check.v1 v1.0.0-20200902074654-038fdea0a05b/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=

‎json/read.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ import (
1212

1313
const maxJSONSize = 1024 * 1024 * 20
1414

15-
func (*Client) Read(r types.ReaderAtSeeker, table *schema.Table, res chan<- arrow.Record) error {
15+
func (*Client) Read(r types.ReaderAtSeeker, table *schema.Table, res chan<- arrow.RecordBatch) error {
1616
scanner := bufio.NewScanner(r)
1717
scanner.Buffer(make([]byte, maxJSONSize), maxJSONSize)
1818
rb := array.NewRecordBuilder(memory.DefaultAllocator, table.ToArrowSchema())
@@ -22,7 +22,7 @@ func (*Client) Read(r types.ReaderAtSeeker, table *schema.Table, res chan<- arro
2222
if err != nil {
2323
return err
2424
}
25-
r := rb.NewRecord()
25+
r := rb.NewRecordBatch()
2626
res <- r
2727
}
2828

0 commit comments

Comments
 (0)