Package

com.datastax.spark.connector.rdd

reader

Permalink

package reader

Provides components for reading data rows from Cassandra and converting them to objects of desired type. Additionally provides a generic CassandraRow class which can represent any row.

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. reader
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. class AnyObjectFactory[T] extends Logging with Serializable

    Permalink

    Factory for creating objects of any type by invoking their primary constructor.

    Factory for creating objects of any type by invoking their primary constructor. Unlike Java reflection Methods or Scala reflection Mirrors, this factory is serializable and can be safely passed along with Spark tasks.

  2. final class ClassBasedRowReader[R] extends RowReader[R]

    Permalink

    Transforms a Cassandra Java driver Row into an object of a user provided class, calling the class constructor

  3. class ClassBasedRowReaderFactory[R] extends RowReaderFactory[R]

    Permalink
  4. trait FunctionBasedRowReader[R] extends RowReader[R] with ThisRowReaderAsFactory[R]

    Permalink
  5. class FunctionBasedRowReader1[R, A0] extends FunctionBasedRowReader[R]

    Permalink
  6. class FunctionBasedRowReader10[R, A0, A1, A2, A3, A4, A5, A6, A7, A8, A9] extends FunctionBasedRowReader[R]

    Permalink
  7. class FunctionBasedRowReader11[R, A0, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10] extends FunctionBasedRowReader[R]

    Permalink
  8. class FunctionBasedRowReader12[R, A0, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11] extends FunctionBasedRowReader[R]

    Permalink
  9. class FunctionBasedRowReader2[R, A0, A1] extends FunctionBasedRowReader[R]

    Permalink
  10. class FunctionBasedRowReader3[R, A0, A1, A2] extends FunctionBasedRowReader[R]

    Permalink
  11. class FunctionBasedRowReader4[R, A0, A1, A2, A3] extends FunctionBasedRowReader[R]

    Permalink
  12. class FunctionBasedRowReader5[R, A0, A1, A2, A3, A4] extends FunctionBasedRowReader[R]

    Permalink
  13. class FunctionBasedRowReader6[R, A0, A1, A2, A3, A4, A5] extends FunctionBasedRowReader[R]

    Permalink
  14. class FunctionBasedRowReader7[R, A0, A1, A2, A3, A4, A5, A6] extends FunctionBasedRowReader[R]

    Permalink
  15. class FunctionBasedRowReader8[R, A0, A1, A2, A3, A4, A5, A6, A7] extends FunctionBasedRowReader[R]

    Permalink
  16. class FunctionBasedRowReader9[R, A0, A1, A2, A3, A4, A5, A6, A7, A8] extends FunctionBasedRowReader[R]

    Permalink
  17. trait LowPriorityRowReaderFactoryImplicits extends AnyRef

    Permalink
  18. class PrefetchingResultSetIterator extends Iterator[Row]

    Permalink

    Allows to efficiently iterate over a large, paged ResultSet, asynchronously prefetching the next page.

  19. trait RowReader[T] extends Serializable

    Permalink

    Transforms a Cassandra Java driver Row into high-level row representation, e.g.

    Transforms a Cassandra Java driver Row into high-level row representation, e.g. a tuple or a user-defined case class object. The target type T must be serializable.

  20. trait RowReaderFactory[T] extends AnyRef

    Permalink

    Creates RowReader objects prepared for reading rows from the given Cassandra table.

    Creates RowReader objects prepared for reading rows from the given Cassandra table.

    Annotations
    @implicitNotFound( ... )
  21. trait ThisRowReaderAsFactory[T] extends RowReaderFactory[T]

    Permalink

    Helper for implementing RowReader objects that can be used as RowReaderFactory objects.

  22. class ValueRowReader[T] extends RowReader[T]

    Permalink
  23. class ValueRowReaderFactory[T] extends RowReaderFactory[T]

    Permalink

Value Members

  1. object AnyObjectFactory extends Logging with Serializable

    Permalink
  2. object RowReaderFactory extends LowPriorityRowReaderFactoryImplicits

    Permalink

Inherited from AnyRef

Inherited from Any

Ungrouped