org.xbib.elasticsearch.common.io.stream

Class BytesStreamOutput

java.lang.Object

java.io.OutputStream

org.elasticsearch.common.io.stream.StreamOutput

org.xbib.elasticsearch.common.io.stream.BytesStreamOutput

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable, org.elasticsearch.common.io.BytesStream

Direct Known Subclasses:

ReleasableBytesStreamOutput

public class BytesStreamOutput
extends org.elasticsearch.common.io.stream.StreamOutput
implements org.elasticsearch.common.io.BytesStream

Field Summary

Fields

Modifier and Type	Field and Description
protected org.elasticsearch.common.util.BigArrays	bigarrays
protected org.elasticsearch.common.util.ByteArray	bytes
protected int	count

Constructor Summary

Constructors

Modifier	Constructor and Description
	BytesStreamOutput() Create a non recycling BytesStreamOutput with 1 initial page acquired.
	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, org.elasticsearch.common.util.BigArrays bigarrays)

Method Summary

Methods

Modifier and Type	Method and Description
org.elasticsearch.common.bytes.BytesReference	bytes()
void	close()
void	flush()
BytesReference	ourBytes()
long	position()
void	reset()
void	seek(long position)
boolean	seekPositionSupported()
int	size() Returns the current size of the buffer.
void	skip(int length)
void	writeByte(byte b)
void	writeBytes(byte[] b, int offset, int length)

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

getVersion, setVersion, write, write, writeBoolean, writeBytes, writeBytes, writeBytesRef, writeBytesReference, writeDouble, writeDoubleArray, writeFloat, writeFloatArray, writeGenericValue, writeInt, writeIntArray, writeLong, writeLongArray, writeMap, writeOptionalBoolean, writeOptionalSharedString, writeOptionalStreamable, writeOptionalString, writeOptionalText, writeSharedString, writeSharedText, writeShort, writeString, writeStringArray, writeStringArrayNullable, writeText, writeTextArray, writeVInt, writeVLong

Methods inherited from class java.io.OutputStream

write

Methods inherited from class java.lang.Object

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

Field Detail

bigarrays

protected final org.elasticsearch.common.util.BigArrays bigarrays

bytes

protected org.elasticsearch.common.util.ByteArray bytes

count

protected int count

Constructor Detail

BytesStreamOutput

public BytesStreamOutput()

Create a non recycling BytesStreamOutput with 1 initial page acquired.

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,
                 org.elasticsearch.common.util.BigArrays bigarrays)

Method Detail

seekPositionSupported

public boolean seekPositionSupported()

Overrides:

seekPositionSupported in class org.elasticsearch.common.io.stream.StreamOutput

position

public long position()
              throws IOException

Overrides:

position in class org.elasticsearch.common.io.stream.StreamOutput

Throws:

IOException

writeByte

public void writeByte(byte b)
               throws IOException

Specified by:

writeByte in class org.elasticsearch.common.io.stream.StreamOutput

Throws:

IOException

writeBytes

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

Specified by:

writeBytes in class org.elasticsearch.common.io.stream.StreamOutput

Throws:

IOException

reset

public void reset()

Specified by:

reset in class org.elasticsearch.common.io.stream.StreamOutput

flush

public void flush()
           throws IOException

Specified by:

flush in interface Flushable

Specified by:

flush in class org.elasticsearch.common.io.stream.StreamOutput

Throws:

IOException

seek

public void seek(long position)
          throws IOException

Overrides:

seek in class org.elasticsearch.common.io.stream.StreamOutput

Throws:

IOException

skip

public void skip(int length)

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in class org.elasticsearch.common.io.stream.StreamOutput

Throws:

IOException

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 org.elasticsearch.common.bytes.BytesReference bytes()

Specified by:

bytes in interface org.elasticsearch.common.io.BytesStream

ourBytes

public BytesReference ourBytes()