Package org.apache.iceberg.parquet
Class ParquetValueWriters.StructWriter<S>
- java.lang.Object
-
- org.apache.iceberg.parquet.ParquetValueWriters.StructWriter<S>
-
- All Implemented Interfaces:
ParquetValueWriter<S>
- Direct Known Subclasses:
ParquetValueWriters.PositionDeleteStructWriter
- Enclosing class:
- ParquetValueWriters
public abstract static class ParquetValueWriters.StructWriter<S> extends java.lang.Object implements ParquetValueWriter<S>
-
-
Constructor Summary
Constructors Modifier Constructor Description protectedStructWriter(java.util.List<ParquetValueWriter<?>> writers)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description java.util.List<TripleWriter<?>>columns()protected abstract java.lang.Objectget(S struct, int index)java.util.stream.Stream<FieldMetrics<?>>metrics()Returns a stream ofFieldMetricsthat this ParquetValueWriter keeps track of.voidsetColumnStore(org.apache.parquet.column.ColumnWriteStore columnStore)voidwrite(int repetitionLevel, S value)
-
-
-
Constructor Detail
-
StructWriter
protected StructWriter(java.util.List<ParquetValueWriter<?>> writers)
-
-
Method Detail
-
write
public void write(int repetitionLevel, S value)- Specified by:
writein interfaceParquetValueWriter<S>
-
columns
public java.util.List<TripleWriter<?>> columns()
- Specified by:
columnsin interfaceParquetValueWriter<S>
-
setColumnStore
public void setColumnStore(org.apache.parquet.column.ColumnWriteStore columnStore)
- Specified by:
setColumnStorein interfaceParquetValueWriter<S>
-
get
protected abstract java.lang.Object get(S struct, int index)
-
metrics
public java.util.stream.Stream<FieldMetrics<?>> metrics()
Description copied from interface:ParquetValueWriterReturns a stream ofFieldMetricsthat this ParquetValueWriter keeps track of.- Specified by:
metricsin interfaceParquetValueWriter<S>
-
-