Package org.apache.iceberg.parquet

Class ParquetValueWriters.RepeatedWriter<L,E>

java.lang.Object
org.apache.iceberg.parquet.ParquetValueWriters.RepeatedWriter<L,E>
All Implemented Interfaces:
ParquetValueWriter<L>
Enclosing class:
ParquetValueWriters
public abstract static class ParquetValueWriters.RepeatedWriter<L,E> extends Object implements ParquetValueWriter<L>

  • Constructor Details

    • RepeatedWriter

      protected RepeatedWriter(int definitionLevel, int repetitionLevel, ParquetValueWriter<E> writer)

  • Method Details

    • write

      public void write(int parentRepetition, L value)
      Specified by:
      write in interface ParquetValueWriter<L>

    • columns

      public List<TripleWriter<?>> columns()
      Specified by:
      columns in interface ParquetValueWriter<L>

    • setColumnStore

      public void setColumnStore(org.apache.parquet.column.ColumnWriteStore columnStore)
      Specified by:
      setColumnStore in interface ParquetValueWriter<L>

    • elements

      protected abstract Iterator<E> elements(L value)
      Returns an iterator over the elements of a value.

      The iterator is fully consumed before write returns and is never retained, so implementations may return a reused iterator instance.

      Parameters:
      value - a value to write
      Returns:
      an iterator over the value's elements

    • metrics

      public Stream<FieldMetrics<?>> metrics()
      Description copied from interface: ParquetValueWriter
      Returns a stream of FieldMetrics that this ParquetValueWriter keeps track of.
      Specified by:
      metrics in interface ParquetValueWriter<L>