parquetFooterRowsPerBlock

snowflakedb · Jul 1, 2024 · d39ca44 · d39ca44
1 parent d84cb68
commit d39ca44
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 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
@@ -248,7 +248,7 @@ private void verifyRowCounts(
       long javaSerializationTotalRowCount) {
     long parquetTotalRowsWritten = writer.getRowsWritten();
 
-    List<Long> parquetFooterRowsPerBlock = writer.getRowCountFromFooter();
+    List<Long> 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
@@ -104,7 +104,7 @@ public BdecParquetWriter(
   }
 
   /** @return List of row counts per block stored in the parquet footer */
-  public List<Long> getRowCountFromFooter() {
+  public List<Long> getRowCountsFromFooter() {
     final List<Long> blockRowCounts = new ArrayList<>();
     for (BlockMetaData metadata : writer.getFooter().getBlocks()) {
       blockRowCounts.add(metadata.getRowCount());