org.apache.ignite.internal.portable

Class PortableReaderExImpl

java.lang.Object

org.apache.ignite.internal.portable.PortableReaderExImpl

All Implemented Interfaces:

DataInput, ObjectInput, AutoCloseable, PortableRawReader, PortableReader, PortableRawReaderEx

public class PortableReaderExImpl
extends Object
implements PortableReader, PortableRawReaderEx, ObjectInput

Portable reader implementation.

Constructor Summary

Constructors

Constructor and Description
PortableReaderExImpl(PortableContext ctx, byte[] arr, int start, ClassLoader ldr)

Method Summary

Methods

Modifier and Type	Method and Description
int	available()
void	close()
boolean	hasField(String fieldName)
PortableRawReader	rawReader() Gets raw reader.
int	read()
int	read(byte[] b)
int	read(byte[] b, int off, int len)
boolean	readBoolean()
boolean	readBoolean(String fieldName)
boolean[]	readBooleanArray()
boolean[]	readBooleanArray(String fieldName)
byte	readByte()
byte	readByte(String fieldName)
byte[]	readByteArray()
byte[]	readByteArray(String fieldName)
char	readChar()
char	readChar(String fieldName)
char[]	readCharArray()
char[]	readCharArray(String fieldName)
<T> Collection<T>	readCollection()
<T> Collection<T>	readCollection(Class<? extends Collection<T>> colCls)
<T> Collection<T>	readCollection(String fieldName)
<T> Collection<T>	readCollection(String fieldName, Class<? extends Collection<T>> colCls)
Date	readDate()
Date	readDate(String fieldName)
Date[]	readDateArray()
Date[]	readDateArray(String fieldName)
BigDecimal	readDecimal()
BigDecimal	readDecimal(String fieldName)
BigDecimal[]	readDecimalArray()
BigDecimal[]	readDecimalArray(String fieldName)
double	readDouble()
double	readDouble(String fieldName)
double[]	readDoubleArray()
double[]	readDoubleArray(String fieldName)
<T extends Enum<?>> T	readEnum()
<T extends Enum<?>> T	readEnum(String fieldName)
<T extends Enum<?>> T[]	readEnumArray()
<T extends Enum<?>> T[]	readEnumArray(String fieldName)
float	readFloat()
float	readFloat(String fieldName)
float[]	readFloatArray()
float[]	readFloatArray(String fieldName)
void	readFully(byte[] b)
void	readFully(byte[] b, int off, int len)
int	readInt()
int	readInt(String fieldName)
int[]	readIntArray()
int[]	readIntArray(String fieldName)
String	readLine()
long	readLong()
long	readLong(String fieldName)
long[]	readLongArray()
long[]	readLongArray(String fieldName)
<K,V> Map<K,V>	readMap()
<K,V> Map<K,V>	readMap(Class<? extends Map<K,V>> mapCls)
<K,V> Map<K,V>	readMap(String fieldName)
<K,V> Map<K,V>	readMap(String fieldName, Class<? extends Map<K,V>> mapCls)
Object	readObject()
<T> T	readObject(String fieldName)
Object[]	readObjectArray()
Object[]	readObjectArray(String fieldName)
Object	readObjectDetached()
short	readShort()
short	readShort(String fieldName)
short[]	readShortArray()
short[]	readShortArray(String fieldName)
String	readString()
String	readString(String fieldName)
String[]	readStringArray()
String[]	readStringArray(String fieldName)
Timestamp	readTimestamp()
Timestamp	readTimestamp(String fieldName)
int	readUnsignedByte()
int	readUnsignedShort()
String	readUTF()
UUID	readUuid()
UUID	readUuid(String fieldName)
UUID[]	readUuidArray()
UUID[]	readUuidArray(String fieldName)
long	skip(long n)
int	skipBytes(int n)
Object	unmarshal(int offset)

Methods inherited from class java.lang.Object

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

Constructor Detail

PortableReaderExImpl

