public class ParquetWriteAdapter<D> extends java.lang.Object implements FileAppender<D>
Constructor and Description |
---|
ParquetWriteAdapter(org.apache.parquet.hadoop.ParquetWriter<D> writer,
MetricsConfig metricsConfig) |
Modifier and Type | Method and Description |
---|---|
void |
add(D datum) |
void |
close() |
long |
length() |
Metrics |
metrics() |
java.util.List<java.lang.Long> |
splitOffsets() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addAll, addAll
public ParquetWriteAdapter(org.apache.parquet.hadoop.ParquetWriter<D> writer, MetricsConfig metricsConfig)
public void add(D datum)
add
in interface FileAppender<D>
public Metrics metrics()
metrics
in interface FileAppender<D>
Metrics
for this file. Only valid after the file is closed.public long length()
length
in interface FileAppender<D>
public java.util.List<java.lang.Long> splitOffsets()
splitOffsets
in interface FileAppender<D>
public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
java.io.IOException