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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

    Permalink
  16. trait LowPriorityRowReaderFactoryImplicits extends AnyRef

    Permalink
  17. class PrefetchingResultSetIterator extends Iterator[Row]

    Permalink

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

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

  19. 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( ... )
  20. trait ThisRowReaderAsFactory[T] extends RowReaderFactory[T]

    Permalink

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

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

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

    Permalink

Inherited from AnyRef

Inherited from Any

Ungrouped