public PortableReaderExImpl(PortableContext ctx,
                    byte[] arr,
                    int start,
                    ClassLoader ldr)

Parameters:

ctx - Context.

arr - Array.

start - Start.

ldr - Class loader.

Method Detail

unmarshal

public Object unmarshal(int offset)
                 throws PortableException

Parameters:

offset - Offset in the array.

Returns:

Unmarshalled value.

Throws:

PortableException - In case of error.

readByte

public byte readByte(String fieldName)
              throws PortableException

Specified by:

readByte in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Byte value.

Throws:

PortableException - In case of error.

readByte

public byte readByte()
              throws PortableException

Specified by:

readByte in interface DataInput

Specified by:

readByte in interface PortableRawReader

Returns:

Byte value.

Throws:

PortableException - In case of error.

readShort

public short readShort(String fieldName)
                throws PortableException

Specified by:

readShort in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Short value.

Throws:

PortableException - In case of error.

readShort

public short readShort()
                throws PortableException

Specified by:

readShort in interface DataInput

Specified by:

readShort in interface PortableRawReader

Returns:

Short value.

Throws:

PortableException - In case of error.

readInt

public int readInt(String fieldName)
            throws PortableException

Specified by:

readInt in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Integer value.

Throws:

PortableException - In case of error.

readInt

public int readInt()
            throws PortableException

Specified by:

readInt in interface DataInput

Specified by:

readInt in interface PortableRawReader

Returns:

Integer value.

Throws:

PortableException - In case of error.

readLong

public long readLong(String fieldName)
              throws PortableException

Specified by:

readLong in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Long value.

Throws:

PortableException - In case of error.

readLong

public long readLong()
              throws PortableException

Specified by:

readLong in interface DataInput

Specified by:

readLong in interface PortableRawReader

Returns:

Long value.

Throws:

PortableException - In case of error.

readFloat

public float readFloat(String fieldName)
                throws PortableException

Specified by:

readFloat in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Float value.

Throws:

PortableException - In case of error.

readFloat

public float readFloat()
                throws PortableException

Specified by:

readFloat in interface DataInput

Specified by:

readFloat in interface PortableRawReader

Returns:

Float value.

Throws:

PortableException - In case of error.

readDouble

public double readDouble(String fieldName)
                  throws PortableException

Specified by:

readDouble in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Double value.

Throws:

PortableException - In case of error.

readDouble

public double readDouble()
                  throws PortableException

Specified by:

readDouble in interface DataInput

Specified by:

readDouble in interface PortableRawReader

Returns:

Double value.

Throws:

PortableException - In case of error.

readChar

public char readChar(String fieldName)
              throws PortableException

Specified by:

readChar in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Char value.

Throws:

PortableException - In case of error.

readChar

public char readChar()
              throws PortableException

Specified by:

readChar in interface DataInput

Specified by:

readChar in interface PortableRawReader

Returns:

Char value.

Throws:

PortableException - In case of error.

readBoolean

public boolean readBoolean(String fieldName)
                    throws PortableException

Specified by:

readBoolean in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Boolean value.

Throws:

PortableException - In case of error.

readBoolean

public boolean readBoolean()
                    throws PortableException

Specified by:

readBoolean in interface DataInput

Specified by:

readBoolean in interface PortableRawReader

Returns:

Boolean value.

Throws:

PortableException - In case of error.

readDecimal

@Nullable
public BigDecimal readDecimal(String fieldName)
                       throws PortableException

Specified by:

readDecimal in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Decimal value.

Throws:

PortableException - In case of error.

readDecimal

@Nullable
public BigDecimal readDecimal()
                       throws PortableException

Specified by:

readDecimal in interface PortableRawReader

Returns:

Decimal value.

Throws:

PortableException - In case of error.

readString

@Nullable
public String readString(String fieldName)
                  throws PortableException

Specified by:

readString in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

String value.

Throws:

PortableException - In case of error.

readString

@Nullable
public String readString()
                  throws PortableException

Specified by:

readString in interface PortableRawReader

Returns:

String value.

