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());