ClusterCockpit/cc-backend
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-backend synced 2026-02-20 17:57:30 +01:00
Code Issues Packages Releases Activity

Switch to zstd compression for parquet writers

Browse Source
This commit is contained in:
Jan Eitzinger
2026-02-18 07:55:28 +01:00
parent 589149790f
commit 757be60b22
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/archive/parquet/nodestate_writer.go
View File

@@ -83,7 +83,7 @@ func writeNodeStateParquetBytes(rows []ParquetNodeStateRow) ([]byte, error) {
var buf bytes.Buffer var buf bytes.Buffer
writer := pq.NewGenericWriter[ParquetNodeStateRow](&buf, writer := pq.NewGenericWriter[ParquetNodeStateRow](&buf,
pq.Compression(&pq.Snappy), pq.Compression(&pq.Zstd),
) )
if _, err := writer.Write(rows); err != nil { if _, err := writer.Write(rows); err != nil {

2
pkg/archive/parquet/writer.go
View File

@@ -87,7 +87,7 @@ func writeParquetBytes(rows []ParquetJobRow) ([]byte, error) {
var buf bytes.Buffer var buf bytes.Buffer
writer := pq.NewGenericWriter[ParquetJobRow](&buf, writer := pq.NewGenericWriter[ParquetJobRow](&buf,
pq.Compression(&pq.Snappy), pq.Compression(&pq.Zstd),
) )
if _, err := writer.Write(rows); err != nil { if _, err := writer.Write(rows); err != nil {