object RedirectFeature

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. RedirectFeature
  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 DELTALOG_PREFIX: String
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  9. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  10. def getRedirectConfiguration(snapshot: Snapshot): Option[TableRedirectConfiguration]

    Get the current TableRedirectConfiguration object from the snapshot.

    Get the current TableRedirectConfiguration object from the snapshot. Note that the redirect-reader-writer takes precedence over redirect-writer-only.

  11. def getRedirectConfiguration(properties: Map[String, String]): Option[TableRedirectConfiguration]

    Get the current TableRedirectConfiguration object from the table properties.

    Get the current TableRedirectConfiguration object from the table properties. Note that the redirect-reader-writer takes precedence over redirect-writer-only.

  12. def getRedirectLocationAndTable(spark: SparkSession, deltaLog: DeltaLog, redirectConfig: TableRedirectConfiguration): (Path, Option[CatalogTable])

    This is the main method that redirect deltaLog to the destination location.

  13. def hasRedirectConfig(configs: Map[String, String]): Boolean

    Determines whether configs contains redirect configuration.

  14. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  15. def isFeatureSupported(snapshot: Snapshot): Boolean

    Determine whether the redirect-reader-writer or the redirect-writer-only feature is supported.

  16. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  17. def isRedirectProperty(name: String): Boolean

    Determines whether the property name is redirect property.

  18. def isUpdateProperty(snapshot: Snapshot, op: Operation): Boolean

    Determine whether the operation op updates the existing redirect-reader-writer or redirect-writer-only table property of a table with snapshot.

  19. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  20. def needDeltaLogRedirect(spark: SparkSession, deltaLog: DeltaLog, initialCatalogTable: Option[CatalogTable]): Option[TableRedirectConfiguration]

    Determine whether the current deltaLog needs to skip redirect feature.

  21. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  22. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  23. def parseRedirectConfiguration(configString: String): TableRedirectConfiguration
  24. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  25. def toString(): String
    Definition Classes
    AnyRef → Any
  26. def validateStateTransition(identifier: String, currentState: RedirectState, newState: RedirectState): Unit
  27. def validateTableRedirect(snapshot: Snapshot, catalogTable: Option[CatalogTable], configs: Map[String, String]): Unit
  28. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  29. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  30. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  31. def withUpdateTableRedirectDDL[T](updateTableRedirectDDL: Boolean)(thunk: => T): T

    Execute thunk while isUpdateTableRedirectDDL is set to updateTableRedirectDDL.

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