Module org.elasticsearch.server

Package org.elasticsearch.common.io.stream

Class DelayableWriteable.Serialized<T extends Writeable>

java.lang.Object

org.elasticsearch.common.io.stream.DelayableWriteable<T>

org.elasticsearch.common.io.stream.DelayableWriteable.Serialized<T>

All Implemented Interfaces:

Closeable, AutoCloseable, Writeable, Releasable

Enclosing class:

DelayableWriteable<T extends Writeable>

public static class DelayableWriteable.Serialized<T extends Writeable>
extends DelayableWriteable<T>

A Writeable stored in serialized form backed by a ReleasableBytesReference. Once an instance is no longer used its backing memory must be manually released by invoking close() on it.

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.common.io.stream.DelayableWriteable

DelayableWriteable.Deduplicator, DelayableWriteable.Serialized<T extends Writeable>

Nested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable

Writeable.Reader<V>, Writeable.Writer<V>

Method Summary

Modifier and Type	Method	Description
DelayableWriteable.Serialized<T>	asSerialized(Writeable.Reader<T> reader, NamedWriteableRegistry registry)	Returns a DelayableWriteable that stores its contents in serialized form.
void	close()
T	expand()	Expands the inner Writeable to its original representation and returns it
long	getUncompressedSerializedSize()	Returns the uncompressed serialized size of the inner Writeable: the byte count it would have if written to a plain StreamOutput without compression.
boolean	isSerialized()	true if the Writeable is being stored in serialized form, false otherwise.
void	writeTo(StreamOutput out)	Write this into the StreamOutput.

Methods inherited from class org.elasticsearch.common.io.stream.DelayableWriteable

delayed, getUncompressedSerializedSize, referencing, referencing, wrapWithDeduplicatorStreamInput

Methods inherited from class java.lang.Object

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

Method Details

writeTo

public void writeTo(StreamOutput out)
             throws IOException

Description copied from interface: Writeable

Write this into the StreamOutput.

Throws:

IOException

expand

public T expand()

Description copied from class: DelayableWriteable

Expands the inner Writeable to its original representation and returns it

Specified by:

expand in class DelayableWriteable<T extends Writeable>

asSerialized

public DelayableWriteable.Serialized<T> asSerialized(Writeable.Reader<T> reader,
 NamedWriteableRegistry registry)

Description copied from class: DelayableWriteable

Returns a DelayableWriteable that stores its contents in serialized form.

Specified by:

asSerialized in class DelayableWriteable<T extends Writeable>

isSerialized

public boolean isSerialized()

Description copied from class: DelayableWriteable

true if the Writeable is being stored in serialized form, false otherwise.

Specified by:

isSerialized in class DelayableWriteable<T extends Writeable>

getUncompressedSerializedSize

public long getUncompressedSerializedSize()

Description copied from class: DelayableWriteable

Returns the uncompressed serialized size of the inner Writeable: the byte count it would have if written to a plain StreamOutput without compression.

Specified by:

getUncompressedSerializedSize in class DelayableWriteable<T extends Writeable>

close

public void close()