java.lang.Object
org.elasticsearch.cluster.DiffableUtils
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classDiffableUtils.DiffableValueReader<K,V extends Diffable<V>> Implementation of the ValueSerializer that wraps value and diff readers.static classDiffableUtils.DiffableValueSerializer<K,V extends Diffable<V>> Serializer for Diffable map values.static interfaceProvides read and write operations to serialize keys of mapstatic classRepresents differences between two maps of objects and is used as base class for different map implementations.static classSerializer for non-diffable map valuesstatic classImplementation of ValueSerializer that serializes immutable setsstatic interfaceProvides read and write operations to serialize map values. -
Method Summary
Modifier and TypeMethodDescriptionstatic <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 objectsstatic <K,T, M extends Map<K, T>>
DiffableUtils.MapDiff<K, T, M> static DiffableUtils.KeySerializer<Integer> Returns a map key serializer for Integer keys.static DiffableUtils.KeySerializer<String> Returns a map key serializer for String keysstatic DiffableUtils.KeySerializer<Integer> 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 objectstatic <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 ImmutableOpenMapsstatic <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 objectsstatic <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
-
Method Details
-
getStringKeySerializer
Returns a map key serializer for String keys -
getIntKeySerializer
Returns a map key serializer for Integer keys. Encodes as Int. -
getVIntKeySerializer
Returns a map key serializer for Integer keys. Encodes as VInt. -
diff
public static <K,T extends Diffable<T>, DiffableUtils.MapDiff<K,M extends Map<K, T>> T, diffM> (M before, M after, DiffableUtils.KeySerializer<K> keySerializer) Calculates diff between two Maps of Diffable objects. -
diff
public static <K,T, DiffableUtils.MapDiff<K,M extends Map<K, T>> T, diffM> (M before, M after, DiffableUtils.KeySerializer<K> keySerializer, DiffableUtils.ValueSerializer<K, T> valueSerializer) Calculates diff between two Maps of non-diffable objects -
emptyDiff
-
readImmutableOpenMapDiff
public static <K,T> DiffableUtils.MapDiff<K,T, readImmutableOpenMapDiffImmutableOpenMap<K, T>> (StreamInput in, DiffableUtils.KeySerializer<K> keySerializer, DiffableUtils.ValueSerializer<K, T> valueSerializer) throws IOExceptionLoads an object that represents difference between two ImmutableOpenMaps- Throws:
IOException
-
readJdkMapDiff
public static <K,T> DiffableUtils.MapDiff<K,T, readJdkMapDiffMap<K, T>> (StreamInput in, DiffableUtils.KeySerializer<K> keySerializer, DiffableUtils.ValueSerializer<K, T> valueSerializer) throws IOExceptionLoads 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, readImmutableOpenMapDiffImmutableOpenMap<K, T>> (StreamInput in, DiffableUtils.KeySerializer<K> keySerializer, DiffableUtils.DiffableValueReader<K, T> diffableValueReader) throws IOExceptionLoads 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, readJdkMapDiffMap<K, T>> (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
-