Package org.apache.cassandra.locator

Class AbstractReplicaCollection<C extends AbstractReplicaCollection<C>>

java.lang.Object

org.apache.cassandra.locator.AbstractReplicaCollection<C>

All Implemented Interfaces:

Iterable<Replica>, ReplicaCollection<C>

Direct Known Subclasses:

Endpoints, RangesAtEndpoint

public abstract class AbstractReplicaCollection<C extends AbstractReplicaCollection<C>>
extends Object
implements ReplicaCollection<C>

A collection like class for Replica objects. Since the Replica class contains inetaddress, range, and transient replication status, basic contains and remove methods can be ambiguous. Replicas forces you to be explicit about what you're checking the container for, or removing from it. TODO: there's nothing about this collection that's unique to Replicas, and the implementation could make a useful general purpose immutable list<->set

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static final class	AbstractReplicaCollection.ReplicaList	A simple list with no comodification checks and immutability by default (only append permitted, and only one initial copy) this permits us to reduce the amount of garbage generated, by not wrapping iterators or unnecessarily copying and reduces the amount of indirection necessary, as well as ensuring monomorphic callsites TODO flatten into AbstractReplicaCollection?
protected static class	AbstractReplicaCollection.ReplicaMap<K>	A simple map that ensures the underlying list's iteration order is maintained, and can be shared with subLists (either produced via subList, or via filter that naturally produced a subList).

Nested classes/interfaces inherited from interface org.apache.cassandra.locator.ReplicaCollection

ReplicaCollection.Builder<C extends ReplicaCollection<C>>

Field Summary

Fields

Modifier and Type	Field	Description
protected static final AbstractReplicaCollection.ReplicaList	EMPTY_LIST
protected final AbstractReplicaCollection.ReplicaList	list

Method Summary

Modifier and Type	Method	Description
final boolean	anyMatch(Predicate<? super Replica> test)
final <T> List<T>	asList(Function<Replica,T> view)
static <C extends ReplicaCollection<C>, B extends ReplicaCollection.Builder<C>> Collector<Replica,B,C>	collector(Set<Collector.Characteristics> characteristics, Supplier<B> supplier)
final int	count(Predicate<? super Replica> test)	see ReplicaCollection.count(Predicate)
final boolean	equals(Object o)	It's not clear whether AbstractReplicaCollection should implement the order sensitive equals of List or the order oblivious equals of Set.
final C	filter(Predicate<? super Replica> predicate)	see ReplicaCollection.filter(Predicate)
final C	filter(Predicate<? super Replica> predicate, int limit)	see ReplicaCollection.filter(Predicate, int)
final Iterable<Replica>	filterLazily(Predicate<? super Replica> predicate)	see ReplicaCollection.filterLazily(Predicate)
final Iterable<Replica>	filterLazily(Predicate<? super Replica> predicate, int limit)	see ReplicaCollection.filterLazily(Predicate,int)
final void	forEach(Consumer<? super Replica> forEach)
final Replica	get(int i)
final int	hashCode()	It's not clear whether AbstractReplicaCollection should implement the order sensitive hashCode of List or the order oblivious equals of Set.
final boolean	isEmpty()
final Iterator<Replica>	iterator()
abstract ReplicaCollection.Builder<C>	newBuilder(int initialCapacity)	construct a new Builder of our own type, so that we can concatenate TODO: this isn't terribly pretty, but we need sometimes to select / merge two Endpoints of unknown type;
final int	size()
abstract C	snapshot()
final C	sorted(Comparator<? super Replica> comparator)	see ReplicaCollection.sorted(Comparator)
final Stream<Replica>	stream()
final C	subList(int start, int end)	see ReplicaCollection.subList(int, int)
final String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.lang.Iterable

spliterator

Methods inherited from interface org.apache.cassandra.locator.ReplicaCollection

contains, endpoints

Field Details

EMPTY_LIST

protected static final AbstractReplicaCollection.ReplicaList EMPTY_LIST

list

protected final AbstractReplicaCollection.ReplicaList list

Method Details

collector

public static <C extends ReplicaCollection<C>,
B extends ReplicaCollection.Builder<C>>
Collector<Replica,B,C> collector(Set<Collector.Characteristics> characteristics,
 Supplier<B> supplier)

newBuilder

public abstract ReplicaCollection.Builder<C> newBuilder(int initialCapacity)

construct a new Builder of our own type, so that we can concatenate TODO: this isn't terribly pretty, but we need sometimes to select / merge two Endpoints of unknown type;

snapshot

public abstract C snapshot()

subList

public final C subList(int start,
 int end)

see ReplicaCollection.subList(int, int)

Specified by:

subList in interface ReplicaCollection<C extends AbstractReplicaCollection<C>>

Returns:

