Package org.apache.cassandra.dht
package org.apache.cassandra.dht
-
ClassDescriptionAbstractBounds<T extends RingPosition<T>>AbstractBounds.AbstractBoundsSerializer<T extends RingPosition<T>>AbstractBounds.Boundary<T extends RingPosition<T>>Bounds<T extends RingPosition<T>>AbstractBounds containing both its endpoints: [left, right].ExcludingBounds<T extends RingPosition<T>>AbstractBounds containing neither of its endpoints: (left, right).IncludingExcludingBounds<T extends RingPosition<T>>AbstractBounds containing only its left endpoint: [left, right).Versioned serializer where the serialization depends on partitioner.This class generates a BigIntegerToken using a Murmur3 hash.This class generates a BigIntegerToken using MD5 hash.Range<T extends RingPosition<T>>A representation of the range that a node is responsible for on the DHT ring.Helper class to check if a token is contained within a given collection of rangesWe model the graph like this: * Each range we are about to stream is a vertex in the graph * Each node that can provide a range is a vertex in the graph * We add an edge from each range to the node that can provide the range * Then, to be able to solve the maximum flow problem using Ford-Fulkerson we add a super source with edges to all range vertices and a super sink with incoming edges from all the node vertices.Assists in streaming ranges to this node.Source filter which only includes endpoints contained within a provided set.Source filter which excludes nodes from local DC.Source filter which excludes the current node from source calculationsSource filter which excludes any endpoints that are not alive according to a failure detector.Source filter which excludes any endpoints that are not in a specific data center.RingPosition<C extends RingPosition<C>>Interface representing a position on the ring.Partition splitter.Store and update available ranges (data already received) to system keyspace.