Type Members

1.  case class AddColumns(colsToAdd: Seq[QualifiedColTypeWithPositionForLog]) extends Operation with Product with Serializable

   Recorded when columns are added.

2.  case class AddConstraint(constraintName: String, expr: String) extends Operation with Product with Serializable
3.  case class ChangeColumn(columnPath: Seq[String], columnName: String, newColumn: StructField, colPosition: Option[String]) extends Operation with Product with Serializable

   Recorded when columns are changed.

4.  case class Clone(source: String, sourceVersion: Long) extends Operation with Product with Serializable
5.  case class ComputeStats(predicate: Seq[Expression]) extends OperationWithPredicates with Product with Serializable

   Recorded when recomputing stats on the table.

6.  case class Convert(numFiles: Long, partitionBy: Seq[String], collectStats: Boolean, catalogTable: Option[String], sourceFormat: Option[String]) extends Operation with Product with Serializable

   Recorded when converting a table into a Delta table.

7.  case class CreateTable(metadata: Metadata, isManaged: Boolean, asSelect: Boolean = false) extends Operation with Product with Serializable

   Recorded when the table is created.

8.  case class Delete(predicate: Seq[Expression]) extends OperationWithPredicates with Product with Serializable

   Recorded while deleting certain partitions.

9.  case class DropColumns(colsToDrop: Seq[Seq[String]]) extends Operation with Product with Serializable
10.  case class DropConstraint(constraintName: String, expr: Option[String]) extends Operation with Product with Serializable
11.  case class DropTableFeature(featureName: String, truncateHistory: Boolean) extends Operation with Product with Serializable

    Recorded when dropping a table feature.

12.  case class Merge(predicate: Option[Expression], updatePredicate: Option[String], deletePredicate: Option[String], insertPredicate: Option[String], matchedPredicates: Seq[MergePredicate], notMatchedPredicates: Seq[MergePredicate], notMatchedBySourcePredicates: Seq[MergePredicate]) extends OperationWithPredicates with Product with Serializable
13.  case class MergePredicate(predicate: Option[String], actionType: String) extends Product with Serializable

    Represents the predicates and action type (insert, update, delete) for a Merge clause

14.  sealed abstract class Operation extends AnyRef

    An operation that can be performed on a Delta table.

15.  abstract class OperationWithPredicates extends Operation
16.  case class Optimize(predicate: Seq[Expression], zOrderBy: Seq[String] = Seq.empty) extends OptimizeOrReorg with Product with Serializable

    Recorded when optimizing the table.

17.  sealed abstract class OptimizeOrReorg extends OperationWithPredicates
18.  case class QualifiedColTypeWithPositionForLog(columnPath: Seq[String], column: StructField, colPosition: Option[String]) extends Product with Serializable

    Qualified column type with position.

    Qualified column type with position. We define a copy of the type here to avoid depending on the parser output classes in our logging.

19.  case class RenameColumn(oldColumnPath: Seq[String], newColumnPath: Seq[String]) extends Operation with Product with Serializable
20.  case class Reorg(predicate: Seq[Expression], applyPurge: Boolean = true) extends OptimizeOrReorg with Product with Serializable

    Recorded when running REORG on the table.

21.  case class ReplaceColumns(columns: Seq[StructField]) extends Operation with Product with Serializable

    Recorded when columns are replaced.

22.  case class ReplaceTable(metadata: Metadata, isManaged: Boolean, orCreate: Boolean, asSelect: Boolean = false, userMetadata: Option[String] = None) extends Operation with Product with Serializable

    Recorded when the table is replaced.

23.  case class Restore(version: Option[Long], timestamp: Option[String]) extends Operation with Product with Serializable
24.  case class SetTableProperties(properties: Map[String, String]) extends Operation with Product with Serializable
25.  case class StreamingUpdate(outputMode: OutputMode, queryId: String, epochId: Long, userMetadata: Option[String] = None) extends Operation with Product with Serializable

    Recorded during streaming inserts.

26.  case class TestOperation(operationName: String = "TEST") extends Operation with Product with Serializable

    Dummy operation only for testing with arbitrary operation names

27.  case class Truncate() extends Operation with Product with Serializable

    Recorded when truncating the table.

28.  case class UnsetTableProperties(propKeys: Seq[String], ifExists: Boolean) extends Operation with Product with Serializable

    Recorded when the table properties are unset.

29.  case class Update(predicate: Option[Expression]) extends OperationWithPredicates with Product with Serializable

    Recorded when an update operation is committed to the table.

30.  case class UpdateColumnMetadata(operationName: String, columns: Seq[(Seq[String], StructField)]) extends Operation with Product with Serializable
31.  case class UpdateSchema(oldSchema: StructType, newSchema: StructType) extends Operation with Product with Serializable
32.  case class UpgradeProtocol(newProtocol: Protocol) extends Operation with Product with Serializable
33.  case class VacuumEnd(status: String) extends Operation with Product with Serializable
    status

    - whether the vacuum operation was successful; either "COMPLETED" or "FAILED"

34.  case class VacuumStart(retentionCheckEnabled: Boolean, specifiedRetentionMillis: Option[Long], defaultRetentionMillis: Long) extends Operation with Product with Serializable
    retentionCheckEnabled

    - whether retention check was enabled for this run of vacuum.

    specifiedRetentionMillis

    - specified retention interval

    defaultRetentionMillis

    - default retention period for the table

35.  case class Write(mode: SaveMode, partitionBy: Option[Seq[String]] = None, predicate: Option[String] = None, userMetadata: Option[String] = None) extends Operation with Product with Serializable

    Recorded during batch inserts.

    Recorded during batch inserts. Predicates can be provided for overwrites.