public class ObjectDataInputStream extends InputStream implements Closeable
Modifier and Type | Field and Description |
---|---|
protected Version |
version |
protected Version |
wanProtocolVersion |
Constructor and Description |
---|
ObjectDataInputStream(InputStream in,
InternalSerializationService serializationService) |
Modifier and Type | Method and Description |
---|---|
int |
available() |
void |
close() |
ByteOrder |
getByteOrder() |
ClassLoader |
getClassLoader()
Returns class loader that internally used for objects.
|
InternalSerializationService |
getSerializationService() |
Version |
getVersion()
If the serializer supports versioning it may set the version to use for
the intra-cluster message serialization on this object.
|
Version |
getWanProtocolVersion()
Returns the WAN protocol version.
|
void |
mark(int readlimit) |
boolean |
markSupported() |
int |
read() |
int |
read(byte[] b) |
int |
read(byte[] b,
int off,
int len) |
boolean |
readBoolean() |
boolean[] |
readBooleanArray() |
byte |
readByte() |
byte[] |
readByteArray() |
char |
readChar() |
char[] |
readCharArray() |
Data |
readData() |
<T> T |
readDataAsObject()
Reads to stored Data as an object instead of a Data instance.
|
double |
readDouble() |
double[] |
readDoubleArray() |
float |
readFloat() |
float[] |
readFloatArray() |
void |
readFully(byte[] b) |
void |
readFully(byte[] b,
int off,
int len) |
int |
readInt() |
int[] |
readIntArray() |
String |
readLine()
Deprecated.
|
long |
readLong() |
long[] |
readLongArray() |
<T> T |
readObject() |
<T> T |
readObject(Class aClass) |
short |
readShort() |
short[] |
readShortArray() |
int |
readUnsignedByte() |
int |
readUnsignedShort() |
String |
readUTF() |
String[] |
readUTFArray() |
void |
reset() |
void |
setVersion(Version version)
If the serializer supports versioning it may set the version to use for
the serialization on this object.
|
void |
setWanProtocolVersion(Version version)
Sets the WAN protocol version.
|
long |
skip(long n) |
int |
skipBytes(int n) |
protected Version version
protected Version wanProtocolVersion
public ObjectDataInputStream(InputStream in, InternalSerializationService serializationService)
public int read() throws IOException
read
in class InputStream
IOException
public long skip(long n) throws IOException
skip
in class InputStream
IOException
public int available() throws IOException
available
in class InputStream
IOException
public int read(byte[] b) throws IOException
read
in class InputStream
IOException
public int read(byte[] b, int off, int len) throws IOException
read
in class InputStream
IOException
public void readFully(byte[] b) throws IOException
readFully
in interface DataInput
IOException
public void readFully(byte[] b, int off, int len) throws IOException
readFully
in interface DataInput
IOException
public int skipBytes(int n) throws IOException
skipBytes
in interface DataInput
IOException
public boolean readBoolean() throws IOException
readBoolean
in interface DataInput
IOException
public byte readByte() throws IOException
readByte
in interface DataInput
IOException
public int readUnsignedByte() throws IOException
readUnsignedByte
in interface DataInput
IOException
public short readShort() throws IOException
readShort
in interface DataInput
IOException
public int readUnsignedShort() throws IOException
readUnsignedShort
in interface DataInput
IOException
public char readChar() throws IOException
readChar
in interface DataInput
IOException
public int readInt() throws IOException
readInt
in interface DataInput
IOException
public long readLong() throws IOException
readLong
in interface DataInput
IOException
public float readFloat() throws IOException
readFloat
in interface DataInput
IOException
public double readDouble() throws IOException
readDouble
in interface DataInput
IOException
public byte[] readByteArray() throws IOException
readByteArray
in interface ObjectDataInput
IOException
- if it reaches end of file before finish readingpublic boolean[] readBooleanArray() throws IOException
readBooleanArray
in interface ObjectDataInput
IOException
- if it reaches end of file before finish readingpublic char[] readCharArray() throws IOException
readCharArray
in interface ObjectDataInput
IOException
- if it reaches end of file before finish readingpublic int[] readIntArray() throws IOException
readIntArray
in interface ObjectDataInput
IOException
- if it reaches end of file before finish readingpublic long[] readLongArray() throws IOException
readLongArray
in interface ObjectDataInput
IOException
- if it reaches end of file before finish readingpublic double[] readDoubleArray() throws IOException
readDoubleArray
in interface ObjectDataInput
IOException
- if it reaches end of file before finish readingpublic float[] readFloatArray() throws IOException
readFloatArray
in interface ObjectDataInput
IOException
- if it reaches end of file before finish readingpublic short[] readShortArray() throws IOException
readShortArray
in interface ObjectDataInput
IOException
- if it reaches end of file before finish readingpublic String[] readUTFArray() throws IOException
readUTFArray
in interface ObjectDataInput
IOException
- if it reaches end of file before finish reading@Deprecated public String readLine() throws IOException
readLine
in interface DataInput
IOException
public String readUTF() throws IOException
readUTF
in interface DataInput
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class InputStream
IOException
public void mark(int readlimit)
mark
in class InputStream
public void reset() throws IOException
reset
in class InputStream
IOException
public boolean markSupported()
markSupported
in class InputStream
public <T> T readObject() throws IOException
readObject
in interface ObjectDataInput
T
- type of the object to be readIOException
- if it reaches end of file before finish readingpublic <T> T readDataAsObject() throws IOException
ObjectDataInput
The reason this method exists is that in some cases Data
is stored on serialization, but on deserialization
the actual object instance is needed. Getting access to the Data
is easy by calling the ObjectDataInput.readData()
method. But de-serializing the Data
to an object instance is impossible because there is no reference to the
SerializationService
.
readDataAsObject
in interface ObjectDataInput
T
- type of the object to be readIOException
- if it reaches end of file before finish readingpublic <T> T readObject(Class aClass) throws IOException
readObject
in interface ObjectDataInput
T
- type of the object to be readaClass
- the type of the class to use when readingIOException
- if it reaches end of file before finish readingpublic Data readData() throws IOException
readData
in interface ObjectDataInput
IOException
- if it reaches end of file before finish readingpublic ClassLoader getClassLoader()
ObjectDataInput
getClassLoader
in interface ObjectDataInput
public InternalSerializationService getSerializationService()
getSerializationService
in interface ObjectDataInput
public ByteOrder getByteOrder()
getByteOrder
in interface ObjectDataInput
public Version getWanProtocolVersion()
WanProtocolVersionAware
VersionAware.getVersion()
but is used in WAN replication, not in
message exchange inside a single cluster.getWanProtocolVersion
in interface WanProtocolVersionAware
Version.UNKNOWN
if not setVersionAware.getVersion()
public void setWanProtocolVersion(Version version)
WanProtocolVersionAware
VersionAware.setVersion(Version)
but is used in WAN replication,
not in message exchange inside a single cluster.setWanProtocolVersion
in interface WanProtocolVersionAware
version
- the WAN protocol versionVersionAware.setVersion(Version)
public Version getVersion()
getVersion
in interface VersionAware
Version.UNKNOWN
if the version is unknown to the object.public void setVersion(Version version)
setVersion
in interface VersionAware
version
- version to setCopyright © 2019 Hazelcast, Inc.. All rights reserved.