Package io.delta.kernel.internal.actions

Class SingleAction

Object
io.delta.kernel.internal.actions.SingleAction
public class SingleAction extends Object

  • Field Details

    • CHECKPOINT_SCHEMA

      public static StructType CHECKPOINT_SCHEMA
      Get the schema of reading entries from Delta Log delta and checkpoint files for construction of new checkpoint.

    • CONFLICT_RESOLUTION_SCHEMA

      public static StructType CONFLICT_RESOLUTION_SCHEMA
      Schema to use when reading the winning commit files for conflict resolution. This schema is just for resolving conflicts when doing a blind append. It doesn't cover case when the txn is reading data from the table and updating the table.

    • FULL_SCHEMA

      public static StructType FULL_SCHEMA

    • TXN_ORDINAL

      public static final int TXN_ORDINAL

    • ADD_FILE_ORDINAL

      public static final int ADD_FILE_ORDINAL

    • REMOVE_FILE_ORDINAL

      public static final int REMOVE_FILE_ORDINAL

    • METADATA_ORDINAL

      public static final int METADATA_ORDINAL

    • PROTOCOL_ORDINAL

      public static final int PROTOCOL_ORDINAL

    • COMMIT_INFO_ORDINAL

      public static final int COMMIT_INFO_ORDINAL

  • Constructor Details

    • SingleAction

      public SingleAction()

  • Method Details

    • createAddFileSingleAction

      public static Row createAddFileSingleAction(Row addFile)

    • createProtocolSingleAction

      public static Row createProtocolSingleAction(Row protocol)

    • createMetadataSingleAction

      public static Row createMetadataSingleAction(Row metadata)

    • createRemoveFileSingleAction

      public static Row createRemoveFileSingleAction(Row remove)

    • createCommitInfoSingleAction

      public static Row createCommitInfoSingleAction(Row commitInfo)

    • createDomainMetadataSingleAction

      public static Row createDomainMetadataSingleAction(Row domainMetadata)

    • createTxnSingleAction

      public static Row createTxnSingleAction(Row txn)