Module org.elasticsearch.server
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.
-
ClassDescriptionAdapts a raw
OutputStreaminto a richStreamOutputfor use withWriteableinstances, using a buffer.ResettableStreamInputthat wraps a byte array.A @linkStreamOutputthat is backed by aBytesRef.A @linkStreamOutputthat accumulates the resulting data in memory, usingBigArraysto avoids frequent reallocation & copying of the internal data once the resulting data grows large enough whilst avoiding excessive overhead in the final result for small objects.A reusable @linkStreamOutputthat just count how many bytes are written.DelayableWriteable<T extends Writeable>A holder forWriteables that delays reading the underlying object on the receiving end.An object implementing this interface can deduplicate instance of the provided objects.DelayableWriteable.Serialized<T extends Writeable>AWriteablestored in serialized form backed by aReleasableBytesReference.Wraps aStreamInputand delegates to it.Marker interface that allows specific NamedWritable objects to be serialized as part of the generic serialization in StreamOutput and StreamInput.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).A @linkStreamOutputthat uses aRecycler<org.apache.lucene.util.BytesRef>to acquire pages of bytes, which avoids frequent reallocation & copying of the internal data.A @linkStreamOutputthat accumulates the resulting data in memory, usingBigArraysto avoids frequent reallocation & copying of the internal data once the resulting data grows large enough whilst avoiding excessive overhead in the final result for small objects.A stream from this node to another node.A stream into which a structured Writeable may be written, e.g.Utilities for implementing aStreamOutput, for cases where performance is not a concern.Truncates writes once the max size is exceeded.ThisStreamOutputwrites nowhere.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.