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
public final class OneVersionVector extends VersionVector implements scala.Product, java.io.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$
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static OneVersionVector
apply(UniqueAddress node, long version)
boolean
canEqual(java.lang.Object x$1)
OneVersionVector
copy(UniqueAddress node, long version)
UniqueAddress
copy$default$1()
long
copy$default$2()
boolean
equals(java.lang.Object x$1)
int
hashCode()
boolean
isEmpty()
VersionVector
merge(VersionVector that)
Merges this VersionVector with another VersionVector.scala.collection.immutable.Set<UniqueAddress>
modifiedByNodes()
The nodes that have changed the state for this data and would need pruning when such node is no longer part of the cluster.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)
java.lang.String
productElementName(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.java.lang.String
toString()
static scala.Option<scala.Tuple2<UniqueAddress,java.lang.Object>>
unapply(OneVersionVector x$0)
long
version()
-
Methods inherited from class akka.cluster.ddata.VersionVector
$colon$plus, $eq$eq, $greater, $less, $less$greater, AfterInstance, apply, apply, BeforeInstance, compareTo, ConcurrentInstance, create, empty, 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
-
-
-
-
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)
-
node
public UniqueAddress node()
-
version
public long version()
-
isEmpty
public boolean isEmpty()
- Specified by:
isEmpty
in classVersionVector
-
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
-
modifiedByNodes
public scala.collection.immutable.Set<UniqueAddress> modifiedByNodes()
Description copied from interface:RemovedNodePruning
The nodes that have changed the state for this data and would need pruning when such node is no longer part of the cluster.- 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
-
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
-
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
-
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
-
productElementName
public java.lang.String productElementName(int x$1)
- Specified by:
productElementName
in interfacescala.Product
-
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
-
-