Package org.elasticsearch.cluster

Class DiffableUtils

java.lang.Object

org.elasticsearch.cluster.DiffableUtils

public final class DiffableUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DiffableUtils.DiffableValueReader<K,V extends Diffable<V>>	Implementation of the ValueSerializer that wraps value and diff readers.
static class	DiffableUtils.DiffableValueSerializer<K,V extends Diffable<V>>	Serializer for Diffable map values.
static class	DiffableUtils.ImmutableOpenMapDiff<K,T>	Represents differences between two ImmutableOpenMap of (possibly diffable) objects
static interface	DiffableUtils.KeySerializer<K>	Provides read and write operations to serialize keys of map
static class	DiffableUtils.MapDiff<K,T,M>	Represents differences between two maps of objects and is used as base class for different map implementations.
static class	DiffableUtils.NonDiffableValueSerializer<K,V>	Serializer for non-diffable map values
static class	DiffableUtils.StringSetValueSerializer<K>	Implementation of ValueSerializer that serializes immutable sets
static interface	DiffableUtils.ValueSerializer<K,V>	Provides read and write operations to serialize map values.

Method Summary

Modifier and Type	Method	Description
static <K, T extends Diffable<T>> DiffableUtils.MapDiff<K,T,Map<K,T>>	diff(Map<K,T> before, Map<K,T> after, DiffableUtils.KeySerializer<K> keySerializer)	Calculates diff between two Maps of Diffable objects.
static <K, T> DiffableUtils.MapDiff<K,T,Map<K,T>>	diff(Map<K,T> before, Map<K,T> after, DiffableUtils.KeySerializer<K> keySerializer, DiffableUtils.ValueSerializer<K,T> valueSerializer)	Calculates diff between two Maps of non-diffable objects
static <T extends Diffable<T>> DiffableUtils.MapDiff<Integer,T,ImmutableOpenIntMap<T>>	diff(ImmutableOpenIntMap<T> before, ImmutableOpenIntMap<T> after, DiffableUtils.KeySerializer<Integer> keySerializer)	Calculates diff between two ImmutableOpenIntMaps of Diffable objects
static <T> DiffableUtils.MapDiff<Integer,T,ImmutableOpenIntMap<T>>	diff(ImmutableOpenIntMap<T> before, ImmutableOpenIntMap<T> after, DiffableUtils.KeySerializer<Integer> keySerializer, DiffableUtils.ValueSerializer<Integer,T> valueSerializer)	Calculates diff between two ImmutableOpenIntMaps of non-diffable objects
static <K, T extends Diffable<T>> DiffableUtils.MapDiff<K,T,ImmutableOpenMap<K,T>>	diff(ImmutableOpenMap<K,T> before, ImmutableOpenMap<K,T> after, DiffableUtils.KeySerializer<K> keySerializer)	Calculates diff between two ImmutableOpenMaps of Diffable objects
static <K, T> DiffableUtils.MapDiff<K,T,ImmutableOpenMap<K,T>>	diff(ImmutableOpenMap<K,T> before, ImmutableOpenMap<K,T> after, DiffableUtils.KeySerializer<K> keySerializer, DiffableUtils.ValueSerializer<K,T> valueSerializer)	Calculates diff between two ImmutableOpenMaps of non-diffable objects
static DiffableUtils.KeySerializer<Integer>	getIntKeySerializer()	Returns a map key serializer for Integer keys.
static DiffableUtils.KeySerializer<String>	getStringKeySerializer()	Returns a map key serializer for String keys
static DiffableUtils.KeySerializer<Integer>	getVIntKeySerializer()	Returns a map key serializer for Integer keys.
static <T> DiffableUtils.MapDiff<Integer,T,ImmutableOpenIntMap<T>>	readImmutableOpenIntMapDiff(StreamInput in, DiffableUtils.KeySerializer<Integer> keySerializer, DiffableUtils.ValueSerializer<Integer,T> valueSerializer)	Loads an object that represents difference between two ImmutableOpenMaps
static <T extends Diffable<T>> DiffableUtils.MapDiff<Integer,T,ImmutableOpenIntMap<T>>	readImmutableOpenIntMapDiff(StreamInput in, DiffableUtils.KeySerializer<Integer> keySerializer, Writeable.Reader<T> reader, Writeable.Reader<Diff<T>> diffReader)	Loads an object that represents difference between two ImmutableOpenIntMaps of Diffable objects using Diffable proto object
static <K, T extends Diffable<T>> DiffableUtils.MapDiff<K,T,ImmutableOpenMap<K,T>>	readImmutableOpenMapDiff(StreamInput in, DiffableUtils.KeySerializer<K> keySerializer, DiffableUtils.DiffableValueReader<K,T> diffableValueReader)	Loads an object that represents difference between two ImmutableOpenMaps of Diffable objects using Diffable proto object
static <K, T> DiffableUtils.MapDiff<K,T,ImmutableOpenMap<K,T>>	readImmutableOpenMapDiff(StreamInput in, DiffableUtils.KeySerializer<K> keySerializer, DiffableUtils.ValueSerializer<K,T> valueSerializer)	Loads an object that represents difference between two ImmutableOpenMaps
static <K, T> DiffableUtils.MapDiff<K,T,Map<K,T>>	readJdkMapDiff(StreamInput in, DiffableUtils.KeySerializer<K> keySerializer, DiffableUtils.ValueSerializer<K,T> valueSerializer)	Loads an object that represents difference between two Maps of Diffable objects
static <K, T extends Diffable<T>> DiffableUtils.MapDiff<K,T,Map<K,T>>	readJdkMapDiff(StreamInput in, DiffableUtils.KeySerializer<K> keySerializer, Writeable.Reader<T> reader, Writeable.Reader<Diff<T>> diffReader)	Loads an object that represents difference between two Maps of Diffable objects using Diffable proto object

