Beautiful Cassandra

AbstractReadExecutor.java

public abstract class AbstractReadExecutor
{
    protected void makeDataRequests(Iterable<InetAddress> endpoints)
    protected void makeDigestRequests(Iterable<InetAddress> endpoints)
    private void makeRequests(ReadCommand readCommand, Iterable<InetAddress> endpoints)
    public abstract void maybeTryAdditionalReplicas();
    public abstract Collection<InetAddress> getContactedReplicas();
    public abstract void executeAsync();
    public PartitionIterator get() throws ReadFailureException, ReadTimeoutException, DigestMismatchException
    public static AbstractReadExecutor getReadExecutor(SinglePartitionReadCommand command, ConsistencyLevel consistencyLevel) throws UnavailableException

}