Packages

c

org.apache.spark.sql.catalyst.catalog

TempVariableManager

class TempVariableManager extends VariableManager with DataTypeErrorsBase

A thread-safe manager for temporary SQL variables (that live in the schema SYSTEM.SESSION), providing atomic operations to manage them, e.g. create, get, remove, etc.

Note that, the variable name is always case-sensitive here, callers are responsible to format the variable name w.r.t. case-sensitive config.

Linear Supertypes
DataTypeErrorsBase, VariableManager, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TempVariableManager
  2. DataTypeErrorsBase
  3. VariableManager
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new TempVariableManager()

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. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clear(): Unit

    Delete all variables.

    Delete all variables.

    Definition Classes
    TempVariableManager → VariableManager
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  7. def create(nameParts: Seq[String], varDef: VariableDefinition, overrideIfExists: Boolean): Unit

    Create a variable.

    Create a variable.

    nameParts

    NameParts of the variable.

    varDef

    The VariableDefinition of the variable.

    overrideIfExists

    If true, the new variable will replace an existing one with the same identifier, if it exists.

    Definition Classes
    TempVariableManager → VariableManager
  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  10. def get(nameParts: Seq[String]): Option[VariableDefinition]

    Get an existing variable.

    Get an existing variable.

    nameParts

    Name parts of the variable.

    Definition Classes
    TempVariableManager → VariableManager
  11. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  12. def getQueryContext(context: QueryContext): Array[QueryContext]
    Definition Classes
    DataTypeErrorsBase
  13. def getSummary(sqlContext: QueryContext): String
    Definition Classes
    DataTypeErrorsBase
  14. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  15. def isEmpty: Boolean

    returns

    true if at least one variable exists, false otherwise.

    Definition Classes
    TempVariableManager → VariableManager
  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 qualify(name: String): ResolvedIdentifier

    Create an identifier for the provided variable name.

    Create an identifier for the provided variable name. Could be context dependent.

    name

    Name for which an identifier is created.

    Definition Classes
    TempVariableManager → VariableManager
  21. def quoteByDefault(elem: String): String
    Attributes
    protected
    Definition Classes
    DataTypeErrorsBase
  22. def remove(nameParts: Seq[String]): Boolean

    Delete an existing variable.

    Delete an existing variable.

    nameParts

    Name parts of the variable.

    Definition Classes
    TempVariableManager → VariableManager
  23. def set(nameParts: Seq[String], varDef: VariableDefinition): Unit

    Set an existing variable to a new value.

    Set an existing variable to a new value.

    nameParts

    Name parts of the variable.

    varDef

    The new VariableDefinition of the variable.

    Definition Classes
    TempVariableManager → VariableManager
  24. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  25. def toDSOption(option: String): String
    Definition Classes
    DataTypeErrorsBase
  26. def toSQLConf(conf: String): String
    Definition Classes
    DataTypeErrorsBase
  27. def toSQLId(parts: Seq[String]): String
    Definition Classes
    DataTypeErrorsBase
  28. def toSQLId(parts: String): String
    Definition Classes
    DataTypeErrorsBase
  29. def toSQLStmt(text: String): String
    Definition Classes
    DataTypeErrorsBase
  30. def toSQLType(t: AbstractDataType): String
    Definition Classes
    DataTypeErrorsBase
  31. def toSQLType(text: String): String
    Definition Classes
    DataTypeErrorsBase
  32. def toSQLValue(value: Double): String
    Definition Classes
    DataTypeErrorsBase
  33. def toSQLValue(value: Float): String
    Definition Classes
    DataTypeErrorsBase
  34. def toSQLValue(value: Long): String
    Definition Classes
    DataTypeErrorsBase
  35. def toSQLValue(value: Int): String
    Definition Classes
    DataTypeErrorsBase
  36. def toSQLValue(value: Short): String
    Definition Classes
    DataTypeErrorsBase
  37. def toSQLValue(value: UTF8String): String
    Definition Classes
    DataTypeErrorsBase
  38. def toSQLValue(value: String): String
    Definition Classes
    DataTypeErrorsBase
  39. def toString(): String
    Definition Classes
    AnyRef → Any
  40. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  41. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  42. 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 DataTypeErrorsBase

Inherited from VariableManager

Inherited from AnyRef

Inherited from Any

Ungrouped