SparkParquetWriters.VariantWriter

java.lang.Object

org.apache.iceberg.spark.data.SparkParquetWriters.VariantWriter

All Implemented Interfaces:: ParquetValueWriter<org.apache.spark.unsafe.types.VariantVal>

Enclosing class:: SparkParquetWriters

public static class SparkParquetWriters.VariantWriter extends Object implements ParquetValueWriter<org.apache.spark.unsafe.types.VariantVal>

Variant writer converts from VariantVal to Variant

Method Summary

Modifier and Type

Method

Description

List<TripleWriter<?>>

columns()

Stream<FieldMetrics<?>>

metrics()

Returns a stream of FieldMetrics that this ParquetValueWriter keeps track of.

void

setColumnStore(org.apache.parquet.column.ColumnWriteStore columnStore)

void

write(int repetitionLevel, org.apache.spark.unsafe.types.VariantVal variantVal)

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details
- write
  
  public void write(int repetitionLevel, org.apache.spark.unsafe.types.VariantVal variantVal)
  
  Specified by:
  
  write in interface ParquetValueWriter<org.apache.spark.unsafe.types.VariantVal>
- columns
  
  public List<TripleWriter<?>> columns()
  
  Specified by:
  
  columns in interface ParquetValueWriter<org.apache.spark.unsafe.types.VariantVal>
- setColumnStore
  
  public void setColumnStore(org.apache.parquet.column.ColumnWriteStore columnStore)
  
  Specified by:
  
  setColumnStore in interface ParquetValueWriter<org.apache.spark.unsafe.types.VariantVal>
- 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<org.apache.spark.unsafe.types.VariantVal>