parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ParquetFileWriter.java
public void endColumn() throws IOException {
    state = state.endColumn();
    LOG.debug("{}: end column", out.getPos());
    if (columnIndexBuilder.getMinMaxSize() > columnIndexBuilder.getPageCount() * MAX_STATS_SIZE) {
      currentColumnIndexes.add(null);
    } else {
      currentColumnIndexes.add(columnIndexBuilder.build());
    }
    currentOffsetIndexes.add(offsetIndexBuilder.build(firstPageOffset));
    currentBlock.addColumn(ColumnChunkMetaData.get(
        currentChunkPath,
        currentChunkType,
        currentChunkCodec,
        encodingStatsBuilder.build(),
        currentEncodings,
        currentStatistics,
        currentChunkFirstDataPage,
        currentChunkDictionaryPageOffset,
        currentChunkValueCount,
        compressedLength,
        uncompressedLength));
    this.currentBlock.setTotalByteSize(currentBlock.getTotalByteSize() + uncompressedLength);
    this.uncompressedLength = 0;
    this.compressedLength = 0;
    columnIndexBuilder = null;
    offsetIndexBuilder = null;
  }
public void endColumn() throws IOException {
    state = state.endColumn();
    LOG.debug("{}: end column", out.getPos());
    if (columnIndexBuilder.getMinMaxSize() > columnIndexBuilder.getPageCount() * MAX_STATS_SIZE) {
      currentColumnIndexes.add(null);
    } else {
      currentColumnIndexes.add(columnIndexBuilder.build());
    }
    currentOffsetIndexes.add(offsetIndexBuilder.build(firstPageOffset));
    currentBlock.addColumn(ColumnChunkMetaData.get(
        currentChunkPath,
        currentChunkType,
        currentChunkCodec,
        encodingStatsBuilder.build(),
        currentEncodings,
        currentStatistics,
        currentChunkFirstDataPage,
        currentChunkDictionaryPageOffset,
        currentChunkValueCount,
        compressedLength,
        uncompressedLength));
    this.currentBlock.setTotalByteSize(currentBlock.getTotalByteSize() + uncompressedLength);
    this.uncompressedLength = 0;
    this.compressedLength = 0;
    columnIndexBuilder = null;
    offsetIndexBuilder = null;
  }
public void endColumn ( ) throws IOException { state = state . endColumn ( ) ; LOG . debug ( "{}: end column" , out . getPos ( ) ) ; if ( columnIndexBuilder . getMinMaxSize ( ) > columnIndexBuilder . getPageCount ( ) * MAX_STATS_SIZE ) { currentColumnIndexes . add ( null ) ; } else { currentColumnIndexes . add ( columnIndexBuilder . build ( ) ) ; } currentOffsetIndexes . add ( offsetIndexBuilder . build ( firstPageOffset ) ) ; currentBlock . addColumn ( ColumnChunkMetaData . get ( currentChunkPath , currentChunkType , currentChunkCodec , encodingStatsBuilder . build ( ) , currentEncodings , currentStatistics , currentChunkFirstDataPage , currentChunkDictionaryPageOffset , currentChunkValueCount , compressedLength , uncompressedLength ) ) ; this . currentBlock . setTotalByteSize ( currentBlock . getTotalByteSize ( ) + uncompressedLength ) ; this . uncompressedLength = 0 ; this . compressedLength = 0 ; columnIndexBuilder = null ; offsetIndexBuilder = null ; }
end a column (once all rep, def and data have been written)
@throws IOException if there is an error while writing
end a column ( once all rep def and data have been written )