public class PositionDeleteWriter<T> extends java.lang.Object implements FileWriter<PositionDelete<T>,DeleteWriteResult>
Constructor and Description |
---|
PositionDeleteWriter(FileAppender<StructLike> appender,
FileFormat format,
java.lang.String location,
PartitionSpec spec,
StructLike partition,
EncryptionKeyMetadata keyMetadata) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
long |
length()
Returns the number of bytes that were currently written by this writer.
|
CharSequenceSet |
referencedDataFiles() |
DeleteWriteResult |
result()
Returns a result that contains information about written
DataFile s or DeleteFile s. |
DeleteFile |
toDeleteFile() |
void |
write(PositionDelete<T> positionDelete)
Writes a row to a predefined spec/partition.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
write
public PositionDeleteWriter(FileAppender<StructLike> appender, FileFormat format, java.lang.String location, PartitionSpec spec, StructLike partition, EncryptionKeyMetadata keyMetadata)
public void write(PositionDelete<T> positionDelete)
FileWriter
write
in interface FileWriter<PositionDelete<T>,DeleteWriteResult>
positionDelete
- a data or delete recordpublic long length()
FileWriter
length
in interface FileWriter<PositionDelete<T>,DeleteWriteResult>
public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
java.io.IOException
public CharSequenceSet referencedDataFiles()
public DeleteFile toDeleteFile()
public DeleteWriteResult result()
FileWriter
DataFile
s or DeleteFile
s. The result is valid only after the writer is closed.result
in interface FileWriter<PositionDelete<T>,DeleteWriteResult>