Class

com.datastax.bdp.graph.spark.sql

StructConverter

Related Doc: package sql

Permalink

class StructConverter extends CassandraRowConverter

Linear Supertypes
CassandraRowConverter, Serializable, Serializable, (Row) ⇒ Any, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. StructConverter
  2. CassandraRowConverter
  3. Serializable
  4. Serializable
  5. Function1
  6. AnyRef
  7. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new StructConverter(dataType: StructType, fieldIndex: Int, metaIndexes: Seq[Int])

    Permalink

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  4. def andThen[A](g: (Any) ⇒ A): (Row) ⇒ A

    Permalink
    Definition Classes
    Function1
    Annotations
    @unspecialized()
  5. def apply(row: Row): Any

    Permalink
    Definition Classes
    StructConverter → Function1
  6. def apply(iter: BufferedIterator[Row]): Any

    Permalink

    Iterator is used in array converter to read multiply C* rows It is strongly recommended to call this method for unified access.

    Iterator is used in array converter to read multiply C* rows It is strongly recommended to call this method for unified access.

    Definition Classes
    CassandraRowConverter
  7. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  8. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  9. def compose[A](g: (A) ⇒ Row): (A) ⇒ Any

    Permalink
    Definition Classes
    Function1
    Annotations
    @unspecialized()
  10. def convert(data: Any): Any

    Permalink

    connector converter reference, mostly used for DseGraphTraversal conversions

    connector converter reference, mostly used for DseGraphTraversal conversions

    Definition Classes
    StructConverterCassandraRowConverter
  11. def copy(fieldIndex: Int = fieldIndex): CassandraRowConverter

    Permalink
    Definition Classes
    StructConverterCassandraRowConverter
  12. val dataType: StructType

    Permalink

    spark SQL data type.

    spark SQL data type. The result will be converted to the dataType.

    Definition Classes
    StructConverterCassandraRowConverter
  13. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  14. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  15. val fieldConverters: Array[CassandraRowConverter]

    Permalink
  16. val fieldIndex: Int

    Permalink

    index in the C* row to read base value.

    index in the C* row to read base value.

    Definition Classes
    StructConverterCassandraRowConverter
  17. val fieldIndexes: Seq[Int]

    Permalink
  18. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  19. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  20. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  21. def inverse(out: Array[Any], data: Any): Unit

    Permalink

    the function that convert data back from DF value to C* representation row

    the function that convert data back from DF value to C* representation row

    out

    SparkSQL mutable row, that will be saved to C*

    data

    data to convert

    Definition Classes
    StructConverterCassandraRowConverter
  22. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  23. val metaIndexes: Seq[Int]

    Permalink
  24. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  25. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  26. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  27. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef
  28. def toString(): String

    Permalink
    Definition Classes
    Function1 → AnyRef → Any
  29. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  30. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  31. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from CassandraRowConverter

Inherited from Serializable

Inherited from Serializable

Inherited from (Row) ⇒ Any

Inherited from AnyRef

Inherited from Any

Ungrouped