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 OneVersionVectorapply(UniqueAddress node, long version)booleancanEqual(java.lang.Object x$1)OneVersionVectorcopy(UniqueAddress node, long version)UniqueAddresscopy$default$1()longcopy$default$2()booleanequals(java.lang.Object x$1)inthashCode()booleanisEmpty()VersionVectormerge(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.booleanneedPruningFrom(UniqueAddress removedNode)Does it have any state changes from a specific node, which has been removed from the cluster.UniqueAddressnode()intproductArity()java.lang.ObjectproductElement(int x$1)java.lang.StringproductElementName(int x$1)scala.collection.Iterator<java.lang.Object>productIterator()java.lang.StringproductPrefix()VersionVectorprune(UniqueAddress removedNode, UniqueAddress collapseInto)When theremovednode has been removed from the cluster the state changes from that node will be pruned by collapsing the data entries to another node.VersionVectorpruningCleanup(UniqueAddress removedNode)Remove data entries from a node that has been removed from the cluster and already been pruned.java.lang.StringtoString()static scala.Option<scala.Tuple2<UniqueAddress,java.lang.Object>>unapply(OneVersionVector x$0)longversion()-
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:
isEmptyin classVersionVector
-
merge
public VersionVector merge(VersionVector that)
Description copied from class:VersionVectorMerges this VersionVector with another VersionVector. E.g. merges its versioned history.- Specified by:
mergein classVersionVector
-
modifiedByNodes
public scala.collection.immutable.Set<UniqueAddress> modifiedByNodes()
Description copied from interface:RemovedNodePruningThe 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:
modifiedByNodesin interfaceRemovedNodePruning
-
needPruningFrom
public boolean needPruningFrom(UniqueAddress removedNode)
Description copied from interface:RemovedNodePruningDoes it have any state changes from a specific node, which has been removed from the cluster.- Specified by:
needPruningFromin interfaceRemovedNodePruning- Specified by:
needPruningFromin classVersionVector
-
prune
public VersionVector prune(UniqueAddress removedNode, UniqueAddress collapseInto)
Description copied from interface:RemovedNodePruningWhen theremovednode 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:
prunein interfaceRemovedNodePruning- Specified by:
prunein classVersionVector
-
pruningCleanup
public VersionVector pruningCleanup(UniqueAddress removedNode)
Description copied from interface:RemovedNodePruningRemove data entries from a node that has been removed from the cluster and already been pruned.- Specified by:
pruningCleanupin interfaceRemovedNodePruning- Specified by:
pruningCleanupin classVersionVector
-
toString
public java.lang.String toString()
- Overrides:
toStringin 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:
productPrefixin interfacescala.Product
-
productArity
public int productArity()
- Specified by:
productArityin interfacescala.Product
-
productElement
public java.lang.Object productElement(int x$1)
- Specified by:
productElementin interfacescala.Product
-
productIterator
public scala.collection.Iterator<java.lang.Object> productIterator()
- Specified by:
productIteratorin interfacescala.Product
-
canEqual
public boolean canEqual(java.lang.Object x$1)
- Specified by:
canEqualin interfacescala.Equals
-
productElementName
public java.lang.String productElementName(int x$1)
- Specified by:
productElementNamein interfacescala.Product
-
hashCode
public int hashCode()
- Overrides:
hashCodein classjava.lang.Object
-
equals
public boolean equals(java.lang.Object x$1)
- Specified by:
equalsin interfacescala.Equals- Overrides:
equalsin classjava.lang.Object
-
-