Trait/Object

com.datastax.bdp.graph.spark.sql

CassandraRowConverter

Related Docs: object CassandraRowConverter | package sql

Permalink

trait CassandraRowConverter extends (Row) ⇒ Any with Serializable

Converters is not thread safe! For performance. clone converters for each partition params: sqlRow iterator, fieldIndex in the row, beginning of meta property index return catalist compatible value All struct should be UnsafeRow type.

Linear Supertypes
Serializable, Serializable, (Row) ⇒ Any, AnyRef, Any
Known Subclasses
ArrayConverter, DateFieldConverter, DecimalFieldConverter, FieldConverter, StructConverter, TimestampFieldConverter
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CassandraRowConverter
  2. Serializable
  3. Serializable
  4. Function1
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Abstract Value Members

  1. abstract def apply(v1: Row): Any

    Permalink
    Definition Classes
    Function1

  2. abstract def convert(data: Any): Any

    Permalink

    connector converter reference, mostly used for DseGraphTraversal conversions

  3. abstract def copy(fieldIndex: Int): CassandraRowConverter

    Permalink

  4. abstract val dataType: DataType

    Permalink

    spark SQL data type.

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

  5. abstract val fieldIndex: Int

    Permalink

    index in the C* row to read base value.

Concrete 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(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.

  6. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any

  7. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  8. def compose[A](g: (A) ⇒ Row): (A) ⇒ Any

    Permalink
    Definition Classes
    Function1
    Annotations
    @unspecialized()

  9. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef

  10. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  11. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

  12. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any

  13. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any

  14. 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

  15. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any

  16. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef

  17. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef

  18. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef

  19. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef

  20. def toString(): String

    Permalink
    Definition Classes
    Function1 → AnyRef → Any

  21. final def wait(): Unit

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

  22. final def wait(arg0: Long, arg1: Int): Unit

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

  23. final def wait(arg0: Long): Unit

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

Inherited from Serializable

Inherited from Serializable

Inherited from (Row) ⇒ Any

Inherited from AnyRef

Inherited from Any

Ungrouped