akka.persistence.multidc.crdt

Class ORSet$

java.lang.Object

akka.persistence.multidc.crdt.ORSet$

All Implemented Interfaces:

java.io.Serializable

public class ORSet$
extends java.lang.Object
implements scala.Serializable

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static ORSet$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
ORSet$()

Method Summary

Modifier and Type	Method and Description
<A> ORSet<A>	apply(java.lang.String originDc)
<A> ORSet<A>	create(java.lang.String originDc) Java API
<A> ORSet<A>	empty(java.lang.String originDc)
<A> scala.collection.immutable.Map<A,VersionVector>	mergeCommonKeys(scala.collection.immutable.Set<A> commonKeys, ORSet<A> lhs, ORSet<A> rhs) INTERNAL API
<A> scala.collection.immutable.Map<A,VersionVector>	mergeDisjointKeys(scala.collection.immutable.Set<A> keys, scala.collection.immutable.Map<A,VersionVector> elementsMap, VersionVector vvector, scala.collection.immutable.Map<A,VersionVector> accumulator) INTERNAL API
VersionVector	subtractDots(VersionVector dot, VersionVector vvector) INTERNAL API Subtract the vvector from the dot.
<A> scala.Option<scala.collection.immutable.Set<A>>	unapply(ORSet<A> s) Extract the ORSet.elements().

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MODULE$

public static final ORSet$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

ORSet$

public ORSet$()

Method Detail

empty

public <A> ORSet<A> empty(java.lang.String originDc)

apply

public <A> ORSet<A> apply(java.lang.String originDc)

create

public <A> ORSet<A> create(java.lang.String originDc)

Java API

Parameters:

originDc - (undocumented)

Returns:

(undocumented)

unapply

public <A> scala.Option<scala.collection.immutable.Set<A>> unapply(ORSet<A> s)

Extract the ORSet.elements().

Parameters:

s - (undocumented)

Returns:

(undocumented)

subtractDots

public VersionVector subtractDots(VersionVector dot,
                                  VersionVector vvector)

INTERNAL API Subtract the vvector from the dot. What this means is that any (dc, version) pair in dot that is <= an entry in vvector is removed from dot. Example [{a, 3}, {b, 2}, {d, 14}, {g, 22}] - [{a, 4}, {b, 1}, {c, 1}, {d, 14}, {e, 5}, {f, 2}] = [{b, 2}, {g, 22}]

Parameters:

dot - (undocumented)

vvector - (undocumented)

Returns:

(undocumented)

mergeCommonKeys

public <A> scala.collection.immutable.Map<A,VersionVector> mergeCommonKeys(scala.collection.immutable.Set<A> commonKeys,
                                                                           ORSet<A> lhs,
                                                                           ORSet<A> rhs)

INTERNAL API

Parameters:

commonKeys - (undocumented)

lhs - (undocumented)

rhs - (undocumented)

Returns:

(undocumented)

See Also:

ORSet#merge

mergeDisjointKeys

public <A> scala.collection.immutable.Map<A,VersionVector> mergeDisjointKeys(scala.collection.immutable.Set<A> keys,
                                                                             scala.collection.immutable.Map<A,VersionVector> elementsMap,
                                                                             VersionVector vvector,
                                                                             scala.collection.immutable.Map<A,VersionVector> accumulator)

INTERNAL API

Parameters:

keys - (undocumented)

elementsMap - (undocumented)

vvector - (undocumented)

accumulator - (undocumented)

Returns:

(undocumented)

See Also:

ORSet#merge