A special structure for fast lookup of rangesContaining containing given point.
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
RDD created by repartitionByCassandraReplica with preferred locations mapping to the CassandraReplicas each partition was created for.
Stores a CQL
WHERE predicate matching a range of tokens.
Estimates amount of data in the Cassandra table.
A mapping from T values to an integer range [0, n), such that for any (t1: T) > (t2: T), bucket(t1) >= bucket(t2).
Looks up listen address of a cluster node given its RPC address.
Extracts rangeBounds of a range R.
The replica partitioner will work on an RDD which is keyed on sets of InetAddresses representing Cassandra Hosts .
Groups a set of token ranges into
groupCount groups containing not more than
Holds a token range together with the index of a partition this token range belongs to