object CatalogOwnedTableUtils

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CatalogOwnedTableUtils
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. val ICT_TABLE_PROPERTY_CONFS: Seq[DeltaConfig[_ >: Option[Long] with Boolean]]
  5. val ICT_TABLE_PROPERTY_KEYS: Seq[String]

    The main ICT table properties used as dependencies for Catalog-Owned enabled table.

  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  8. def defaultCatalogOwnedEnabled(spark: SparkSession): Boolean

    Whether Catalog-Owned is enabled via default SparkSession configuration.

    Whether Catalog-Owned is enabled via default SparkSession configuration.

    spark

    The SparkSession to check.

    returns

    True if Catalog-Owned is enabled by default, false otherwise.

  9. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  10. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  11. def filterOutCatalogOwnedTableFeature(protocol: Protocol): Protocol

    Filters out CatalogOwnedTableFeature from the provided protocol.

    Filters out CatalogOwnedTableFeature from the provided protocol. This is used to ensure that the CatalogOwnedTableFeature is not included in the protocol for specific DDL commands, e.g., CREATE CLONE, REPLACE CLONE, CREATE LIKE.

    protocol

    The protocol to filter.

  12. def getCatalogName(spark: SparkSession, identifier: TableIdentifier): Option[String]

    Returns the catalog name from the given catalog table identifier.

    Returns the catalog name from the given catalog table identifier. If the catalog table is not present, returns None.

  13. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  14. def getCommitCoordinator(spark: SparkSession, identifier: TableIdentifier): Option[CommitCoordinatorClient]
  15. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  16. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  17. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  18. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  19. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  20. def populateTableCommitCoordinatorFromCatalog(spark: SparkSession, catalogTableOpt: Option[CatalogTable], snapshot: Snapshot): Option[TableCommitCoordinatorClient]
  21. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  22. def toString(): String
    Definition Classes
    AnyRef → Any
  23. def validatePropertiesForAlterTableSetPropertiesDeltaCommand(snapshot: Snapshot, propertyOverrides: Map[String, String]): Unit

    Validates the Catalog-Owned configurations in explicit command overrides for AlterTableSetPropertiesDeltaCommand.

    Validates the Catalog-Owned configurations in explicit command overrides for AlterTableSetPropertiesDeltaCommand.

    If CatalogOwnedTableFeature presents, we do NOT allow users to modify any ICT properties that Catalog-Owned depends on.

  24. def validatePropertiesForAlterTableUnsetPropertiesDeltaCommand(snapshot: Snapshot, propKeysToUnset: Seq[String]): Unit

    Validates the configurations to unset for AlterTableUnsetPropertiesDeltaCommand.

    Validates the configurations to unset for AlterTableUnsetPropertiesDeltaCommand.

    If the table already has CatalogOwnedTableFeature present, we do not allow users to unset any of the ICT properties that Catalog-Owned depends on.

  25. def validatePropertiesForCreateDeltaTableCommand(spark: SparkSession, tableExists: Boolean, query: Option[LogicalPlan], catalogTableProperties: Map[String, String]): Unit

    Validates the Catalog-Owned properties in explicit command overrides and default SparkSession properties for CreateDeltaTableCommand.

  26. def validateUCTableIdNotPresent(property: Map[String, String]): Unit

    Validates that the UC table ID is not present in the provided property (overrides).

    Validates that the UC table ID is not present in the provided property (overrides). Errors out if it is present.

    property

    The property to validate.

  27. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  28. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  29. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from AnyRef

Inherited from Any

Ungrouped