use latest parquet version 2.6

Ignalina · Sep 23, 2022 · 6cfc8a7 · 6cfc8a7
1 parent c860115
commit 6cfc8a7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/impl/TableToFile.go b/impl/TableToFile.go
@@ -31,7 +31,7 @@ import (
 func SaveToParquet(schema *arrow.Schema, record []arrow.Record, writer io.Writer, i int64) error {
 	var err error
 
-	props := parquet.NewWriterProperties(parquet.WithDictionaryDefault(false), parquet.WithCompression(compress.Codecs.Snappy))
+	props := parquet.NewWriterProperties(parquet.WithVersion(parquet.V2_LATEST),parquet.WithDictionaryDefault(false), parquet.WithCompression(compress.Codecs.Snappy))
 	arrProps := pqarrow.DefaultWriterProps()
 	tbl := array.NewTableFromRecords(schema, record)