parquet-column/src/main/java/org/apache/parquet/column/impl/ColumnWriterBase.java
void writePage() {
    if (valueCount == 0) {
      throw new ParquetEncodingException("writing empty page");
    }
    this.rowsWrittenSoFar += pageRowCount;
    if (DEBUG)
      LOG.debug("write page");
    try {
      writePage(pageRowCount, valueCount, statistics, repetitionLevelColumn, definitionLevelColumn, dataColumn);
    } catch (IOException e) {
      throw new ParquetEncodingException("could not write page for " + path, e);
    }
    repetitionLevelColumn.reset();
    definitionLevelColumn.reset();
    dataColumn.reset();
    valueCount = 0;
    resetStatistics();
    pageRowCount = 0;
  }
void writePage() {
    if (valueCount == 0) {
      throw new ParquetEncodingException("writing empty page");
    }
    this.rowsWrittenSoFar += pageRowCount;
    if (DEBUG)
      LOG.debug("write page");
    try {
      writePage(pageRowCount, valueCount, statistics, repetitionLevelColumn, definitionLevelColumn, dataColumn);
    } catch (IOException e) {
      throw new ParquetEncodingException("could not write page for " + path, e);
    }
    repetitionLevelColumn.reset();
    definitionLevelColumn.reset();
    dataColumn.reset();
    valueCount = 0;
    resetStatistics();
    pageRowCount = 0;
  }
void writePage ( ) { if ( valueCount == 0 ) { throw new ParquetEncodingException ( "writing empty page" ) ; } this . rowsWrittenSoFar += pageRowCount ; if ( DEBUG ) LOG . debug ( "write page" ) ; try { writePage ( pageRowCount , valueCount , statistics , repetitionLevelColumn , definitionLevelColumn , dataColumn ) ; } catch ( IOException e ) { throw new ParquetEncodingException ( "could not write page for " + path , e ) ; } repetitionLevelColumn . reset ( ) ; definitionLevelColumn . reset ( ) ; dataColumn . reset ( ) ; valueCount = 0 ; resetStatistics ( ) ; pageRowCount = 0 ; }
Writes the current data to a new page in the page store
Writes the current data to a new page in the page store