public abstract class BaseTaskWriter<T> extends java.lang.Object implements TaskWriter<T>
Modifier and Type | Class and Description |
---|---|
protected class |
BaseTaskWriter.RollingFileWriter |
Modifier | Constructor and Description |
---|---|
protected |
BaseTaskWriter(PartitionSpec spec,
FileFormat format,
FileAppenderFactory<T> appenderFactory,
OutputFileFactory fileFactory,
FileIO io,
long targetFileSize) |
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.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
write
protected BaseTaskWriter(PartitionSpec spec, FileFormat format, FileAppenderFactory<T> appenderFactory, OutputFileFactory fileFactory, FileIO io, long targetFileSize)
public void abort() throws java.io.IOException
TaskWriter
abort
in interface TaskWriter<T>
java.io.IOException
- if any IO error happen.public DataFile[] complete() throws java.io.IOException
TaskWriter
complete
in interface TaskWriter<T>
java.io.IOException