com.datastax.spark.connector

writer

package writer

Contains components for writing RDDs to Cassandra

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. writer
  2. AnyRef
  3. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Type Members

  1. class AsyncExecutor[T, R] extends Logging

    Asynchronously executes tasks but blocks if the limit of unfinished tasks is reached.

  2. sealed trait BatchGroupingKey extends AnyRef

  3. class CassandraRowWriter extends RowWriter[CassandraRow]

    A RowWriter that can write CassandraRow objects.

  4. class DefaultRowWriter[T] extends RowWriter[T]

    A RowWriter suitable for saving objects mappable by a ColumnMapper.

  5. trait LowPriorityRowWriterFactoryImplicits extends AnyRef

    Provides a low-priority implicit RowWriterFactory able to write objects of any class for which a ColumnMapper is defined.

  6. case class NullKeyColumnException(columnName: String) extends NullPointerException with Product with Serializable

  7. case class PerRowWriteOptionValue[T](placeholder: String) extends WriteOptionValue[T] with Product with Serializable

  8. class PropertyExtractor[T] extends Serializable

    Extracts values from fields of an object.

  9. class QueryExecutor extends AsyncExecutor[RichStatement, ResultSet]

  10. class RateLimiter extends AnyRef

    A leaking bucket rate limiter.

  11. class ReplicaLocator[T] extends Serializable with Logging

    A utility class for determining the Replica Set (Ip Addresses) of a particular Cassandra Row.

  12. trait RichStatement extends AnyRef

  13. class RoutingKeyGenerator extends (BoundStatement) ⇒ ByteBuffer

    This class computes the routing key of a bound statement.

  14. trait RowWriter[T] extends Serializable

    RowWriter knows how to extract column names and values from custom row objects and how to convert them to values that can be written to Cassandra.

  15. trait RowWriterFactory[T] extends AnyRef

    Creates instances of RowWriter objects for the given row type T.

  16. class SqlRowWriter extends RowWriter[Row]

    A RowWriter that can write SparkSQL Row objects.

  17. case class StaticWriteOptionValue[T](value: T) extends WriteOptionValue[T] with Product with Serializable

  18. case class TTLOption(value: WriteOptionValue[Int]) extends WriteOption[Int] with Product with Serializable

  19. class TableWriter[T] extends Serializable with Logging

    Writes RDD data into given Cassandra table.

  20. case class TimestampOption(value: WriteOptionValue[Long]) extends WriteOption[Long] with Product with Serializable

  21. abstract class WritableToCassandra[T] extends AnyRef

  22. case class WriteConf(batchSize: BatchSize = ..., batchGroupingBufferSize: Int = ..., batchGroupingKey: BatchGroupingKey = WriteConf.DefaultBatchGroupingKey, consistencyLevel: ConsistencyLevel = WriteConf.DefaultConsistencyLevel, parallelismLevel: Int = WriteConf.DefaultParallelismLevel, throughputMiBPS: Double = ..., ttl: TTLOption = TTLOption.defaultValue, timestamp: TimestampOption = TimestampOption.defaultValue, taskMetricsEnabled: Boolean = ...) extends Product with Serializable

    Write settings for RDD

  23. sealed trait WriteOption[+T] extends AnyRef

  24. sealed trait WriteOptionValue[+T] extends AnyRef

Value Members

  1. object AsyncExecutor

  2. object BatchGroupingKey

  3. object CassandraRowWriter extends Serializable

  4. object DefaultRowWriter extends Serializable

  5. object DefaultValue extends WriteOptionValue[Nothing] with Product with Serializable

  6. object ObjectSizeEstimator

    Estimates amount of memory required to serialize Java/Scala objects

  7. object PropertyExtractor extends Serializable

  8. object ReplicaLocator extends Serializable

    Helper methods for mapping a set of data to their relative locations in a Cassandra Cluster.

  9. object RowWriterFactory extends LowPriorityRowWriterFactoryImplicits

    Provides an implicit RowWriterFactory for saving CassandraRow objects.

  10. object SqlRowWriter extends Serializable

  11. object TTLOption extends Serializable

  12. object TableWriter extends Serializable

  13. object TimestampOption extends Serializable

  14. object WriteConf extends Serializable

  15. object WriteOption

Inherited from AnyRef

Inherited from Any

Ungrouped