Bump github.com/parquet-go/parquet-go (#4778)

Bumps [github.com/parquet-go/parquet-go](https://github.com/parquet-go/parquet-go) from 0.24.1-0.20250221124813-750802ae6cc3 to 0.25.0.
- [Release notes](https://github.com/parquet-go/parquet-go/releases)
- [Changelog](https://github.com/parquet-go/parquet-go/blob/main/CHANGELOG.md)
- [Commits](https://github.com/parquet-go/parquet-go/commits/v0.25.0)

---
updated-dependencies:
- dependency-name: github.com/parquet-go/parquet-go
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
This commit is contained in:
dependabot[bot]
2025-03-10 14:18:32 +10:00
committed by GitHub
parent 5454085875
commit 9bc9043e66
5 changed files with 24 additions and 10 deletions

2
go.mod
View File

@ -95,7 +95,7 @@ require (
github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kafkareceiver v0.119.0
github.com/open-telemetry/opentelemetry-collector-contrib/receiver/opencensusreceiver v0.119.0
github.com/open-telemetry/opentelemetry-collector-contrib/receiver/zipkinreceiver v0.119.0
github.com/parquet-go/parquet-go v0.24.1-0.20250221124813-750802ae6cc3
github.com/parquet-go/parquet-go v0.25.0
github.com/stoewer/parquet-cli v0.0.9
github.com/twmb/franz-go v1.18.1
github.com/twmb/franz-go/pkg/kadm v1.15.0

4
go.sum
View File

@ -739,8 +739,8 @@ github.com/openzipkin/zipkin-go v0.4.3 h1:9EGwpqkgnwdEIJ+Od7QVSEIH+ocmm5nPat0G7s
github.com/openzipkin/zipkin-go v0.4.3/go.mod h1:M9wCJZFWCo2RiY+o1eBCEMe0Dp2S5LDHcMZmk3RmK7c=
github.com/ovh/go-ovh v1.6.0 h1:ixLOwxQdzYDx296sXcgS35TOPEahJkpjMGtzPadCjQI=
github.com/ovh/go-ovh v1.6.0/go.mod h1:cTVDnl94z4tl8pP1uZ/8jlVxntjSIf09bNcQ5TJSC7c=
github.com/parquet-go/parquet-go v0.24.1-0.20250221124813-750802ae6cc3 h1:t2/tVHCiQe59lwktENtQ3XFEdQZppA+/MFFSvLUHFso=
github.com/parquet-go/parquet-go v0.24.1-0.20250221124813-750802ae6cc3/go.mod h1:OqBBRGBl7+llplCvDMql8dEKaDqjaFA/VAPw+OJiNiw=
github.com/parquet-go/parquet-go v0.25.0 h1:GwKy11MuF+al/lV6nUsFw8w8HCiPOSAx1/y8yFxjH5c=
github.com/parquet-go/parquet-go v0.25.0/go.mod h1:OqBBRGBl7+llplCvDMql8dEKaDqjaFA/VAPw+OJiNiw=
github.com/pascaldekloe/goe v0.0.0-20180627143212-57f6aae5913c/go.mod h1:lzWF7FIEvWOWxwDKqyGYQf6ZUaNfKdP144TG7ZOy1lc=
github.com/pascaldekloe/goe v0.1.0 h1:cBOtyMzM9HTpWjXfbbunk26uA6nG3a8n06Wieeh0MwY=
github.com/pascaldekloe/goe v0.1.0/go.mod h1:lzWF7FIEvWOWxwDKqyGYQf6ZUaNfKdP144TG7ZOy1lc=

View File

@ -298,10 +298,10 @@ func (buf *Buffer) NumRows() int64 { return int64(buf.Len()) }
// ColumnChunks returns the buffer columns.
func (buf *Buffer) ColumnChunks() []ColumnChunk { return buf.chunks }
// ColumnBuffer returns the buffer columns.
// ColumnBuffers returns the buffer columns.
//
// This method is similar to ColumnChunks, but returns a list of ColumnBuffer
// instead of a ColumnChunk values (the latter being read-only); calling
// instead of a list of ColumnChunk (the latter being read-only); calling
// ColumnBuffers or ColumnChunks with the same index returns the same underlying
// objects, but with different types, which removes the need for making a type
// assertion if the program needed to write directly to the column buffers.

View File

@ -221,6 +221,10 @@ func (w *GenericWriter[T]) Schema() *Schema {
return w.base.Schema()
}
func (w *GenericWriter[T]) ColumnWriters() []ValueWriter {
return w.base.ColumnWriters()
}
func (w *GenericWriter[T]) writeRows(rows []T) (int, error) {
if cap(w.base.rowbuf) < len(rows) {
w.base.rowbuf = make([]Row, len(rows))
@ -484,6 +488,11 @@ func (w *Writer) SetKeyValueMetadata(key, value string) {
})
}
// ColumnWriters returns writers for each column. This allows applications to
// write values directly to each column instead of having to first assemble
// values into rows to use WriteRows.
func (w *Writer) ColumnWriters() []ValueWriter { return w.writer.valueWriters }
type writerFileView struct {
writer *writer
schema *Schema
@ -563,10 +572,11 @@ type writer struct {
createdBy string
metadata []format.KeyValue
columns []*writerColumn
columnChunk []format.ColumnChunk
columnIndex []format.ColumnIndex
offsetIndex []format.OffsetIndex
columns []*writerColumn
valueWriters []ValueWriter
columnChunk []format.ColumnChunk
columnIndex []format.ColumnIndex
offsetIndex []format.OffsetIndex
columnOrders []format.ColumnOrder
schemaElements []format.SchemaElement
@ -754,6 +764,10 @@ func newWriter(output io.Writer, config *WriterConfig) *writer {
for i, c := range w.columns {
w.columnOrders[i] = *c.columnType.ColumnOrder()
}
w.valueWriters = make([]ValueWriter, len(w.columns))
for i, c := range w.columns {
w.valueWriters[i] = c
}
return w
}

2
vendor/modules.txt vendored
View File

@ -1063,7 +1063,7 @@ github.com/opentracing/opentracing-go/log
github.com/openzipkin/zipkin-go/model
github.com/openzipkin/zipkin-go/proto/zipkin_proto3
github.com/openzipkin/zipkin-go/reporter
# github.com/parquet-go/parquet-go v0.24.1-0.20250221124813-750802ae6cc3
# github.com/parquet-go/parquet-go v0.25.0
## explicit; go 1.22
github.com/parquet-go/parquet-go
github.com/parquet-go/parquet-go/bloom