Package org.apache.ignite.internal.binary

Class BinaryObjectImpl

java.lang.Object

org.apache.ignite.internal.binary.BinaryObjectImpl

All Implemented Interfaces:

Externalizable, Serializable, Cloneable, BinaryObject, BinaryObjectEx, CacheObject, KeyCacheObject

public final class BinaryObjectImpl
extends Object
implements Externalizable, KeyCacheObject

Binary object implementation.

See Also:

Serialized Form

Field Summary

Fields inherited from interface org.apache.ignite.internal.processors.cache.CacheObject

TYPE_BINARY, TYPE_BINARY_ENUM, TYPE_BYTE_ARR, TYPE_REGULAR

Constructor Summary

Constructors

Constructor	Description
BinaryObjectImpl()	For Externalizable.
BinaryObjectImpl(BinaryContext ctx, byte[] arr, int start)

Method Summary

Modifier and Type	Method	Description
byte[]	bytes()
byte	cacheObjectType()
BinaryObject	clone()
BinaryContext	context()
void	context(BinaryContext ctx)
KeyCacheObject	copy(int part)
int	dataStartOffset()
<T> T	deserialize()
<T> T	deserialize(@Nullable ClassLoader ldr)
BinaryObjectEx	detach()
BinaryObjectImpl	detach(boolean checkCrossObjReferences)
void	detachAllowed(boolean detachAllowed)
boolean	detached()
String	enumName()
int	enumOrdinal()
boolean	equals(Object arg0)
<F> F	field(int fieldId)
<F> F	field(String fieldName)
protected <F> F	field(org.apache.ignite.internal.binary.BinaryReaderHandles rCtx, String fieldName)
<F> F	fieldByOrder(int order)
void	finishUnmarshal(CacheObjectValueContext ctx, ClassLoader ldr)
int	footerStartOffset()
boolean	hasBytes()
boolean	hasCircularReferences()
boolean	hasField(String fieldName)
int	hashCode()
boolean	hasSchema()
boolean	internal()
boolean	isFlagSet(short flag)
boolean	isPlatformType()
int	length()
long	offheapAddress()
int	partition()
void	partition(int part)
CacheObject	prepareForCache(CacheObjectValueContext ctx)
void	prepareMarshal(CacheObjectValueContext ctx)
int	putValue(long addr)
boolean	putValue(ByteBuffer buf)
boolean	putValue(ByteBuffer buf, int off, int len)
@Nullable BinaryType	rawType()
void	readExternal(ObjectInput in)
int	schemaId()
int	size()
int	start()
BinaryObjectBuilder	toBuilder()
String	toString()
@Nullable BinaryType	type()
int	typeId()
<T> T	value(CacheObjectValueContext ctx, boolean cpy)
<T> T	value(CacheObjectValueContext ctx, boolean cpy, ClassLoader ldr)
byte[]	valueBytes(CacheObjectValueContext ctx)
int	valueBytesLength(CacheObjectValueContext ctx)
void	writeExternal(ObjectOutput out)
boolean	writeFieldByOrder(int order, ByteBuffer buf)

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.ignite.internal.binary.BinaryObjectEx

array, componentClassName, componentTypeId, enumClassName, heapCopy

Methods inherited from interface org.apache.ignite.internal.processors.cache.CacheObject

postWriteRequired

Constructor Detail

BinaryObjectImpl

public BinaryObjectImpl()

For Externalizable.

BinaryObjectImpl

public BinaryObjectImpl(BinaryContext ctx,
                        byte[] arr,
                        int start)

Parameters:

ctx - Context.

arr - Array.

start - Start.

Method Detail

copy

public KeyCacheObject copy(int part)

Specified by:

copy in interface KeyCacheObject

partition

public int partition()

Specified by:

partition in interface KeyCacheObject

partition

public void partition(int part)

Specified by:

partition in interface KeyCacheObject

cacheObjectType

public byte cacheObjectType()

Specified by:

cacheObjectType in interface CacheObject

isPlatformType

public boolean isPlatformType()

Specified by:

isPlatformType in interface CacheObject

internal

public boolean internal()

Specified by:

internal in interface KeyCacheObject

value

@Nullable
public <T> T value(CacheObjectValueContext ctx,
                   boolean cpy)

Specified by:

value in interface CacheObject

value

@Nullable
public <T> T value(CacheObjectValueContext ctx,
                   boolean cpy,
                   ClassLoader ldr)

Specified by:

value in interface CacheObject

valueBytes

public byte[] valueBytes(CacheObjectValueContext ctx)
                  throws IgniteCheckedException

Specified by:

valueBytes in interface CacheObject

Throws:

IgniteCheckedException

putValue

public boolean putValue(ByteBuffer buf)
                 throws IgniteCheckedException

Specified by:

putValue in interface CacheObject

Throws:

IgniteCheckedException

