Package org.elasticsearch.common.io.stream
package org.elasticsearch.common.io.stream
Classes for streaming objects from one Elasticsearch node to another over its binary internode protocol.
-
ClassDescriptionResettable
StreamInputthat wraps a byte array.A @linkStreamOutputthat usesBigArraysto acquire pages of bytes, which avoids frequent reallocation & copying of the internal data.DelayableWriteable<T extends Writeable>A holder forWriteables that delays reading the underlying object on the receiving end.DelayableWriteable.Serialized<T extends Writeable>AWriteablestored in serialized form backed by aReleasableBytesReference.Wraps aStreamInputand delegates to it.AWriteableobject identified by its name.Wraps aStreamInputand associates it with aNamedWriteableRegistryA registry forWriteable.Readerreaders ofNamedWriteable.An entry in the registry, made up of a category class and name, and a reader for that category class.This exception can be used to wrap a given, not serializable exception to serialize viaStreamOutput.writeException(Throwable).An bytes stream output that allows providing aBigArraysinstance expecting it to require releasing its content (BytesStreamOutput.bytes()) once done.A stream from this node to another node.A stream from another node to this node.ANamedWriteablethat has a minimum version associated with it.Implementers can be written to a StreamOutput and read from a StreamInput.Reference to a method that can read some object from a stream.Reference to a method that can write some object to aStreamOutput.