From 1b240e6789e638482c853b46dc6107577b089b4e Mon Sep 17 00:00:00 2001 From: Lukas Sembera Date: Mon, 1 Jul 2024 09:40:41 +0000 Subject: [PATCH] parquetFooterRowsPerBlock --- .../net/snowflake/ingest/streaming/internal/ParquetFlusher.java | 2 +- src/main/java/org/apache/parquet/hadoop/BdecParquetWriter.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/net/snowflake/ingest/streaming/internal/ParquetFlusher.java b/src/main/java/net/snowflake/ingest/streaming/internal/ParquetFlusher.java index 771e5f71a..1893be9b1 100644 --- a/src/main/java/net/snowflake/ingest/streaming/internal/ParquetFlusher.java +++ b/src/main/java/net/snowflake/ingest/streaming/internal/ParquetFlusher.java @@ -248,7 +248,7 @@ private void verifyRowCounts( long javaSerializationTotalRowCount) { long parquetTotalRowsWritten = writer.getRowsWritten(); - List parquetFooterRowsPerBlock = writer.getRowCountFromFooter(); + List parquetFooterRowsPerBlock = writer.getRowCountsFromFooter(); long parquetTotalRowsInFooter = 0; for (long perBlockCount : parquetFooterRowsPerBlock) parquetTotalRowsInFooter += perBlockCount; diff --git a/src/main/java/org/apache/parquet/hadoop/BdecParquetWriter.java b/src/main/java/org/apache/parquet/hadoop/BdecParquetWriter.java index 720e9f38e..58e7df4f3 100644 --- a/src/main/java/org/apache/parquet/hadoop/BdecParquetWriter.java +++ b/src/main/java/org/apache/parquet/hadoop/BdecParquetWriter.java @@ -104,7 +104,7 @@ public BdecParquetWriter( } /** @return List of row counts per block stored in the parquet footer */ - public List getRowCountFromFooter() { + public List getRowCountsFromFooter() { final List blockRowCounts = new ArrayList<>(); for (BlockMetaData metadata : writer.getFooter().getBlocks()) { blockRowCounts.add(metadata.getRowCount());