akka.cluster.ddata

Class ManyVersionVector

java.lang.Object

akka.cluster.ddata.VersionVector

akka.cluster.ddata.ManyVersionVector

All Implemented Interfaces:

RemovedNodePruning, ReplicatedData, ReplicatedDataSerialization, java.io.Serializable, scala.Equals, scala.Product

public final class ManyVersionVector
extends VersionVector
implements scala.Product, scala.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class akka.cluster.ddata.VersionVector

VersionVector.After$, VersionVector.Before$, VersionVector.Concurrent$, VersionVector.Ordering, VersionVector.Same$, VersionVector.Timestamp$

Constructor Summary

Constructors

Constructor and Description
ManyVersionVector(scala.collection.immutable.TreeMap<UniqueAddress,java.lang.Object> versions)

Method Summary

Modifier and Type	Method and Description
static boolean	$eq$eq(VersionVector that)
static boolean	$greater(VersionVector that)
static boolean	$less(VersionVector that)
static boolean	$less$greater(VersionVector that)
static VersionVector	$plus(Cluster node)
static VersionVector	$plus(UniqueAddress node)
abstract static boolean	canEqual(java.lang.Object that)
static VersionVector.Ordering	compareTo(VersionVector that)
boolean	contains(UniqueAddress node) INTERNAL API
abstract static boolean	equals(java.lang.Object that)
VersionVector	increment(UniqueAddress node) INTERNAL API
boolean	isEmpty()
VersionVector	merge(VersionVector that) Merges this VersionVector with another VersionVector.
boolean	needPruningFrom(UniqueAddress removedNode) Does it have any state changes from a specific node, which has been removed from the cluster.
abstract static int	productArity()
abstract static java.lang.Object	productElement(int n)
static scala.collection.Iterator<java.lang.Object>	productIterator()
static java.lang.String	productPrefix()
VersionVector	prune(UniqueAddress removedNode, UniqueAddress collapseInto) When the removed node has been removed from the cluster the state changes from that node will be pruned by collapsing the data entries to another node.
VersionVector	pruningCleanup(UniqueAddress removedNode) Remove data entries from a node that has been removed from the cluster and already been pruned.
int	size() INTERNAL API
java.lang.String	toString()
long	versionAt(UniqueAddress node) INTERNAL API
scala.collection.immutable.TreeMap<UniqueAddress,java.lang.Object>	versions()
scala.collection.Iterator<scala.Tuple2<UniqueAddress,java.lang.Object>>	versionsIterator() INTERNAL API

Methods inherited from class akka.cluster.ddata.VersionVector

AfterInstance, apply, apply, apply, apply, BeforeInstance, compareTo, ConcurrentInstance, create, empty, increment, SameInstance

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Methods inherited from interface akka.cluster.ddata.ReplicatedData

merge

Constructor Detail

ManyVersionVector

public ManyVersionVector(scala.collection.immutable.TreeMap<UniqueAddress,java.lang.Object> versions)

Method Detail

$plus

public static VersionVector $plus(Cluster node)

$plus

public static VersionVector $plus(UniqueAddress node)

$less$greater

public static boolean $less$greater(VersionVector that)

$less

public static boolean $less(VersionVector that)

$greater

public static boolean $greater(VersionVector that)

$eq$eq

public static boolean $eq$eq(VersionVector that)

compareTo

public static VersionVector.Ordering compareTo(VersionVector that)

canEqual

public abstract static boolean canEqual(java.lang.Object that)

equals

public abstract static boolean equals(java.lang.Object that)

productElement

public abstract static java.lang.Object productElement(int n)

productArity

public abstract static int productArity()

productIterator

public static scala.collection.Iterator<java.lang.Object> productIterator()

productPrefix

public static java.lang.String productPrefix()

versions

public scala.collection.immutable.TreeMap<UniqueAddress,java.lang.Object> versions()

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in class VersionVector

size

public int size()

INTERNAL API

Specified by:

size in class VersionVector

Returns:

(undocumented)

increment

public VersionVector increment(UniqueAddress node)

INTERNAL API

Specified by:

increment in class VersionVector

Parameters:

node - (undocumented)

Returns:

(undocumented)

versionAt

public long versionAt(UniqueAddress node)

INTERNAL API

Specified by:

versionAt in class VersionVector

Parameters:

node - (undocumented)

Returns:

(undocumented)

contains

public boolean contains(UniqueAddress node)

INTERNAL API

Specified by:

contains in class VersionVector

Parameters:

node - (undocumented)

Returns:

(undocumented)

versionsIterator

public scala.collection.Iterator<scala.Tuple2<UniqueAddress,java.lang.Object>> versionsIterator()

INTERNAL API

Specified by:

versionsIterator in class VersionVector

Returns:

(undocumented)

merge

public VersionVector merge(VersionVector that)

Description copied from class: VersionVector

Merges this VersionVector with another VersionVector. E.g. merges its versioned history.

Specified by:

merge in class VersionVector

Parameters:

that - (undocumented)

Returns:

(undocumented)

needPruningFrom

public boolean needPruningFrom(UniqueAddress removedNode)

Description copied from interface: RemovedNodePruning

Does it have any state changes from a specific node, which has been removed from the cluster.

Specified by:

needPruningFrom in interface RemovedNodePruning

Specified by:

needPruningFrom in class VersionVector

Parameters:

removedNode - (undocumented)

Returns:

(undocumented)

prune

public VersionVector prune(UniqueAddress removedNode,
                           UniqueAddress collapseInto)

Description copied from interface: RemovedNodePruning

When the removed node has been removed from the cluster the state changes from that node will be pruned by collapsing the data entries to another node.

Specified by:

prune in interface RemovedNodePruning

Specified by:

prune in class VersionVector

Parameters:

removedNode - (undocumented)

collapseInto - (undocumented)

Returns:

(undocumented)

pruningCleanup

public VersionVector pruningCleanup(UniqueAddress removedNode)

Description copied from interface: RemovedNodePruning

Remove data entries from a node that has been removed from the cluster and already been pruned.

Specified by:

pruningCleanup in interface RemovedNodePruning

Specified by:

pruningCleanup in class VersionVector

Parameters:

removedNode - (undocumented)

Returns:

(undocumented)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object