org.apache.iceberg.io

Class BaseTaskWriter.RollingFileWriter

java.lang.Object

org.apache.iceberg.io.BaseTaskWriter.RollingFileWriter

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

Enclosing class:

BaseTaskWriter<T>

protected class BaseTaskWriter.RollingFileWriter
extends java.lang.Object
implements java.io.Closeable

Constructor Summary

Constructors

Constructor and Description
RollingFileWriter(PartitionKey partitionKey)

Method Summary

Modifier and Type	Method and Description
void	add(T record)
void	close()

Methods inherited from class java.lang.Object

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

Constructor Detail

RollingFileWriter

public RollingFileWriter(PartitionKey partitionKey)

Method Detail

add

public void add(T record)
         throws java.io.IOException

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException