Package org.elasticsearch.common.bytes

Class RecyclingBytesStreamOutput

java.lang.Object

java.io.OutputStream

org.elasticsearch.common.io.stream.StreamOutput

org.elasticsearch.common.io.stream.BytesStream

org.elasticsearch.common.bytes.RecyclingBytesStreamOutput

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

public class RecyclingBytesStreamOutput
extends BytesStream

An in-memory StreamOutput which first fills the given byte[] and then allocates more space from the given BigArrays if needed. The idea is that you can use this for passing data to an API that requires a single byte[] (or a BytesRef) which you'd prefer to re-use if possible, avoiding excessive allocations, but which may not always be large enough.

Constructor Summary

Constructors

Constructor	Description
RecyclingBytesStreamOutput(byte[] buffer, BigArrays bigArrays)

Method Summary

Modifier and Type	Method	Description
BytesReference	bytes()
void	close()	Closes this stream to further operations.
void	flush()	Forces any buffered output to be written.
void	reset()
org.apache.lucene.util.BytesRef	toBytesRef()	Return the written bytes in a BytesRef, avoiding allocating a new byte[] if the original buffer was already large enough.
void	writeByte(byte b)	Writes a single byte.
void	writeBytes(byte[] b, int offset, int length)	Writes an array of bytes.

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

checkWriteable, getFeatures, getVersion, hasFeature, position, seek, setFeatures, setVersion, write, write, writeArray, writeArray, writeBoolean, writeByteArray, writeBytes, writeBytes, writeBytesRef, writeBytesReference, writeCollection, writeCollection, writeDouble, writeDoubleArray, writeEnum, writeEnumSet, writeException, writeFloat, writeFloatArray, writeGenericValue, writeGeoPoint, writeInstant, writeInt, writeIntArray, writeList, writeLong, writeLongArray, writeMap, writeMap, writeMap, writeMap, writeMapOfLists, writeMapWithConsistentOrder, writeNamedWriteable, writeNamedWriteableList, writeOptionalArray, writeOptionalArray, writeOptionalBoolean, writeOptionalBytesReference, writeOptionalDouble, writeOptionalEnum, writeOptionalFloat, writeOptionalInstant, writeOptionalInt, writeOptionalLong, writeOptionalNamedWriteable, writeOptionalSecureString, writeOptionalString, writeOptionalStringArray, writeOptionalStringCollection, writeOptionalText, writeOptionalTimeValue, writeOptionalTimeZone, writeOptionalVInt, writeOptionalVLong, writeOptionalWriteable, writeOptionalZoneId, writeSecureString, writeShort, writeString, writeStringArray, writeStringArrayNullable, writeStringCollection, writeText, writeTimeValue, writeTimeZone, writeVInt, writeVIntArray, writeVLong, writeVLongArray, writeZLong, writeZoneId

Methods inherited from class java.io.OutputStream

nullOutputStream, write

Methods inherited from class java.lang.Object

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

Constructor Details

RecyclingBytesStreamOutput

public RecyclingBytesStreamOutput(byte[] buffer,
 BigArrays bigArrays)

Method Details

writeByte

public void writeByte(byte b)

Description copied from class: StreamOutput

Writes a single byte.

Specified by:

writeByte in class StreamOutput

writeBytes

public void writeBytes(byte[] b,
 int offset,
 int length)

Description copied from class: StreamOutput

Writes an array of bytes.

Specified by:

writeBytes in class StreamOutput

Parameters:

b - the bytes to write

offset - the offset in the byte array

length - the number of bytes to write

flush

public void flush()

Description copied from class: StreamOutput

Forces any buffered output to be written.

Specified by:

flush in interface Flushable

Specified by:

flush in class StreamOutput

close

public void close()
           throws IOException

Description copied from class: StreamOutput

Closes this stream to further operations.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in class StreamOutput

Throws:

IOException

reset

public void reset()
           throws IOException

Specified by:

reset in class StreamOutput

Throws:

IOException

toBytesRef

public org.apache.lucene.util.BytesRef toBytesRef()

Return the written bytes in a BytesRef, avoiding allocating a new byte[] if the original buffer was already large enough. If we allocate a new (larger) buffer here then callers should typically re-use it for subsequent streams.

bytes

public BytesReference bytes()

Specified by:

bytes in class BytesStream