Asynchronously executes tasks but blocks if the limit of unfinished tasks is reached.
RowWriter suitable for saving objects mappable by a ColumnMapper.
Provides a low-priority implicit
RowWriterFactory able to write objects of any class for which
a ColumnMapper is defined.
Extracts values from fields of an object.
A leaking bucket rate limiter.
A utility class for determining the Replica Set (Ip Addresses) of a particular Cassandra Row.
This class computes the routing key of a bound statement.
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.
Creates instances of RowWriter objects for the given row type
A RowWriter that can write SparkSQL
Writes RDD data into given Cassandra table.
Write settings for RDD
approx. number of bytes to be written in a single batch or exact number of rows to be written in a single batch;
the number of distinct batches that can be buffered before they are written to Cassandra
which rows can be grouped into a single batch
consistency level for writes, default LOCAL_QUORUM
inserting a row should happen only if it does not already exist
number of batches to be written in parallel
the default TTL value which is used when it is defined (in seconds)
the default timestamp value which is used when it is defined (in microseconds)
whether or not enable task metrics updates (requires Spark 1.2+)
Estimates amount of memory required to serialize Java/Scala objects
Helper methods for mapping a set of data to their relative locations in a Cassandra Cluster.
Provides an implicit
RowWriterFactory for saving CassandraRow objects.