Throws:

PortableException - In case of error.

readUuid

@Nullable
public UUID readUuid(String fieldName)
              throws PortableException

Specified by:

readUuid in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

UUID.

Throws:

PortableException - In case of error.

readUuid

@Nullable
public UUID readUuid()
              throws PortableException

Specified by:

readUuid in interface PortableRawReader

Returns:

UUID.

Throws:

PortableException - In case of error.

readDate

@Nullable
public Date readDate(String fieldName)
              throws PortableException

Specified by:

readDate in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Date.

Throws:

PortableException - In case of error.

readDate

@Nullable
public Date readDate()
              throws PortableException

Specified by:

readDate in interface PortableRawReader

Returns:

Date.

Throws:

PortableException - In case of error.

readTimestamp

@Nullable
public Timestamp readTimestamp(String fieldName)
                        throws PortableException

Specified by:

readTimestamp in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Timestamp.

Throws:

PortableException - In case of error.

readTimestamp

@Nullable
public Timestamp readTimestamp()
                        throws PortableException

Specified by:

readTimestamp in interface PortableRawReader

Returns:

Timestamp.

Throws:

PortableException - In case of error.

readObject

@Nullable
public <T> T readObject(String fieldName)
             throws PortableException

Specified by:

readObject in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Object.

Throws:

PortableException - In case of error.

readObject

public Object readObject()
                  throws PortableException

Specified by:

readObject in interface ObjectInput

Specified by:

readObject in interface PortableRawReader

Returns:

Object.

Throws:

PortableException - In case of error.

readObjectDetached

@Nullable
public Object readObjectDetached()
                          throws PortableException

Specified by:

readObjectDetached in interface PortableRawReaderEx

Returns:

Object.

Throws:

PortableException - In case of error.

readByteArray

@Nullable
public byte[] readByteArray(String fieldName)
                     throws PortableException

Specified by:

readByteArray in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Byte array.

Throws:

PortableException - In case of error.

readByteArray

@Nullable
public byte[] readByteArray()
                     throws PortableException

Specified by:

readByteArray in interface PortableRawReader

Returns:

Byte array.

Throws:

PortableException - In case of error.

readShortArray

@Nullable
public short[] readShortArray(String fieldName)
                       throws PortableException

Specified by:

readShortArray in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Short array.

Throws:

PortableException - In case of error.

readShortArray

@Nullable
public short[] readShortArray()
                       throws PortableException

Specified by:

readShortArray in interface PortableRawReader

Returns:

Short array.

Throws:

PortableException - In case of error.

readIntArray

@Nullable
public int[] readIntArray(String fieldName)
                   throws PortableException

Specified by:

readIntArray in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Integer array.

Throws:

PortableException - In case of error.

readIntArray

@Nullable
public int[] readIntArray()
                   throws PortableException

Specified by:

readIntArray in interface PortableRawReader

Returns:

Integer array.

Throws:

PortableException - In case of error.

readLongArray

@Nullable
public long[] readLongArray(String fieldName)
                     throws PortableException

Specified by:

readLongArray in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Long array.

Throws:

PortableException - In case of error.

readLongArray

@Nullable
public long[] readLongArray()
                     throws PortableException

Specified by:

readLongArray in interface PortableRawReader

Returns:

Long array.

Throws:

PortableException - In case of error.

readFloatArray

@Nullable
public float[] readFloatArray(String fieldName)
                       throws PortableException

Specified by:

readFloatArray in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Float array.

Throws:

PortableException - In case of error.

readFloatArray

@Nullable
public float[] readFloatArray()
                       throws PortableException

Specified by:

readFloatArray in interface PortableRawReader

Returns:

Float array.

Throws:

PortableException - In case of error.

readDoubleArray

@Nullable
public double[] readDoubleArray(String fieldName)
                         throws PortableException

Specified by:

readDoubleArray in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Byte array.

Throws:

PortableException - In case of error.

readDoubleArray

@Nullable
public double[] readDoubleArray()
                         throws PortableException

