Packages

c

org.apache.spark.sql.internal.connector

VariantExtractionImpl

case class VariantExtractionImpl(columnName: Array[String], metadata: Metadata, expectedDataType: DataType) extends VariantExtraction with Product with Serializable

Implementation of VariantExtraction.

columnName

Path to the variant column (e.g., Array("v") for top-level, Array("struct1", "v") for nested)

metadata

The metadata for extraction including JSON path, failOnError, and timeZoneId

expectedDataType

The expected data type for the extracted value

Linear Supertypes
Product, Equals, VariantExtraction, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. VariantExtractionImpl
  2. Product
  3. Equals
  4. VariantExtraction
  5. Serializable
  6. AnyRef
  7. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new VariantExtractionImpl(columnName: Array[String], metadata: Metadata, expectedDataType: DataType)

    columnName

    Path to the variant column (e.g., Array("v") for top-level, Array("struct1", "v") for nested)

    metadata

    The metadata for extraction including JSON path, failOnError, and timeZoneId

    expectedDataType

    The expected data type for the extracted value

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 clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  6. val columnName: Array[String]

    Returns the path to the variant column.

    Returns the path to the variant column. For top-level variant columns, this is a single element array containing the column name. For nested variant columns within structs, this is an array representing the path (e.g., ["structCol", "innerStruct", "variantCol"]).

    Definition Classes
    VariantExtractionImpl → VariantExtraction
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. val expectedDataType: DataType

    Returns the expected data type for the extracted value.

    Returns the expected data type for the extracted value. This is the target type specified in variant_get (e.g., IntegerType, StringType).

    Definition Classes
    VariantExtractionImpl → VariantExtraction
  9. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  10. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  11. val metadata: Metadata

    Returns the metadata associated with this variant extraction.

    Returns the metadata associated with this variant extraction. This may include additional information needed by the data source: - "path": the extraction path from variant_get or try_variant_get. This follows JSON path syntax (e.g., "$.a", "$.b.c", "$[0]"). - "failOnError": whether the extraction to expected data type should throw an exception or return null if the cast fails. - "timeZoneId": a string identifier of a time zone. It is required by timestamp-related casts.

    Definition Classes
    VariantExtractionImpl → VariantExtraction
  12. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  14. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  15. def productElementNames: Iterator[String]
    Definition Classes
    Product
  16. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  17. def toString(): String
    Definition Classes
    VariantExtractionImpl → AnyRef → Any
  18. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  19. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  20. 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 Product

Inherited from Equals

Inherited from VariantExtraction

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped