Package org.apache.iceberg.io
Class ClusteredPositionDeleteWriter<T>
- java.lang.Object
-
- org.apache.iceberg.io.ClusteredPositionDeleteWriter<T>
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
,PartitioningWriter<PositionDelete<T>,DeleteWriteResult>
public class ClusteredPositionDeleteWriter<T> extends java.lang.Object
A position delete writer capable of writing to multiple specs and partitions that requires the incoming delete records to be properly clustered by partition spec and by partition within each spec.
-
-
Constructor Summary
Constructors Constructor Description ClusteredPositionDeleteWriter(FileWriterFactory<T> writerFactory, OutputFileFactory fileFactory, FileIO io, long targetFileSizeInBytes)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
addResult(DeleteWriteResult result)
protected DeleteWriteResult
aggregatedResult()
void
close()
protected EncryptedOutputFile
newOutputFile(OutputFileFactory fileFactory, PartitionSpec spec, StructLike partition)
protected FileWriter<PositionDelete<T>,DeleteWriteResult>
newWriter(PartitionSpec spec, StructLike partition)
R
result()
Returns a result that contains information about writtenDataFile
s orDeleteFile
s.void
write(T row, PartitionSpec spec, StructLike partition)
Writes a row to the provided spec/partition.
-
-
-
Constructor Detail
-
ClusteredPositionDeleteWriter
public ClusteredPositionDeleteWriter(FileWriterFactory<T> writerFactory, OutputFileFactory fileFactory, FileIO io, long targetFileSizeInBytes)
-
-
Method Detail
-
newWriter
protected FileWriter<PositionDelete<T>,DeleteWriteResult> newWriter(PartitionSpec spec, StructLike partition)
-
addResult
protected void addResult(DeleteWriteResult result)
-
aggregatedResult
protected DeleteWriteResult aggregatedResult()
-
write
public void write(T row, PartitionSpec spec, StructLike partition)
Description copied from interface:PartitioningWriter
Writes a row to the provided spec/partition.- Specified by:
write
in interfacePartitioningWriter<T,R>
- Parameters:
row
- a data or delete recordspec
- a partition specpartition
- a partition or null if the spec is unpartitioned
-
close
public void close() throws java.io.IOException
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- Throws:
java.io.IOException
-
result
public final R result()
Description copied from interface:PartitioningWriter
Returns a result that contains information about writtenDataFile
s orDeleteFile
s. The result is valid only after the writer is closed.- Specified by:
result
in interfacePartitioningWriter<T,R>
- Returns:
- the writer result
-
newOutputFile
protected EncryptedOutputFile newOutputFile(OutputFileFactory fileFactory, PartitionSpec spec, StructLike partition)
-
-