an *eagerly constructed* copy of this collection containing the Replica at positions [start..end); An effort will be made to either return ourself, or a subList, where possible. It is guaranteed that no changes to any upstream Builder will affect the state of the result.

asList

public final <T> List<T> asList(Function<Replica,T> view)

count

public final int count(Predicate<? super Replica> test)

see ReplicaCollection.count(Predicate)

Specified by:

count in interface ReplicaCollection<C extends AbstractReplicaCollection<C>>

Returns:

the number of replicas that match the predicate

anyMatch

public final boolean anyMatch(Predicate<? super Replica> test)

filter

public final C filter(Predicate<? super Replica> predicate)

see ReplicaCollection.filter(Predicate)

Specified by:

filter in interface ReplicaCollection<C extends AbstractReplicaCollection<C>>

Returns:

a *eagerly constructed* copy of this collection containing the Replica that match the provided predicate. An effort will be made to either return ourself, or a subList, where possible. It is guaranteed that no changes to any upstream Builder will affect the state of the result.

filter

public final C filter(Predicate<? super Replica> predicate,
 int limit)

see ReplicaCollection.filter(Predicate, int)

Specified by:

filter in interface ReplicaCollection<C extends AbstractReplicaCollection<C>>

Returns:

a *eagerly constructed* copy of this collection containing the Replica that match the provided predicate. An effort will be made to either return ourself, or a subList, where possible. It is guaranteed that no changes to any upstream Builder will affect the state of the result. Only the first maxSize items will be returned.

filterLazily

public final Iterable<Replica> filterLazily(Predicate<? super Replica> predicate)

see ReplicaCollection.filterLazily(Predicate)

Specified by:

filterLazily in interface ReplicaCollection<C extends AbstractReplicaCollection<C>>

Returns:

a *lazily constructed* Iterable over this collection, containing the Replica that match the provided predicate.

filterLazily

public final Iterable<Replica> filterLazily(Predicate<? super Replica> predicate,
 int limit)

see ReplicaCollection.filterLazily(Predicate,int)

Specified by:

filterLazily in interface ReplicaCollection<C extends AbstractReplicaCollection<C>>

Returns:

a *lazily constructed* Iterable over this collection, containing the Replica that match the provided predicate. Only the first maxSize matching items will be returned.

sorted

public final C sorted(Comparator<? super Replica> comparator)

see ReplicaCollection.sorted(Comparator)

Specified by:

sorted in interface ReplicaCollection<C extends AbstractReplicaCollection<C>>

Returns:

an *eagerly constructed* copy of this collection containing the Replica re-ordered according to this comparator It is guaranteed that no changes to any upstream Builder will affect the state of the result.

get

public final Replica get(int i)

Specified by:

get in interface ReplicaCollection<C extends AbstractReplicaCollection<C>>

Parameters:

i - a value in the range [0..size())

Returns:

the i'th Replica, in our iteration order

size

public final int size()

Specified by:

size in interface ReplicaCollection<C extends AbstractReplicaCollection<C>>

Returns:

the number of Replica contained

isEmpty

public final boolean isEmpty()

Specified by:

isEmpty in interface ReplicaCollection<C extends AbstractReplicaCollection<C>>

Returns:

true iff size() == 0

iterator

public final Iterator<Replica> iterator()

Specified by:

iterator in interface Iterable<C extends AbstractReplicaCollection<C>>

Specified by:

iterator in interface ReplicaCollection<C extends AbstractReplicaCollection<C>>

forEach

public final void forEach(Consumer<? super Replica> forEach)

Specified by:

forEach in interface Iterable<C extends AbstractReplicaCollection<C>>

stream

public final Stream<Replica> stream()

Specified by:

stream in interface ReplicaCollection<C extends AbstractReplicaCollection<C>>

equals

public final boolean equals(Object o)

It's not clear whether AbstractReplicaCollection should implement the order sensitive equals of List or the order oblivious equals of Set. We never rely on equality in the database so rather then leave in a potentially surprising implementation we have it throw UnsupportedOperationException.

Don't implement this and pick one behavior over the other. If you want equality you can static import Iterables.elementsEqual(Iterable, Iterable) and use that to get order sensitive equals.

Specified by:

equals in interface ReplicaCollection<C extends AbstractReplicaCollection<C>>

Overrides:

equals in class Object

hashCode

public final int hashCode()

It's not clear whether AbstractReplicaCollection should implement the order sensitive hashCode of List or the order oblivious equals of Set. We never rely on hashCode in the database so rather then leave in a potentially surprising implementation we have it throw UnsupportedOperationException.

Don't implement this and pick one behavior over the other.

Specified by:

hashCode in interface ReplicaCollection<C extends AbstractReplicaCollection<C>>

Overrides:

hashCode in class Object

toString

public final String toString()

Specified by:

toString in interface ReplicaCollection<C extends AbstractReplicaCollection<C>>

Overrides:

toString in class Object