Specified by:

readDoubleArray in interface PortableRawReader

Returns:

Byte array.

Throws:

PortableException - In case of error.

readCharArray

@Nullable
public char[] readCharArray(String fieldName)
                     throws PortableException

Specified by:

readCharArray in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Char array.

Throws:

PortableException - In case of error.

readCharArray

@Nullable
public char[] readCharArray()
                     throws PortableException

Specified by:

readCharArray in interface PortableRawReader

Returns:

Char array.

Throws:

PortableException - In case of error.

readBooleanArray

@Nullable
public boolean[] readBooleanArray(String fieldName)
                           throws PortableException

Specified by:

readBooleanArray in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Boolean array.

Throws:

PortableException - In case of error.

readBooleanArray

@Nullable
public boolean[] readBooleanArray()
                           throws PortableException

Specified by:

readBooleanArray in interface PortableRawReader

Returns:

Boolean array.

Throws:

PortableException - In case of error.

readDecimalArray

@Nullable
public BigDecimal[] readDecimalArray(String fieldName)
                              throws PortableException

Specified by:

readDecimalArray in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Decimal array.

Throws:

PortableException - In case of error.

readDecimalArray

@Nullable
public BigDecimal[] readDecimalArray()
                              throws PortableException

Specified by:

readDecimalArray in interface PortableRawReader

Returns:

Decimal array.

Throws:

PortableException - In case of error.

readStringArray

@Nullable
public String[] readStringArray(String fieldName)
                         throws PortableException

Specified by:

readStringArray in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

String array.

Throws:

PortableException - In case of error.

readStringArray

@Nullable
public String[] readStringArray()
                         throws PortableException

Specified by:

readStringArray in interface PortableRawReader

Returns:

String array.

Throws:

PortableException - In case of error.

readUuidArray

@Nullable
public UUID[] readUuidArray(String fieldName)
                     throws PortableException

Specified by:

readUuidArray in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

UUID array.

Throws:

PortableException - In case of error.

readUuidArray

@Nullable
public UUID[] readUuidArray()
                     throws PortableException

Specified by:

readUuidArray in interface PortableRawReader

Returns:

UUID array.

Throws:

PortableException - In case of error.

readDateArray

@Nullable
public Date[] readDateArray(String fieldName)
                     throws PortableException

Specified by:

readDateArray in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Date array.

Throws:

PortableException - In case of error.

readDateArray

@Nullable
public Date[] readDateArray()
                     throws PortableException

Specified by:

readDateArray in interface PortableRawReader

Returns:

Date array.

Throws:

PortableException - In case of error.

readObjectArray

@Nullable
public Object[] readObjectArray(String fieldName)
                         throws PortableException

Specified by:

readObjectArray in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Object array.

Throws:

PortableException - In case of error.

readObjectArray

@Nullable
public Object[] readObjectArray()
                         throws PortableException

Specified by:

readObjectArray in interface PortableRawReader

Returns:

Object array.

Throws:

PortableException - In case of error.

readCollection

@Nullable
public <T> Collection<T> readCollection(String fieldName)
                             throws PortableException

Specified by:

readCollection in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Collection.

Throws:

PortableException - In case of error.

readCollection

@Nullable
public <T> Collection<T> readCollection()
                             throws PortableException

Specified by:

readCollection in interface PortableRawReader

Returns:

Collection.

Throws:

PortableException - In case of error.

readCollection

@Nullable
public <T> Collection<T> readCollection(String fieldName,
                                        Class<? extends Collection<T>> colCls)
                             throws PortableException

Specified by:

readCollection in interface PortableReader

Parameters:

fieldName - Field name.

colCls - Collection class.

Returns:

Collection.

Throws:

PortableException - In case of error.

readCollection

@Nullable
public <T> Collection<T> readCollection(Class<? extends Collection<T>> colCls)
                             throws PortableException

Specified by:

readCollection in interface PortableRawReader

Parameters:

colCls - Collection class.

Returns:

Collection.

Throws:

