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 ChangeColumns(columns: Seq[ChangeColumn]) extends Operation with Product with Serializable

   Recorded when columns are changed in bulk.

5.  case class Clone(source: String, sourceVersion: Long) extends Operation with Product with Serializable
6.  case class ClusterBy(oldClusteringColumns: String, newClusteringColumns: String) extends Operation with Product with Serializable

   Recorded when clustering columns are changed on clustered tables.

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

   Recorded when recomputing stats on the table.

8.  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.

9.  case class CreateTable(metadata: Metadata, isManaged: Boolean, asSelect: Boolean = false, clusterBy: Option[Seq[String]] = None) extends Operation with Product with Serializable

   Recorded when the table is created.

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

    Recorded while deleting certain partitions.

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

    Recorded when dropping a table feature.

14.  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
15.  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

16.  sealed abstract class Operation extends AnyRef

    An operation that can be performed on a Delta table.

17.  abstract class OperationWithPredicates extends Operation
18.  case class Optimize(predicate: Seq[Expression], zOrderBy: Seq[String] = Seq.empty, auto: Boolean = false, clusterBy: Option[Seq[String]] = None, isFull: Boolean = false) extends OptimizeOrReorg with Product with Serializable

    Recorded when optimizing the table.

19.  sealed abstract class OptimizeOrReorg extends OperationWithPredicates
20.  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.

21.  case class RemoveColumnMapping(userMetadata: Option[String] = None) extends Operation with Product with Serializable
22.  case class RenameColumn(oldColumnPath: Seq[String], newColumnPath: Seq[String]) extends Operation with Product with Serializable
23.  case class Reorg(predicate: Seq[Expression], applyPurge: Boolean = true) extends OptimizeOrReorg with Product with Serializable

    Recorded when running REORG on the table.

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

    Recorded when columns are replaced.

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

    Recorded when the table is replaced.

26.  case class Restore(version: Option[Long], timestamp: Option[String]) extends Operation with Product with Serializable
27.  case class RowTrackingBackfill(batchId: Int = 0) extends Operation with Product with Serializable

    Recorded when we backfill a Delta table's existing AddFiles with row tracking data.

28.  case class SetTableProperties(properties: Map[String, String]) extends Operation with Product with Serializable
29.  case class StreamingUpdate(outputMode: OutputMode, queryId: String, epochId: Long, userMetadata: Option[String] = None) extends Operation with Product with Serializable

    Recorded during streaming inserts.

30.  case class TestOperation(operationName: String = "TEST", isInPlaceFileMetadataUpdate: Option[Boolean] = None) extends Operation with Product with Serializable

    Dummy operation only for testing with arbitrary operation names

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

    Recorded when truncating the table.

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

    Recorded when the table properties are unset.

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

    Recorded when an update operation is committed to the table.

34.  case class UpdateColumnMetadata(operationName: String, columns: Seq[(Seq[String], StructField)]) extends Operation with Product with Serializable
35.  case class UpdateSchema(oldSchema: StructType, newSchema: StructType) extends Operation with Product with Serializable
36.  case class UpgradeProtocol(newProtocol: Protocol) extends Operation with Product with Serializable
37.  case class UpgradeUniformProperties(properties: Map[String, String]) extends Operation with Product with Serializable

    recorded when upgrading a table set uniform properties by REORG TABLE ...

    recorded when upgrading a table set uniform properties by REORG TABLE ... UPGRADE UNIFORM

38.  case class VacuumEnd(status: String) extends Operation with Product with Serializable
    status

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

39.  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

40.  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.