Package akka.cluster.ddata
Class OneVersionVector
- java.lang.Object
-
- akka.cluster.ddata.VersionVector
-
- akka.cluster.ddata.OneVersionVector
-
- All Implemented Interfaces:
RemovedNodePruning
,ReplicatedData
,ReplicatedDataSerialization
,java.io.Serializable
,scala.Equals
,scala.Product
,scala.Serializable
public final class OneVersionVector 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 OneVersionVector(UniqueAddress node, long version)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static OneVersionVector
apply(UniqueAddress node, long version)
static double
apply$mcDDD$sp(double v1, double v2)
static double
apply$mcDDI$sp(double v1, int v2)
static double
apply$mcDDJ$sp(double v1, long v2)
static double
apply$mcDID$sp(int v1, double v2)
static double
apply$mcDII$sp(int v1, int v2)
static double
apply$mcDIJ$sp(int v1, long v2)
static double
apply$mcDJD$sp(long v1, double v2)
static double
apply$mcDJI$sp(long v1, int v2)
static double
apply$mcDJJ$sp(long v1, long v2)
static float
apply$mcFDD$sp(double v1, double v2)
static float
apply$mcFDI$sp(double v1, int v2)
static float
apply$mcFDJ$sp(double v1, long v2)
static float
apply$mcFID$sp(int v1, double v2)
static float
apply$mcFII$sp(int v1, int v2)
static float
apply$mcFIJ$sp(int v1, long v2)
static float
apply$mcFJD$sp(long v1, double v2)
static float
apply$mcFJI$sp(long v1, int v2)
static float
apply$mcFJJ$sp(long v1, long v2)
static int
apply$mcIDD$sp(double v1, double v2)
static int
apply$mcIDI$sp(double v1, int v2)
static int
apply$mcIDJ$sp(double v1, long v2)
static int
apply$mcIID$sp(int v1, double v2)
static int
apply$mcIII$sp(int v1, int v2)
static int
apply$mcIIJ$sp(int v1, long v2)
static int
apply$mcIJD$sp(long v1, double v2)
static int
apply$mcIJI$sp(long v1, int v2)
static int
apply$mcIJJ$sp(long v1, long v2)
static long
apply$mcJDD$sp(double v1, double v2)
static long
apply$mcJDI$sp(double v1, int v2)
static long
apply$mcJDJ$sp(double v1, long v2)
static long
apply$mcJID$sp(int v1, double v2)
static long
apply$mcJII$sp(int v1, int v2)
static long
apply$mcJIJ$sp(int v1, long v2)
static long
apply$mcJJD$sp(long v1, double v2)
static long
apply$mcJJI$sp(long v1, int v2)
static long
apply$mcJJJ$sp(long v1, long v2)
static void
apply$mcVDD$sp(double v1, double v2)
static void
apply$mcVDI$sp(double v1, int v2)
static void
apply$mcVDJ$sp(double v1, long v2)
static void
apply$mcVID$sp(int v1, double v2)
static void
apply$mcVII$sp(int v1, int v2)
static void
apply$mcVIJ$sp(int v1, long v2)
static void
apply$mcVJD$sp(long v1, double v2)
static void
apply$mcVJI$sp(long v1, int v2)
static void
apply$mcVJJ$sp(long v1, long v2)
static boolean
apply$mcZDD$sp(double v1, double v2)
static boolean
apply$mcZDI$sp(double v1, int v2)
static boolean
apply$mcZDJ$sp(double v1, long v2)
static boolean
apply$mcZID$sp(int v1, double v2)
static boolean
apply$mcZII$sp(int v1, int v2)
static boolean
apply$mcZIJ$sp(int v1, long v2)
static boolean
apply$mcZJD$sp(long v1, double v2)
static boolean
apply$mcZJI$sp(long v1, int v2)
static boolean
apply$mcZJJ$sp(long v1, long v2)
boolean
canEqual(java.lang.Object x$1)
boolean
contains(UniqueAddress n)
INTERNAL APIOneVersionVector
copy(UniqueAddress node, long version)
UniqueAddress
copy$default$1()
long
copy$default$2()
boolean
equals(java.lang.Object x$1)
int
hashCode()
VersionVector
increment(UniqueAddress n)
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.UniqueAddress
node()
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.Tuple2<UniqueAddress,java.lang.Object>>
unapply(OneVersionVector x$0)
long
version()
long
versionAt(UniqueAddress n)
INTERNAL APIscala.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
-
OneVersionVector
public OneVersionVector(UniqueAddress node, long version)
-
-
Method Detail
-
apply
public static OneVersionVector apply(UniqueAddress node, long version)
-
unapply
public static scala.Option<scala.Tuple2<UniqueAddress,java.lang.Object>> unapply(OneVersionVector x$0)
-
apply$mcZDD$sp
public static boolean apply$mcZDD$sp(double v1, double v2)
-
apply$mcDDD$sp
public static double apply$mcDDD$sp(double v1, double v2)
-
apply$mcFDD$sp
public static float apply$mcFDD$sp(double v1, double v2)
-
apply$mcIDD$sp
public static int apply$mcIDD$sp(double v1, double v2)
-
apply$mcJDD$sp
public static long apply$mcJDD$sp(double v1, double v2)
-
apply$mcVDD$sp
public static void apply$mcVDD$sp(double v1, double v2)
-
apply$mcZDI$sp
public static boolean apply$mcZDI$sp(double v1, int v2)
-
apply$mcDDI$sp
public static double apply$mcDDI$sp(double v1, int v2)
-
apply$mcFDI$sp
public static float apply$mcFDI$sp(double v1, int v2)
-
apply$mcIDI$sp
public static int apply$mcIDI$sp(double v1, int v2)
-
apply$mcJDI$sp
public static long apply$mcJDI$sp(double v1, int v2)
-
apply$mcVDI$sp
public static void apply$mcVDI$sp(double v1, int v2)
-
apply$mcZDJ$sp
public static boolean apply$mcZDJ$sp(double v1, long v2)
-
apply$mcDDJ$sp
public static double apply$mcDDJ$sp(double v1, long v2)
-
apply$mcFDJ$sp
public static float apply$mcFDJ$sp(double v1, long v2)
-
apply$mcIDJ$sp
public static int apply$mcIDJ$sp(double v1, long v2)
-
apply$mcJDJ$sp
public static long apply$mcJDJ$sp(double v1, long v2)
-
apply$mcVDJ$sp
public static void apply$mcVDJ$sp(double v1, long v2)
-
apply$mcZID$sp
public static boolean apply$mcZID$sp(int v1, double v2)
-
apply$mcDID$sp
public static double apply$mcDID$sp(int v1, double v2)
-
apply$mcFID$sp
public static float apply$mcFID$sp(int v1, double v2)
-
apply$mcIID$sp
public static int apply$mcIID$sp(int v1, double v2)
-
apply$mcJID$sp
public static long apply$mcJID$sp(int v1, double v2)
-
apply$mcVID$sp
public static void apply$mcVID$sp(int v1, double v2)
-
apply$mcZII$sp
public static boolean apply$mcZII$sp(int v1, int v2)
-
apply$mcDII$sp
public static double apply$mcDII$sp(int v1, int v2)
-
apply$mcFII$sp
public static float apply$mcFII$sp(int v1, int v2)
-
apply$mcIII$sp
public static int apply$mcIII$sp(int v1, int v2)
-
apply$mcJII$sp
public static long apply$mcJII$sp(int v1, int v2)
-
apply$mcVII$sp
public static void apply$mcVII$sp(int v1, int v2)
-
apply$mcZIJ$sp
public static boolean apply$mcZIJ$sp(int v1, long v2)
-
apply$mcDIJ$sp
public static double apply$mcDIJ$sp(int v1, long v2)
-
apply$mcFIJ$sp
public static float apply$mcFIJ$sp(int v1, long v2)
-
apply$mcIIJ$sp
public static int apply$mcIIJ$sp(int v1, long v2)
-
apply$mcJIJ$sp
public static long apply$mcJIJ$sp(int v1, long v2)
-
apply$mcVIJ$sp
public static void apply$mcVIJ$sp(int v1, long v2)
-
apply$mcZJD$sp
public static boolean apply$mcZJD$sp(long v1, double v2)
-
apply$mcDJD$sp
public static double apply$mcDJD$sp(long v1, double v2)
-
apply$mcFJD$sp
public static float apply$mcFJD$sp(long v1, double v2)
-
apply$mcIJD$sp
public static int apply$mcIJD$sp(long v1, double v2)
-
apply$mcJJD$sp
public static long apply$mcJJD$sp(long v1, double v2)
-
apply$mcVJD$sp
public static void apply$mcVJD$sp(long v1, double v2)
-
apply$mcZJI$sp
public static boolean apply$mcZJI$sp(long v1, int v2)
-
apply$mcDJI$sp
public static double apply$mcDJI$sp(long v1, int v2)
-
apply$mcFJI$sp
public static float apply$mcFJI$sp(long v1, int v2)
-
apply$mcIJI$sp
public static int apply$mcIJI$sp(long v1, int v2)
-
apply$mcJJI$sp
public static long apply$mcJJI$sp(long v1, int v2)
-
apply$mcVJI$sp
public static void apply$mcVJI$sp(long v1, int v2)
-
apply$mcZJJ$sp
public static boolean apply$mcZJJ$sp(long v1, long v2)
-
apply$mcDJJ$sp
public static double apply$mcDJJ$sp(long v1, long v2)
-
apply$mcFJJ$sp
public static float apply$mcFJJ$sp(long v1, long v2)
-
apply$mcIJJ$sp
public static int apply$mcIJJ$sp(long v1, long v2)
-
apply$mcJJJ$sp
public static long apply$mcJJJ$sp(long v1, long v2)
-
apply$mcVJJ$sp
public static void apply$mcVJJ$sp(long v1, long v2)
-
node
public UniqueAddress node()
-
version
public long version()
-
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 n)
INTERNAL API- Specified by:
increment
in classVersionVector
- Parameters:
n
- (undocumented)- Returns:
- (undocumented)
-
versionAt
public long versionAt(UniqueAddress n)
INTERNAL API- Specified by:
versionAt
in classVersionVector
- Parameters:
n
- (undocumented)- Returns:
- (undocumented)
-
contains
public boolean contains(UniqueAddress n)
INTERNAL API- Specified by:
contains
in classVersionVector
- Parameters:
n
- (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 OneVersionVector copy(UniqueAddress node, long version)
-
copy$default$1
public UniqueAddress copy$default$1()
-
copy$default$2
public long copy$default$2()
-
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
-
-