Package org.apache.iceberg.io

Class UnpartitionedWriter<T>

java.lang.Object

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

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

All Implemented Interfaces:

Closeable, AutoCloseable, TaskWriter<T>

public class UnpartitionedWriter<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

Constructor	Description
UnpartitionedWriter(PartitionSpec spec, FileFormat format, FileAppenderFactory<T> appenderFactory, OutputFileFactory fileFactory, FileIO io, long targetFileSize)

Method Summary

Modifier and Type	Method	Description
void	close()
void	write(T record)	Write the row into the data files.

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

abort, complete, 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

UnpartitionedWriter

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

Method Details

write

public void write(T record)
           throws IOException

Description copied from interface: TaskWriter

Write the row into the data files.

Throws:

IOException

close

public void close()
           throws IOException

Throws:

IOException