Package org.elasticsearch.common.io.stream

Class BytesStreamOutput

java.lang.Object

java.io.OutputStream

org.elasticsearch.common.io.stream.StreamOutput

org.elasticsearch.common.io.stream.BytesStream

org.elasticsearch.common.io.stream.BytesStreamOutput

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

Direct Known Subclasses:

ReleasableBytesStreamOutput

public class BytesStreamOutput
extends BytesStream

A @link StreamOutput that uses BigArrays to acquire pages of bytes, which avoids frequent reallocation & copying of the internal data.

Field Summary

Fields

Modifier and Type	Field	Description
protected final BigArrays	bigArrays
protected ByteArray	bytes
protected int	count

Constructor Summary

Constructors

Modifier	Constructor	Description
	BytesStreamOutput()	Create a non recycling BytesStreamOutput with an initial capacity of 0.
	BytesStreamOutput(int expectedSize)	Create a non recycling BytesStreamOutput with enough initial pages acquired to satisfy the capacity given by expected size.
protected	BytesStreamOutput(int expectedSize, BigArrays bigArrays)

Method Summary

Modifier and Type	Method	Description
BytesReference	bytes()
void	close()	Closes this stream to further operations.
BytesReference	copyBytes()	Like bytes() but copies the bytes to a freshly allocated buffer.
protected void	ensureCapacity(long offset)
void	flush()	Forces any buffered output to be written.
long	position()
long	ramBytesUsed()	Returns the number of bytes used by the underlying ByteArray
void	reset()
void	seek(long position)
int	size()	Returns the current size of the buffer.
void	skip(int length)
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, 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

Field Details

bigArrays

protected final BigArrays bigArrays

bytes

@Nullable
protected ByteArray bytes

count

protected int count

Constructor Details

BytesStreamOutput

public BytesStreamOutput()

Create a non recycling BytesStreamOutput with an initial capacity of 0.

BytesStreamOutput

public BytesStreamOutput(int expectedSize)

Create a non recycling BytesStreamOutput with enough initial pages acquired to satisfy the capacity given by expected size.

Parameters:

expectedSize - the expected maximum size of the stream in bytes.

BytesStreamOutput

protected BytesStreamOutput(int expectedSize,
 BigArrays bigArrays)

Method Details

position

public long position()

Overrides:

position in class StreamOutput

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

reset

public void reset()

Specified by:

reset in class StreamOutput

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

seek

public void seek(long position)

Overrides:

seek in class StreamOutput

skip

public void skip(int length)

close

public void close()

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

size

public int size()

Returns the current size of the buffer.

Returns:

the value of the count field, which is the number of valid bytes in this output stream.

See Also:

• ByteArrayOutputStream.count

bytes

public BytesReference bytes()

Specified by:

bytes in class BytesStream

copyBytes

public BytesReference copyBytes()

Like bytes() but copies the bytes to a freshly allocated buffer.

Returns:

copy of the bytes in this instances

ramBytesUsed

public long ramBytesUsed()

Returns the number of bytes used by the underlying ByteArray

See Also:

• Accountable.ramBytesUsed()

ensureCapacity

protected void ensureCapacity(long offset)