Class BasePositionDeltaWriter<T>

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable, PositionDeltaWriter<T>

    public class BasePositionDeltaWriter<T>
    extends java.lang.Object
    implements PositionDeltaWriter<T>
    • Method Detail

      • insert

        public void insert​(T row,
                           PartitionSpec spec,
                           StructLike partition)
        Description copied from interface: PositionDeltaWriter
        Inserts a row to the provided spec/partition.
        Specified by:
        insert in interface PositionDeltaWriter<T>
        Parameters:
        row - a data record
        spec - a partition spec
        partition - a partition or null if the spec is unpartitioned
      • delete

        public void delete​(java.lang.CharSequence path,
                           long pos,
                           T row,
                           PartitionSpec spec,
                           StructLike partition)
        Description copied from interface: PositionDeltaWriter
        Deletes a position in the provided spec/partition and records the deleted row in the delete file.
        Specified by:
        delete in interface PositionDeltaWriter<T>
        Parameters:
        path - a data file path
        pos - a position
        row - a deleted row
        spec - a partition spec
        partition - a partition or null if the spec is unpartitioned
      • 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