org.apache.iceberg.io

Interface TaskWriter<T>

Type Parameters:

T - to indicate the record data type.

All Superinterfaces:

java.lang.AutoCloseable, java.io.Closeable

All Known Implementing Classes:

BaseTaskWriter, PartitionedWriter, SparkPartitionedWriter, UnpartitionedWriter

public interface TaskWriter<T>
extends java.io.Closeable

The writer interface could accept records and provide the generated data files.

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.
void	write(T row) Write the row into the data files.

Methods inherited from interface java.io.Closeable

close

Method Detail

write

void write(T row)
    throws java.io.IOException

Write the row into the data files.

Throws:

java.io.IOException

abort

void abort()
    throws java.io.IOException

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

Throws:

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

complete

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

Close the writer and get the completed data files.

Returns:

the completed data files of this task writer.

Throws:

java.io.IOException