Module org.elasticsearch.server

Package org.elasticsearch.common.io.stream

Class CountingStreamOutput

java.lang.Object

java.io.OutputStream

org.elasticsearch.common.io.stream.StreamOutput

org.elasticsearch.common.io.stream.CountingStreamOutput

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

public class CountingStreamOutput
extends StreamOutput

A reusable @link StreamOutput that just count how many bytes are written.

Field Summary

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

GENERIC_LIST_HEADER

Constructor Summary

Constructors

Constructor	Description
CountingStreamOutput()

Method Summary

Modifier and Type	Method	Description
void	close()	Closes this stream to further operations.
void	flush()	Forces any buffered output to be written.
void	reset()	reset the written byes to 0
long	size()	returns how many bytes would have been written
void	writeByte(byte b)	Writes a single byte.
void	writeBytes(byte[] b, int offset, int length)	Writes an array of bytes.
void	writeDouble(double v)
void	writeDoubleArray(double[] values)
void	writeFloat(float v)
void	writeFloatArray(float[] values)
void	writeInt(int i)	Writes an int as four bytes.
void	writeIntArray(int[] values)
void	writeLong(long i)	Writes a long as eight bytes.
void	writeLongArray(long[] values)

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

checkWriteable, getTransportVersion, position, setTransportVersion, write, write, writeArray, writeArray, writeBoolean, writeByteArray, writeBytes, writeBytes, writeBytesRef, writeBytesReference, writeCollection, writeCollection, writeEnum, writeEnumSet, writeException, writeGenericList, writeGenericMap, writeGenericNull, writeGenericString, writeGenericValue, writeGeoPoint, writeInstant, writeMap, writeMap, writeMap, writeMapValues, writeMapValues, writeMapWithConsistentOrder, writeMissingString, writeMissingWriteable, writeNamedWriteable, writeNamedWriteableCollection, writeOptionalArray, writeOptionalArray, writeOptionalBoolean, writeOptionalByteArray, writeOptionalBytesReference, writeOptionalCollection, writeOptionalCollection, writeOptionalDouble, writeOptionalEnum, writeOptionalFloat, writeOptionalInstant, writeOptionalInt, writeOptionalLong, writeOptionalNamedWriteable, writeOptionalSecureString, writeOptionalString, writeOptionalStringArray, writeOptionalStringCollection, writeOptionalText, writeOptionalTimeValue, writeOptionalVInt, writeOptionalVLong, writeOptionalWriteable, writeOptionalZoneId, writeSecureString, writeShort, writeString, writeStringArray, writeStringArrayNullable, writeStringCollection, writeText, writeTimeValue, writeVInt, writeVIntArray, writeVLong, writeVLongArray, writeWithSizePrefix, writeWriteable, 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

CountingStreamOutput

public CountingStreamOutput()

Method Details

reset

public void reset()

reset the written byes to 0

size

public long size()

returns how many bytes would have been written

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

writeInt

public void writeInt(int i)

Description copied from class: StreamOutput

Writes an int as four bytes.

Overrides:

writeInt in class StreamOutput

writeIntArray

public void writeIntArray(int[] values)
                   throws IOException

Overrides:

writeIntArray in class StreamOutput

Throws:

IOException

writeLong

public void writeLong(long i)

Description copied from class: StreamOutput

Writes a long as eight bytes.

Overrides:

writeLong in class StreamOutput

writeLongArray

public void writeLongArray(long[] values)
                    throws IOException

Overrides:

writeLongArray in class StreamOutput

Throws:

IOException

writeFloat

public void writeFloat(float v)

Overrides:

writeFloat in class StreamOutput

writeFloatArray

public void writeFloatArray(float[] values)
                     throws IOException

Overrides:

writeFloatArray in class StreamOutput

Throws:

IOException

writeDouble

public void writeDouble(double v)

Overrides:

writeDouble in class StreamOutput

writeDoubleArray

public void writeDoubleArray(double[] values)
                      throws IOException

Overrides:

writeDoubleArray in class StreamOutput

Throws:

IOException

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()

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