Package org.apache.iceberg.io

Class RollingEqualityDeleteWriter<T>

java.lang.Object

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

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, FileWriter<T,DeleteWriteResult>

public class RollingEqualityDeleteWriter<T>
extends java.lang.Object

A rolling equality delete writer that splits incoming deletes into multiple files within one spec/partition based on the target file size.

Constructor Summary

Constructors

Constructor	Description
RollingEqualityDeleteWriter(FileWriterFactory<T> writerFactory, OutputFileFactory fileFactory, FileIO io, long targetFileSizeInBytes, PartitionSpec spec, StructLike partition)

Method Summary

Modifier and Type	Method	Description
protected void	addResult(DeleteWriteResult result)
protected DeleteWriteResult	aggregatedResult()
void	close()
java.lang.CharSequence	currentFilePath()
long	currentFileRows()
long	length()	Returns the number of bytes that were currently written by this writer.
protected EqualityDeleteWriter<T>	newWriter(EncryptedOutputFile file)
protected void	openCurrentWriter()
protected StructLike	partition()
R	result()	Returns a result that contains information about written DataFiles or DeleteFiles.
protected PartitionSpec	spec()
void	write(T row)	Writes a row to a predefined spec/partition.

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.FileWriter

write

Constructor Detail

RollingEqualityDeleteWriter

public RollingEqualityDeleteWriter(FileWriterFactory<T> writerFactory,
                                   OutputFileFactory fileFactory,
                                   FileIO io,
                                   long targetFileSizeInBytes,
                                   PartitionSpec spec,
                                   StructLike partition)

Method Detail

newWriter

protected EqualityDeleteWriter<T> newWriter(EncryptedOutputFile file)

addResult

protected void addResult(DeleteWriteResult result)

aggregatedResult

protected DeleteWriteResult aggregatedResult()

spec

protected PartitionSpec spec()

partition

protected StructLike partition()

currentFilePath

public java.lang.CharSequence currentFilePath()

currentFileRows

public long currentFileRows()

length

public long length()

Description copied from interface: FileWriter

Returns the number of bytes that were currently written by this writer.

Specified by:

length in interface FileWriter<T,W extends FileWriter<T,R>>

Returns:

the number of written bytes

write

public void write(T row)

Description copied from interface: FileWriter

Writes a row to a predefined spec/partition.

Specified by:

write in interface FileWriter<T,W extends FileWriter<T,R>>

Parameters:

row - a data or delete record

openCurrentWriter

protected void openCurrentWriter()

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Throws:

java.io.IOException

result

public final R result()

Description copied from interface: FileWriter

Returns a result that contains information about written DataFiles or DeleteFiles. The result is valid only after the writer is closed.

Specified by:

result in interface FileWriter<T,W extends FileWriter<T,R>>

Returns:

the file writer result