- By Inheritance
- Hide All
- Show All
BucketingRangeIndex[R, T] extends AnyRef
A special structure for fast lookup of rangesContaining containing given point.
CassandraPartition[V, T <: Token[V]](index: Int, endpoints: Array[String], tokenRanges: Iterable[CqlTokenRange[V, T]], dataSize: Long) extends EndpointPartition with InputPartition with Product with Serializable
Metadata describing Cassandra table partition processed by a single Spark task.
identifier of the partition, used internally by Spark
which nodes the data partition is located on
token ranges determining the row set to be fetched
estimated amount of data in the partition
CassandraPartitionedRDD[T] extends RDD[T]
RDD created by repartitionByCassandraReplica with preferred locations mapping to the CassandraReplicas each partition was created for.
CqlTokenRange[V, T <: Token[V]](range: TokenRange[V, T])(implicit tf: TokenFactory[V, T]) extends Product with Serializable
Stores a CQL
WHEREpredicate matching a range of tokens.
DataSizeEstimates[V, T <: Token[V]] extends Logging
Estimates amount of data in the Cassandra table.
- trait EndpointPartition extends Partition
MonotonicBucketing[-T] extends AnyRef
A mapping from T values to an integer range [0, n), such that for any (t1: T) > (t2: T), bucket(t1) >= bucket(t2).
NodeAddresses extends Serializable
Looks up listen address of a cluster node given its Native Transport address.
RangeBounds[-R, T] extends AnyRef
Extracts rangeBounds of a range R.
- case class ReplicaPartition(index: Int, endpoints: Array[String]) extends EndpointPartition with Product with Serializable
ReplicaPartitioner[T] extends Partitioner
The replica partitioner will work on an RDD which is keyed on sets of InetAddresses representing Cassandra Hosts .
TokenRangeClusterer[V, T <: Token[V]] extends AnyRef
Groups a set of token ranges into
groupCountgroups containing not more than
TokenRangeWithPartitionIndex[V, T <: Token[V]](range: TokenRange[V, T], partitionIndex: Int) extends Product with Serializable
Holds a token range together with the index of a partition this token range belongs to