Package akka.cluster.ddata
Class ORMap.AtomicDeltaOp<A,B extends ReplicatedData>
- java.lang.Object
-
- akka.cluster.ddata.ORMap.AtomicDeltaOp<A,B>
-
- All Implemented Interfaces:
ORMap.DeltaOp
,ReplicatedData
,ReplicatedDataSerialization
,ReplicatedDelta
,ReplicatedDeltaSize
,RequiresCausalDeliveryOfDeltas
,java.io.Serializable
- Direct Known Subclasses:
ORMap.PutDeltaOp
,ORMap.RemoveDeltaOp
,ORMap.RemoveKeyDeltaOp
,ORMap.UpdateDeltaOp
- Enclosing class:
- ORMap<A,B extends ReplicatedData>
public abstract static class ORMap.AtomicDeltaOp<A,B extends ReplicatedData> extends java.lang.Object implements ORMap.DeltaOp, ReplicatedDeltaSize
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description AtomicDeltaOp()
Implements a 'Observed Remove Map' CRDT, also called a 'OR-Map'.
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description int
deltaSize()
ORMap.DeltaOp
merge(ORMap.DeltaOp that)
abstract ORSet.DeltaOp
underlying()
DeltaReplicatedData
zero()
The empty full state.abstract ORMap.ZeroTag
zeroTag()
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface akka.cluster.ddata.ReplicatedData
merge
-
-
-
-
Constructor Detail
-
AtomicDeltaOp
public AtomicDeltaOp()
Implements a 'Observed Remove Map' CRDT, also called a 'OR-Map'.It has similar semantics as an
ORSet
, but in case of concurrent updates the values are merged, and must therefore beReplicatedData
types themselves.This class is immutable, i.e. "modifying" methods return a new instance.
-
-
Method Detail
-
deltaSize
public int deltaSize()
- Specified by:
deltaSize
in interfaceReplicatedDeltaSize
-
merge
public ORMap.DeltaOp merge(ORMap.DeltaOp that)
-
underlying
public abstract ORSet.DeltaOp underlying()
-
zero
public DeltaReplicatedData zero()
Description copied from interface:ReplicatedDelta
The empty full state. This is used when a delta is received and no existing full state exists on the receiving side. Then the delta is merged into thezero
to create the initial full state.- Specified by:
zero
in interfaceORMap.DeltaOp
- Specified by:
zero
in interfaceReplicatedDelta
-
zeroTag
public abstract ORMap.ZeroTag zeroTag()
-
-