Class ByteBufferStreamInput
org.elasticsearch.common.io.stream.StreamInput
org.elasticsearch.common.io.stream.ByteBufferStreamInput
- All Implemented Interfaces:
,
-
Constructor Summary
ConstructorDescriptionbuffer)
-
Method Summary
Modifier and TypeMethodDescriptionint
void
close()
Closes the stream to further operations.protected void
ensureCanReadBytes(int length)
This method throws an if the given number of bytes can not be read from the this stream.void
mark(int readlimit)
boolean
int
read()
int
read(byte[] b, int off, int len)
byte
readByte()
Reads and returns a single byte.void
readBytes(byte[] b, int offset, int len)
Reads a specified number of bytes into an array at the specified offset.int
readInt()
Reads four bytes and returns an int.long
readLong()
Reads eight bytes and returns a long.short
void
reset()
long
skip(long n)
Methods inherited from class org.elasticsearch.common.io.stream.StreamInput
getVersion, namedWriteableRegistry, readArray, readArraySize, readBigInteger, readBoolean, readByteArray, readBytesRef, readBytesRef, readBytesReference, readBytesReference, readDouble, readDoubleArray, readEnum, readEnumSet, readException, readFloat, readFloatArray, readFully, readGenericValue, readGeoPoint, readImmutableMap, readInstant, readIntArray, readList, readLongArray, readMap, readMap, readMapOfLists, readNamedWriteable, readNamedWriteable, readNamedWriteableList, readOptionalArray, readOptionalBoolean, readOptionalBytesReference, readOptionalDouble, readOptionalEnum, readOptionalFloat, readOptionalInstant, readOptionalInt, readOptionalLong, readOptionalNamedWriteable, readOptionalSecureString, readOptionalString, readOptionalStringArray, readOptionalStringList, readOptionalText, readOptionalTimeValue, readOptionalTimeZone, readOptionalVInt, readOptionalVLong, readOptionalWriteable, readOptionalZoneId, readOrderedMap, readReleasableBytesReference, readSecureString, readSet, readString, readStringArray, readStringList, readText, readTimeValue, readTimeZone, readVInt, readVIntArray, readVIntSlow, readVLong, readVLongArray, readVLongSlow, readZLong, readZoneId, setVersion, throwOnBrokenVInt, throwOnBrokenVLong, wrap, wrap
Methods inherited from class java.io.
, , , , , ,
Methods inherited from class java.lang.
, , , , , , , , , ,
-
Constructor Details
-
ByteBufferStreamInput
public ByteBufferStreamInput( buffer)
-
-
Method Details
-
read
public int read() throws- Specified by:
in class
- Throws:
-
readByte
public byte readByte() throwsDescription copied from class:StreamInput
Reads and returns a single byte.- Specified by:
readByte
in classStreamInput
- Throws:
-
read
public int read(byte[] b, int off, int len) throws- Overrides:
in class
- Throws:
-
skip
public long skip(long n) throws- Overrides:
in class
- Throws:
-
readBytes
public void readBytes(byte[] b, int offset, int len) throwsDescription copied from class:StreamInput
Reads a specified number of bytes into an array at the specified offset.- Specified by:
readBytes
in classStreamInput
- Parameters:
b
- the array to read bytes intooffset
- the offset in the array to start storing byteslen
- the number of bytes to read- Throws:
-
readShort
public short readShort() throws- Overrides:
readShort
in classStreamInput
- Throws:
-
readInt
public int readInt() throwsDescription copied from class:StreamInput
Reads four bytes and returns an int.- Overrides:
readInt
in classStreamInput
- Throws:
-
readLong
public long readLong() throwsDescription copied from class:StreamInput
Reads eight bytes and returns a long.- Overrides:
readLong
in classStreamInput
- Throws:
-
reset
public void reset() throws- Overrides:
in class
- Throws:
-
available
public int available() throws- Specified by:
available
in classStreamInput
- Throws:
-
ensureCanReadBytes
protected void ensureCanReadBytes(int length) throwsDescription copied from class:StreamInput
This method throws an if the given number of bytes can not be read from the this stream. This method might be a no-op depending on the underlying implementation if the information of the remaining bytes is not present.- Specified by:
ensureCanReadBytes
in classStreamInput
- Throws:
-
mark
public void mark(int readlimit)- Overrides:
in class
-
markSupported
public boolean markSupported()- Overrides:
in class
-
close
public void close() throwsDescription copied from class:StreamInput
Closes the stream to further operations.- Specified by:
in interface
- Specified by:
in interface
- Specified by:
close
in classStreamInput
- Throws:
-