diff --git a/StandardPlugin/ADAPTParquet.cs b/StandardPlugin/ADAPTParquet.cs index 0029224..2f28c4e 100644 --- a/StandardPlugin/ADAPTParquet.cs +++ b/StandardPlugin/ADAPTParquet.cs @@ -46,7 +46,7 @@ public void Write(string outputFile) using (var fs = File.Create(outputFile)) { - using (var writer = new ParquetFileWriter(outputFile, dataFields.ToArray(), keyValueMetadata: geometadata)) + using (var writer = new ParquetFileWriter(fs, dataFields.ToArray(), keyValueMetadata: geometadata)) { int startIndex = 0; int remainingRowGroups = ColumnData.Geometries.Count / RowGroupSize; @@ -72,7 +72,7 @@ public void Write(string outputFile) } var geometries = ColumnData.Geometries.Skip(startIndex).Take(RowGroupSize); var geometryWriter = rg.NextColumn().LogicalWriter(); - geometryWriter.WriteBatch(ColumnData.Geometries.Skip(startIndex).Take(RowGroupSize).ToArray()); + geometryWriter.WriteBatch(geometries.ToArray()); } startIndex += RowGroupSize; remainingRowGroups--;