Module org.elasticsearch.server

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 interface	DiffableUtils.KeySerializer<K>	Provides read and write operations to serialize keys of map
static class	DiffableUtils.MapDiff<K,T,M extends Map<K,T>>	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>, M extends Map<K, T>> DiffableUtils.MapDiff<K,T,M>	diff(M before, M after, DiffableUtils.KeySerializer<K> keySerializer)	Calculates diff between two Maps of Diffable objects.
static <K, T, M extends Map<K, T>> DiffableUtils.MapDiff<K,T,M>	diff(M before, M after, DiffableUtils.KeySerializer<K> keySerializer, DiffableUtils.ValueSerializer<K,T> valueSerializer)	Calculates diff between two Maps of non-diffable objects
static <K, T, M extends Map<K, T>> DiffableUtils.MapDiff<K,T,M>	emptyDiff()
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 <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>,
M extends Map<K,
T>>
DiffableUtils.MapDiff<K,T,M> diff(M before,
 M after,
 DiffableUtils.KeySerializer<K> keySerializer)

Calculates diff between two Maps of Diffable objects.

diff

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

Calculates diff between two Maps of non-diffable objects

emptyDiff

public static <K,
T,
M extends Map<K,
T>>
DiffableUtils.MapDiff<K,T,M> emptyDiff()

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

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

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