Package org.elasticsearch.cluster

Class DiffableUtils.DiffableValueReader<K,V extends Diffable<V>>

java.lang.Object

org.elasticsearch.cluster.DiffableUtils.DiffableValueSerializer<K,V>

org.elasticsearch.cluster.DiffableUtils.DiffableValueReader<K,V>

All Implemented Interfaces:

DiffableUtils.ValueSerializer<K,V>

Enclosing class:

DiffableUtils

public static class DiffableUtils.DiffableValueReader<K,V extends Diffable<V>>
extends DiffableUtils.DiffableValueSerializer<K,V>

Implementation of the ValueSerializer that wraps value and diff readers. Note: this implementation is ignoring the key.

Constructor Summary

Constructors

Constructor	Description
DiffableValueReader(Writeable.Reader<V> reader, Writeable.Reader<Diff<V>> diffReader)

Method Summary

Modifier and Type	Method	Description
V	read(StreamInput in, K key)	Reads value from stream.
Diff<V>	readDiff(StreamInput in, K key)	Reads value as diff from stream if this serializer supports diffable values.

Methods inherited from class org.elasticsearch.cluster.DiffableUtils.DiffableValueSerializer

diff, supportsDiffableValues, write, writeDiff

Methods inherited from interface org.elasticsearch.cluster.DiffableUtils.ValueSerializer

supportsVersion, supportsVersion

Methods inherited from class java.lang.Object

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

Constructor Detail

DiffableValueReader

public DiffableValueReader(Writeable.Reader<V> reader,
                           Writeable.Reader<Diff<V>> diffReader)

Method Detail

read

public V read(StreamInput in,
              K key)
       throws java.io.IOException

Description copied from interface: DiffableUtils.ValueSerializer

Reads value from stream. Reading operation can be made dependent on map key.

Throws:

java.io.IOException

readDiff

public Diff<V> readDiff(StreamInput in,
                        K key)
                 throws java.io.IOException

Description copied from interface: DiffableUtils.ValueSerializer

Reads value as diff from stream if this serializer supports diffable values. Reading operation can be made dependent on map key.

Throws:

java.io.IOException