com.datastax.spark.connector.rdd

reader

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
Learn more about member selection
Visibility
  1. Public
  2. All

Type Members

  1. class AnyObjectFactory[T] extends Logging with Serializable

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

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

    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]

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

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

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

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

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

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

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

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

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

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

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

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

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

  17. class KeyValueRowReader[K, V] extends RowReader[(K, V)]

  18. class KeyValueRowReaderFactory[K, V] extends RowReaderFactory[(K, V)]

  19. trait LowPriorityRowReaderFactoryImplicits extends AnyRef

  20. class PrefetchingResultSetIterator extends Iterator[Row]

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

  21. trait RowReader[T] extends Serializable

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

  22. trait RowReaderFactory[T] extends AnyRef

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

  23. case class RowReaderOptions(offset: Int = 0, aliasToColumnName: Map[String, String] = ...) extends Product with Serializable

  24. trait ThisRowReaderAsFactory[T] extends RowReaderFactory[T]

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

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

  26. class ValueRowReaderFactory[T] extends RowReaderFactory[T]

Value Members

  1. object AnyObjectFactory extends Logging with Serializable

  2. object RowReaderFactory extends LowPriorityRowReaderFactoryImplicits

  3. object RowReaderOptions extends Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped