Package 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
,scala.Serializable
public final class ManyVersionVector extends VersionVector implements scala.Product, scala.Serializable
INTERNAL API- 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 Description ManyVersionVector(scala.collection.immutable.TreeMap<UniqueAddress,java.lang.Object> versions)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static ManyVersionVector
apply(scala.collection.immutable.TreeMap<UniqueAddress,java.lang.Object> versions)
static double
apply$mcDD$sp(double v1)
static double
apply$mcDF$sp(float v1)
static double
apply$mcDI$sp(int v1)
static double
apply$mcDJ$sp(long v1)
static float
apply$mcFD$sp(double v1)
static float
apply$mcFF$sp(float v1)
static float
apply$mcFI$sp(int v1)
static float
apply$mcFJ$sp(long v1)
static int
apply$mcID$sp(double v1)
static int
apply$mcIF$sp(float v1)
static int
apply$mcII$sp(int v1)
static int
apply$mcIJ$sp(long v1)
static long
apply$mcJD$sp(double v1)
static long
apply$mcJF$sp(float v1)
static long
apply$mcJI$sp(int v1)
static long
apply$mcJJ$sp(long v1)
static void
apply$mcVD$sp(double v1)
static void
apply$mcVF$sp(float v1)
static void
apply$mcVI$sp(int v1)
static void
apply$mcVJ$sp(long v1)
static boolean
apply$mcZD$sp(double v1)
static boolean
apply$mcZF$sp(float v1)
static boolean
apply$mcZI$sp(int v1)
static boolean
apply$mcZJ$sp(long v1)
boolean
canEqual(java.lang.Object x$1)
boolean
contains(UniqueAddress node)
INTERNAL APIManyVersionVector
copy(scala.collection.immutable.TreeMap<UniqueAddress,java.lang.Object> versions)
scala.collection.immutable.TreeMap<UniqueAddress,java.lang.Object>
copy$default$1()
boolean
equals(java.lang.Object x$1)
int
hashCode()
VersionVector
increment(UniqueAddress node)
INTERNAL APIboolean
isEmpty()
VersionVector
merge(VersionVector that)
Merges this VersionVector with another VersionVector.scala.collection.immutable.Set<UniqueAddress>
modifiedByNodes()
boolean
needPruningFrom(UniqueAddress removedNode)
Does it have any state changes from a specific node, which has been removed from the cluster.int
productArity()
java.lang.Object
productElement(int x$1)
scala.collection.Iterator<java.lang.Object>
productIterator()
java.lang.String
productPrefix()
VersionVector
prune(UniqueAddress removedNode, UniqueAddress collapseInto)
When theremoved
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 APIjava.lang.String
toString()
static scala.Option<scala.collection.immutable.TreeMap<UniqueAddress,java.lang.Object>>
unapply(ManyVersionVector x$0)
long
versionAt(UniqueAddress node)
INTERNAL APIscala.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
$colon$plus, $eq$eq, $greater, $less, $less$greater, $plus, $plus, AfterInstance, apply, apply, apply, BeforeInstance, compareTo, ConcurrentInstance, create, empty, increment, increment, SameInstance
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
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
-
apply
public static ManyVersionVector apply(scala.collection.immutable.TreeMap<UniqueAddress,java.lang.Object> versions)
-
unapply
public static scala.Option<scala.collection.immutable.TreeMap<UniqueAddress,java.lang.Object>> unapply(ManyVersionVector x$0)
-
apply$mcZD$sp
public static boolean apply$mcZD$sp(double v1)
-
apply$mcDD$sp
public static double apply$mcDD$sp(double v1)
-
apply$mcFD$sp
public static float apply$mcFD$sp(double v1)
-
apply$mcID$sp
public static int apply$mcID$sp(double v1)
-
apply$mcJD$sp
public static long apply$mcJD$sp(double v1)
-
apply$mcVD$sp
public static void apply$mcVD$sp(double v1)
-
apply$mcZF$sp
public static boolean apply$mcZF$sp(float v1)
-
apply$mcDF$sp
public static double apply$mcDF$sp(float v1)
-
apply$mcFF$sp
public static float apply$mcFF$sp(float v1)
-
apply$mcIF$sp
public static int apply$mcIF$sp(float v1)
-
apply$mcJF$sp
public static long apply$mcJF$sp(float v1)
-
apply$mcVF$sp
public static void apply$mcVF$sp(float v1)
-
apply$mcZI$sp
public static boolean apply$mcZI$sp(int v1)
-
apply$mcDI$sp
public static double apply$mcDI$sp(int v1)
-
apply$mcFI$sp
public static float apply$mcFI$sp(int v1)
-
apply$mcII$sp
public static int apply$mcII$sp(int v1)
-
apply$mcJI$sp
public static long apply$mcJI$sp(int v1)
-
apply$mcVI$sp
public static void apply$mcVI$sp(int v1)
-
apply$mcZJ$sp
public static boolean apply$mcZJ$sp(long v1)
-
apply$mcDJ$sp
public static double apply$mcDJ$sp(long v1)
-
apply$mcFJ$sp
public static float apply$mcFJ$sp(long v1)
-
apply$mcIJ$sp
public static int apply$mcIJ$sp(long v1)
-
apply$mcJJ$sp
public static long apply$mcJJ$sp(long v1)
-
apply$mcVJ$sp
public static void apply$mcVJ$sp(long v1)
-
versions
public scala.collection.immutable.TreeMap<UniqueAddress,java.lang.Object> versions()
-
isEmpty
public boolean isEmpty()
- Specified by:
isEmpty
in classVersionVector
-
size
public int size()
INTERNAL API- Specified by:
size
in classVersionVector
- Returns:
- (undocumented)
-
increment
public VersionVector increment(UniqueAddress node)
INTERNAL API- Specified by:
increment
in classVersionVector
- Parameters:
node
- (undocumented)- Returns:
- (undocumented)
-
versionAt
public long versionAt(UniqueAddress node)
INTERNAL API- Specified by:
versionAt
in classVersionVector
- Parameters:
node
- (undocumented)- Returns:
- (undocumented)
-
contains
public boolean contains(UniqueAddress node)
INTERNAL API- Specified by:
contains
in classVersionVector
- Parameters:
node
- (undocumented)- Returns:
- (undocumented)
-
versionsIterator
public scala.collection.Iterator<scala.Tuple2<UniqueAddress,java.lang.Object>> versionsIterator()
INTERNAL API- Specified by:
versionsIterator
in classVersionVector
- 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 classVersionVector
- Parameters:
that
- (undocumented)- Returns:
- (undocumented)
-
modifiedByNodes
public scala.collection.immutable.Set<UniqueAddress> modifiedByNodes()
- Specified by:
modifiedByNodes
in interfaceRemovedNodePruning
-
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 interfaceRemovedNodePruning
- Specified by:
needPruningFrom
in classVersionVector
- Parameters:
removedNode
- (undocumented)- Returns:
- (undocumented)
-
prune
public VersionVector prune(UniqueAddress removedNode, UniqueAddress collapseInto)
Description copied from interface:RemovedNodePruning
When theremoved
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 interfaceRemovedNodePruning
- Specified by:
prune
in classVersionVector
- 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 interfaceRemovedNodePruning
- Specified by:
pruningCleanup
in classVersionVector
- Parameters:
removedNode
- (undocumented)- Returns:
- (undocumented)
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
copy
public ManyVersionVector copy(scala.collection.immutable.TreeMap<UniqueAddress,java.lang.Object> versions)
-
copy$default$1
public scala.collection.immutable.TreeMap<UniqueAddress,java.lang.Object> copy$default$1()
-
productPrefix
public java.lang.String productPrefix()
- Specified by:
productPrefix
in interfacescala.Product
-
productArity
public int productArity()
- Specified by:
productArity
in interfacescala.Product
-
productElement
public java.lang.Object productElement(int x$1)
- Specified by:
productElement
in interfacescala.Product
-
productIterator
public scala.collection.Iterator<java.lang.Object> productIterator()
- Specified by:
productIterator
in interfacescala.Product
-
canEqual
public boolean canEqual(java.lang.Object x$1)
- Specified by:
canEqual
in interfacescala.Equals
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object x$1)
- Specified by:
equals
in interfacescala.Equals
- Overrides:
equals
in classjava.lang.Object
-
-