PortableException - In case of error.

readMap

@Nullable
public <K,V> Map<K,V> readMap(String fieldName)
                 throws PortableException

Specified by:

readMap in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Map.

Throws:

PortableException - In case of error.

readMap

@Nullable
public <K,V> Map<K,V> readMap()
                 throws PortableException

Specified by:

readMap in interface PortableRawReader

Returns:

Map.

Throws:

PortableException - In case of error.

readMap

@Nullable
public <K,V> Map<K,V> readMap(String fieldName,
                              Class<? extends Map<K,V>> mapCls)
                 throws PortableException

Specified by:

readMap in interface PortableReader

Parameters:

fieldName - Field name.

mapCls - Map class.

Returns:

Map.

Throws:

PortableException - In case of error.

readMap

@Nullable
public <K,V> Map<K,V> readMap(Class<? extends Map<K,V>> mapCls)
                 throws PortableException

Specified by:

readMap in interface PortableRawReader

Parameters:

mapCls - Map class.

Returns:

Map.

Throws:

PortableException - In case of error.

readEnum

@Nullable
public <T extends Enum<?>> T readEnum(String fieldName)
                        throws PortableException

Specified by:

readEnum in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Value.

Throws:

PortableException - In case of error.

readEnum

@Nullable
public <T extends Enum<?>> T readEnum()
                        throws PortableException

Specified by:

readEnum in interface PortableRawReader

Returns:

Value.

Throws:

PortableException - In case of error.

readEnumArray

@Nullable
public <T extends Enum<?>> T[] readEnumArray(String fieldName)
                               throws PortableException

Specified by:

readEnumArray in interface PortableReader

Parameters:

fieldName - Field name.

Returns:

Value.

Throws:

PortableException - In case of error.

readEnumArray

@Nullable
public <T extends Enum<?>> T[] readEnumArray()
                               throws PortableException

Specified by:

readEnumArray in interface PortableRawReader

Returns:

Value.

Throws:

PortableException - In case of error.

hasField

public boolean hasField(String fieldName)

Parameters:

fieldName - Field name.

Returns:

true if field is set.

rawReader

public PortableRawReader rawReader()

Gets raw reader. Raw reader does not use field name hash codes, therefore, making the format even more compact. However, if the raw reader is used, dynamic structure changes to the portable objects are not supported.

Specified by:

rawReader in interface PortableReader

Returns:

Raw reader.

readUnsignedByte

public int readUnsignedByte()
                     throws IOException

Specified by:

readUnsignedByte in interface DataInput

Throws:

IOException

readUnsignedShort

public int readUnsignedShort()
                      throws IOException

Specified by:

readUnsignedShort in interface DataInput

Throws:

IOException

readLine

public String readLine()
                throws IOException

Specified by:

readLine in interface DataInput

Throws:

IOException

readUTF

@NotNull
public String readUTF()
               throws IOException

Specified by:

readUTF in interface DataInput

Throws:

IOException

readFully

public void readFully(byte[] b)
               throws IOException

Specified by:

readFully in interface DataInput

Throws:

IOException

readFully

public void readFully(byte[] b,
             int off,
             int len)
               throws IOException

Specified by:

readFully in interface DataInput

Throws:

IOException

skipBytes

public int skipBytes(int n)
              throws IOException

Specified by:

skipBytes in interface DataInput

Throws:

IOException

read

public int read()
         throws IOException

Specified by:

read in interface ObjectInput

Throws:

IOException

read

public int read(byte[] b)
         throws IOException

Specified by:

read in interface ObjectInput

Throws:

IOException

read

public int read(byte[] b,
       int off,
       int len)
         throws IOException

Specified by:

read in interface ObjectInput

Throws:

IOException

skip

public long skip(long n)
          throws IOException

Specified by:

skip in interface ObjectInput

Throws:

IOException

available

public int available()
              throws IOException

Specified by:

available in interface ObjectInput

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface ObjectInput

Specified by:

close in interface AutoCloseable

Throws:

IOException