putValue

public int putValue(long addr)

Specified by:

putValue in interface CacheObject

putValue

public boolean putValue(ByteBuffer buf,
                        int off,
                        int len)
                 throws IgniteCheckedException

Specified by:

putValue in interface CacheObject

Throws:

IgniteCheckedException

valueBytesLength

public int valueBytesLength(CacheObjectValueContext ctx)
                     throws IgniteCheckedException

Specified by:

valueBytesLength in interface CacheObject

Throws:

IgniteCheckedException

prepareForCache

public CacheObject prepareForCache(CacheObjectValueContext ctx)

Specified by:

prepareForCache in interface CacheObject

finishUnmarshal

public void finishUnmarshal(CacheObjectValueContext ctx,
                            ClassLoader ldr)
                     throws IgniteCheckedException

Specified by:

finishUnmarshal in interface CacheObject

Throws:

IgniteCheckedException

prepareMarshal

public void prepareMarshal(CacheObjectValueContext ctx)

Specified by:

prepareMarshal in interface CacheObject

length

public int length()

detach

public BinaryObjectEx detach()

Specified by:

detach in interface BinaryObjectEx

detach

public BinaryObjectImpl detach(boolean checkCrossObjReferences)

Specified by:

detach in interface BinaryObjectEx

detached

public boolean detached()

Returns:

Detached or not.

detachAllowed

public void detachAllowed(boolean detachAllowed)

Specified by:

detachAllowed in interface BinaryObjectEx

context

public BinaryContext context()

Specified by:

context in interface BinaryObjectEx

context

public void context(BinaryContext ctx)

Parameters:

ctx - Context.

bytes

public byte[] bytes()

Specified by:

bytes in interface BinaryObjectEx

start

public int start()

Specified by:

start in interface BinaryObjectEx

offheapAddress

public long offheapAddress()

hasBytes

public boolean hasBytes()

Specified by:

hasBytes in interface BinaryObjectEx

isFlagSet

public boolean isFlagSet(short flag)

Specified by:

isFlagSet in interface BinaryObjectEx

typeId

public int typeId()

Specified by:

typeId in interface BinaryObjectEx

type

@Nullable
public @Nullable BinaryType type()
                          throws BinaryObjectException

Specified by:

type in interface BinaryObject

Throws:

BinaryObjectException

rawType

@Nullable
public @Nullable BinaryType rawType()
                             throws BinaryObjectException

Specified by:

rawType in interface BinaryObjectEx

Throws:

BinaryObjectException

field

@Nullable
public <F> F field(String fieldName)
            throws BinaryObjectException

Specified by:

field in interface BinaryObject

Throws:

BinaryObjectException

field

@Nullable
public <F> F field(int fieldId)
            throws BinaryObjectException

Throws:

BinaryObjectException

dataStartOffset

public int dataStartOffset()

footerStartOffset

public int footerStartOffset()

fieldByOrder

@Nullable
public <F> F fieldByOrder(int order)

writeFieldByOrder

public boolean writeFieldByOrder(int order,
                                 ByteBuffer buf)

field

@Nullable
protected <F> F field(org.apache.ignite.internal.binary.BinaryReaderHandles rCtx,
                      String fieldName)

hasField

public boolean hasField(String fieldName)

Specified by:

hasField in interface BinaryObject

deserialize

@Nullable
public <T> T deserialize(@Nullable
                         @Nullable ClassLoader ldr)
                  throws BinaryObjectException

Specified by:

deserialize in interface BinaryObject

Throws:

BinaryObjectException

deserialize

@Nullable
public <T> T deserialize()
                  throws BinaryObjectException

Specified by:

deserialize in interface BinaryObject

Throws:

BinaryObjectException

clone

public BinaryObject clone()
                   throws CloneNotSupportedException

Specified by:

clone in interface BinaryObject

Throws:

CloneNotSupportedException

hashCode

public int hashCode()

Specified by:

hashCode in interface KeyCacheObject

Overrides:

hashCode in class Object

hasSchema

public boolean hasSchema()

schemaId

public int schemaId()

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

size

public int size()

Specified by:

size in interface BinaryObject

toString

public String toString()

enumOrdinal

public int enumOrdinal()
                throws BinaryObjectException

Specified by:

enumOrdinal in interface BinaryObject

Throws:

BinaryObjectException

enumName

public String enumName()
                throws BinaryObjectException

Specified by:

enumName in interface BinaryObject

Throws:

BinaryObjectException

toBuilder

public BinaryObjectBuilder toBuilder()
                              throws BinaryObjectException

Specified by:

toBuilder in interface BinaryObject

Throws:

BinaryObjectException

equals

public boolean equals(Object arg0)

Overrides:

equals in class Object

hasCircularReferences

public boolean hasCircularReferences()

Specified by:

hasCircularReferences in interface BinaryObjectEx