org.apache.iceberg.io

Class BaseTaskWriter<T>

java.lang.Object

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

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, TaskWriter<T>

Direct Known Subclasses:

PartitionedWriter, UnpartitionedWriter

public abstract class BaseTaskWriter<T>
extends java.lang.Object
implements TaskWriter<T>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	BaseTaskWriter.RollingFileWriter

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	abort() Close the writer and delete the completed files if possible when aborting.
DataFile[]	complete() Close the writer and get the completed data files.

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

write

Methods inherited from interface java.io.Closeable

close

Constructor Detail

BaseTaskWriter

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

Method Detail

abort

public void abort()
           throws java.io.IOException

Description copied from interface: TaskWriter

Close the writer and delete the completed files if possible when aborting.

Specified by:

abort in interface TaskWriter<T>

Throws:

java.io.IOException - if any IO error happen.

complete

public DataFile[] complete()
                    throws java.io.IOException

Description copied from interface: TaskWriter

Close the writer and get the completed data files.

Specified by:

complete in interface TaskWriter<T>

Returns:

the completed data files of this task writer.

Throws:

java.io.IOException