Package org.apache.iceberg.io

Class PartitionedFanoutWriter<T>

java.lang.Object

org.apache.iceberg.io.BaseTaskWriter<T>

org.apache.iceberg.io.PartitionedFanoutWriter<T>

All Implemented Interfaces:

Closeable, AutoCloseable, TaskWriter<T>

public abstract class PartitionedFanoutWriter<T>
extends BaseTaskWriter<T>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.iceberg.io.BaseTaskWriter

BaseTaskWriter.BaseEqualityDeltaWriter, BaseTaskWriter.RollingEqDeleteWriter, BaseTaskWriter.RollingFileWriter

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	PartitionedFanoutWriter(PartitionSpec spec, FileFormat format, FileAppenderFactory<T> appenderFactory, OutputFileFactory fileFactory, FileIO io, long targetFileSize)
protected	PartitionedFanoutWriter(PartitionSpec spec, FileFormat format, FileWriterFactory<T> fileWriterFactory, OutputFileFactory fileFactory, FileIO io, long targetFileSize)

Method Summary

Modifier and Type	Method	Description
void	close()
protected abstract PartitionKey	partition(T row)	Create a PartitionKey from the values in row.
void	write(T row)	Write the row into the data files.

Methods inherited from class org.apache.iceberg.io.BaseTaskWriter

abort, complete, dvFileWriter, setFailure, spec

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.iceberg.io.TaskWriter

dataFiles

Constructor Details

PartitionedFanoutWriter

protected PartitionedFanoutWriter(PartitionSpec spec,
 FileFormat format,
 FileAppenderFactory<T> appenderFactory,
 OutputFileFactory fileFactory,
 FileIO io,
 long targetFileSize)

PartitionedFanoutWriter

protected PartitionedFanoutWriter(PartitionSpec spec,
 FileFormat format,
 FileWriterFactory<T> fileWriterFactory,
 OutputFileFactory fileFactory,
 FileIO io,
 long targetFileSize)

Method Details

partition

protected abstract PartitionKey partition(T row)

Create a PartitionKey from the values in row.

Any PartitionKey returned by this method can be reused by the implementation.

Parameters:

row - a data row

write

public void write(T row)
           throws IOException

Description copied from interface: TaskWriter

Write the row into the data files.

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class BaseTaskWriter<T>

Throws:

IOException