Methods inherited from class java.lang.Object

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

Method Details

getStringKeySerializer

public static DiffableUtils.KeySerializer<String> getStringKeySerializer()

Returns a map key serializer for String keys

getIntKeySerializer

public static DiffableUtils.KeySerializer<Integer> getIntKeySerializer()

Returns a map key serializer for Integer keys. Encodes as Int.

getVIntKeySerializer

public static DiffableUtils.KeySerializer<Integer> getVIntKeySerializer()

Returns a map key serializer for Integer keys. Encodes as VInt.

diff

public static <K,
T extends Diffable<T>>
DiffableUtils.MapDiff<K,T,ImmutableOpenMap<K,T>> diff(ImmutableOpenMap<K,T> before,
 ImmutableOpenMap<K,T> after,
 DiffableUtils.KeySerializer<K> keySerializer)

Calculates diff between two ImmutableOpenMaps of Diffable objects

diff

public static <K,
T>
DiffableUtils.MapDiff<K,T,ImmutableOpenMap<K,T>> diff(ImmutableOpenMap<K,T> before,
 ImmutableOpenMap<K,T> after,
 DiffableUtils.KeySerializer<K> keySerializer,
 DiffableUtils.ValueSerializer<K,T> valueSerializer)

Calculates diff between two ImmutableOpenMaps of non-diffable objects

diff

public static <T extends Diffable<T>>
DiffableUtils.MapDiff<Integer,T,ImmutableOpenIntMap<T>> diff(ImmutableOpenIntMap<T> before,
 ImmutableOpenIntMap<T> after,
 DiffableUtils.KeySerializer<Integer> keySerializer)

Calculates diff between two ImmutableOpenIntMaps of Diffable objects

diff

public static <T>
DiffableUtils.MapDiff<Integer,T,ImmutableOpenIntMap<T>> diff(ImmutableOpenIntMap<T> before,
 ImmutableOpenIntMap<T> after,
 DiffableUtils.KeySerializer<Integer> keySerializer,
 DiffableUtils.ValueSerializer<Integer,T> valueSerializer)

Calculates diff between two ImmutableOpenIntMaps of non-diffable objects

diff

public static <K,
T extends Diffable<T>>
DiffableUtils.MapDiff<K,T,Map<K,T>> diff(Map<K,T> before,
 Map<K,T> after,
 DiffableUtils.KeySerializer<K> keySerializer)

Calculates diff between two Maps of Diffable objects.

diff

public static <K,
T>
DiffableUtils.MapDiff<K,T,Map<K,T>> diff(Map<K,T> before,
 Map<K,T> after,
 DiffableUtils.KeySerializer<K> keySerializer,
 DiffableUtils.ValueSerializer<K,T> valueSerializer)

Calculates diff between two Maps of non-diffable objects

readImmutableOpenMapDiff

public static <K,
T>
DiffableUtils.MapDiff<K,T,ImmutableOpenMap<K,T>> readImmutableOpenMapDiff(StreamInput in,
 DiffableUtils.KeySerializer<K> keySerializer,
 DiffableUtils.ValueSerializer<K,T> valueSerializer)
                                                                   throws IOException

Loads an object that represents difference between two ImmutableOpenMaps

Throws:

IOException

readImmutableOpenIntMapDiff

public static <T>
DiffableUtils.MapDiff<Integer,T,ImmutableOpenIntMap<T>> readImmutableOpenIntMapDiff(StreamInput in,
 DiffableUtils.KeySerializer<Integer> keySerializer,
 DiffableUtils.ValueSerializer<Integer,T> valueSerializer)
                                                                             throws IOException

Loads an object that represents difference between two ImmutableOpenMaps

Throws:

IOException

readJdkMapDiff

public static <K,
T>
DiffableUtils.MapDiff<K,T,Map<K,T>> readJdkMapDiff(StreamInput in,
 DiffableUtils.KeySerializer<K> keySerializer,
 DiffableUtils.ValueSerializer<K,T> valueSerializer)
                                            throws IOException

Loads an object that represents difference between two Maps of Diffable objects

Throws:

IOException

readImmutableOpenMapDiff

public static <K,
T extends Diffable<T>>
DiffableUtils.MapDiff<K,T,ImmutableOpenMap<K,T>> readImmutableOpenMapDiff(StreamInput in,
 DiffableUtils.KeySerializer<K> keySerializer,
 DiffableUtils.DiffableValueReader<K,T> diffableValueReader)
                                                                   throws IOException

Loads an object that represents difference between two ImmutableOpenMaps of Diffable objects using Diffable proto object

Throws:

IOException

readImmutableOpenIntMapDiff

public static <T extends Diffable<T>>
DiffableUtils.MapDiff<Integer,T,ImmutableOpenIntMap<T>> readImmutableOpenIntMapDiff(StreamInput in,
 DiffableUtils.KeySerializer<Integer> keySerializer,
 Writeable.Reader<T> reader,
 Writeable.Reader<Diff<T>> diffReader)
                                                                             throws IOException

Loads an object that represents difference between two ImmutableOpenIntMaps of Diffable objects using Diffable proto object

Throws:

IOException

readJdkMapDiff

public static <K,
T extends Diffable<T>>
DiffableUtils.MapDiff<K,T,Map<K,T>> readJdkMapDiff(StreamInput in,
 DiffableUtils.KeySerializer<K> keySerializer,
 Writeable.Reader<T> reader,
 Writeable.Reader<Diff<T>> diffReader)
                                            throws IOException

Loads an object that represents difference between two Maps of Diffable objects using Diffable proto object

Throws:

IOException