org.apache.ignite.internal.processors.cache.portable

Class CacheObjectBinaryProcessorImpl

java.lang.Object

org.apache.ignite.internal.processors.GridProcessorAdapter

org.apache.ignite.internal.processors.cacheobject.IgniteCacheObjectProcessorImpl

org.apache.ignite.internal.processors.cache.portable.CacheObjectBinaryProcessorImpl

All Implemented Interfaces:

GridComponent, CacheObjectBinaryProcessor, IgniteCacheObjectProcessor, GridProcessor

public class CacheObjectBinaryProcessorImpl
extends IgniteCacheObjectProcessorImpl
implements CacheObjectBinaryProcessor

Portable processor implementation.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.ignite.internal.GridComponent

GridComponent.DiscoveryDataExchangeType

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

ctx, log

Constructor Summary

Constructors

Constructor and Description
CacheObjectBinaryProcessorImpl(GridKernalContext ctx)

Method Summary

Methods

Modifier and Type	Method and Description
void	addMeta(int typeId, BinaryType newMeta)
Object	affinityKey(BinaryObject po)
IgniteBinary	binary()
BinaryObject	buildEnum(String typeName, int ord)
BinaryObjectBuilder	builder(BinaryObject portableObj) Creates builder initialized by existing portable object.
BinaryObjectBuilder	builder(String clsName)
CacheObjectContext	contextForCache(CacheConfiguration cfg)
Object	field(Object obj, String fieldName)
boolean	hasField(Object obj, String fieldName) Checks whether field is set in the object.
boolean	isPortableEnabled(CacheConfiguration<?,?> ccfg) Checks whether given class is portable.
boolean	isPortableObject(Object obj) Checks whether object is portable object.
byte[]	marshal(CacheObjectContext ctx, Object val)
byte[]	marshal(Object obj)
GridPortableMarshaller	marshaller()
Object	marshalToPortable(Object obj)
Collection<BinaryType>	metadata()
Map<Integer,BinaryType>	metadata(Collection<Integer> typeIds)
BinaryType	metadata(int typeId)
void	onKernalStop(boolean cancel) Callback to notify that kernal is about to stop.
void	onUtilityCacheStarted()
PortableContext	portableContext()
void	start() Starts grid component.
KeyCacheObject	toCacheKeyObject(CacheObjectContext ctx, Object obj, boolean userObj)
CacheObject	toCacheObject(CacheObjectContext ctx, byte type, byte[] bytes)
CacheObject	toCacheObject(CacheObjectContext ctx, Object obj, boolean userObj)
CacheObject	toCacheObject(GridCacheContext ctx, long valPtr, boolean tmp)
Object	toPortable(Object obj)
int	typeId(Object obj)
int	typeId(String typeName)
Object	unmarshal(CacheObjectContext ctx, byte[] bytes, ClassLoader clsLdr)
Object	unmarshal(long ptr, boolean forceHeap)
Object	unwrapTemporary(GridCacheContext ctx, Object obj) Converts temporary off-heap object to heap-based.
void	updateMetadata(int typeId, String typeName, String affKeyFieldName, Map<String,Integer> fieldTypeIds, boolean isEnum)

Methods inherited from class org.apache.ignite.internal.processors.cacheobject.IgniteCacheObjectProcessorImpl

immutable, prepareForCache, toCacheKeyObject0, toCacheObject0

Methods inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

assertParameter, collectDiscoveryData, discoveryDataType, onDisconnected, onDiscoveryDataReceived, onKernalStart, onReconnected, printMemoryStats, stop, toString, validateNode

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.processors.cacheobject.IgniteCacheObjectProcessor

immutable, prepareForCache

Methods inherited from interface org.apache.ignite.internal.GridComponent

collectDiscoveryData, discoveryDataType, onDisconnected, onDiscoveryDataReceived, onKernalStart, onReconnected, printMemoryStats, stop, validateNode

Constructor Detail

CacheObjectBinaryProcessorImpl

public CacheObjectBinaryProcessorImpl(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

start

public void start()
           throws IgniteCheckedException

Starts grid component.

Specified by:

start in interface GridComponent

Overrides:

start in class GridProcessorAdapter

Throws:

IgniteCheckedException - Throws in case of any errors.

onUtilityCacheStarted

public void onUtilityCacheStarted()
                           throws IgniteCheckedException

Specified by:

onUtilityCacheStarted in interface IgniteCacheObjectProcessor

Overrides:

onUtilityCacheStarted in class IgniteCacheObjectProcessorImpl

Throws:

IgniteCheckedException - If failed.

See Also:

GridComponent.onKernalStart()

onKernalStop

public void onKernalStop(boolean cancel)

Callback to notify that kernal is about to stop.

Specified by:

onKernalStop in interface GridComponent

Overrides:

onKernalStop in class GridProcessorAdapter

Parameters:

cancel - Flag indicating whether jobs should be canceled.

typeId

public int typeId(String typeName)

Specified by:

typeId in interface IgniteCacheObjectProcessor

Overrides:

typeId in class IgniteCacheObjectProcessorImpl

Parameters:

typeName - Type name.

Returns:

Type ID.

marshal

public byte[] marshal(@Nullable
             Object obj)
               throws BinaryObjectException

Parameters:

obj - Object.

Returns:

Bytes.

Throws:

BinaryObjectException - If failed.

unmarshal

public Object unmarshal(long ptr,
               boolean forceHeap)
                 throws BinaryObjectException

Parameters:

ptr - Off-heap pointer.

forceHeap - If true creates heap-based object.

Returns:

Object.

Throws:

BinaryObjectException - If failed.

marshalToPortable

public Object marshalToPortable(@Nullable
                       Object obj)
                         throws BinaryObjectException

Specified by:

marshalToPortable in interface CacheObjectBinaryProcessor

Parameters:

obj - Original object.

Returns:

Portable object (in case portable marshaller is used).

Throws:

BinaryObjectException

marshaller

public GridPortableMarshaller marshaller()

Returns:

Marshaller.

builder

public BinaryObjectBuilder builder(String clsName)

Specified by:

builder in interface CacheObjectBinaryProcessor

Parameters:

clsName - Class name.

Returns:

Builder.

builder

public BinaryObjectBuilder builder(BinaryObject portableObj)

Creates builder initialized by existing portable object.

Specified by:

builder in interface CacheObjectBinaryProcessor

Parameters:

portableObj - Portable object to edit.

Returns:

Portable builder.

updateMetadata

public void updateMetadata(int typeId,
                  String typeName,
                  @Nullable
                  String affKeyFieldName,
                  Map<String,Integer> fieldTypeIds,
                  boolean isEnum)
                    throws BinaryObjectException

Specified by:

updateMetadata in interface CacheObjectBinaryProcessor

Parameters:

typeId - Type ID.

typeName - Type name.

affKeyFieldName - Affinity key field name.

fieldTypeIds - Fields map.

isEnum - Enum flag.

Throws:

BinaryObjectException

addMeta

public void addMeta(int typeId,
           BinaryType newMeta)
             throws BinaryObjectException

Specified by:

addMeta in interface CacheObjectBinaryProcessor

Parameters:

typeId - Type ID.

newMeta - New meta data.

Throws:

BinaryObjectException

metadata

@Nullable
public BinaryType metadata(int typeId)
                    throws BinaryObjectException

Specified by:

metadata in interface CacheObjectBinaryProcessor

Parameters:

typeId - Type ID.

Returns:

Meta data.

Throws:

BinaryObjectException

metadata

public Map<Integer,BinaryType> metadata(Collection<Integer> typeIds)
                                 throws BinaryObjectException

Specified by:

metadata in interface CacheObjectBinaryProcessor

Parameters:

typeIds - Type ID.

Returns:

Meta data.

Throws:

BinaryObjectException

metadata

public Collection<BinaryType> metadata()
                                throws BinaryObjectException

Specified by:

metadata in interface CacheObjectBinaryProcessor

Returns:

Metadata for all types.

Throws:

BinaryObjectException

buildEnum

public BinaryObject buildEnum(String typeName,
                     int ord)
                       throws IgniteException

Specified by:

buildEnum in interface CacheObjectBinaryProcessor

Parameters:

typeName - Type name.

ord - ordinal.

Returns:

Enum object.

Throws:

IgniteException - If failed.

binary

public IgniteBinary binary()
                    throws IgniteException

Specified by:

binary in interface CacheObjectBinaryProcessor

Specified by:

binary in interface IgniteCacheObjectProcessor

Overrides:

binary in class IgniteCacheObjectProcessorImpl

Returns:

Ignite binary interface.

Throws:

IgniteException - If failed.

isPortableObject

public boolean isPortableObject(Object obj)

Checks whether object is portable object.

Specified by:

isPortableObject in interface IgniteCacheObjectProcessor

Overrides:

isPortableObject in class IgniteCacheObjectProcessorImpl

Parameters:

obj - Object to check.

Returns:

True if object is already a portable object, false otherwise.

isPortableEnabled

public boolean isPortableEnabled(CacheConfiguration<?,?> ccfg)

Checks whether given class is portable.

Specified by:

isPortableEnabled in interface IgniteCacheObjectProcessor

Overrides:

isPortableEnabled in class IgniteCacheObjectProcessorImpl

Returns:

true If portable objects are enabled.

affinityKey

public Object affinityKey(BinaryObject po)

Parameters:

po - Portable object.

Returns:

Affinity key.

typeId

public int typeId(Object obj)

Specified by:

typeId in interface IgniteCacheObjectProcessor

Overrides:

typeId in class IgniteCacheObjectProcessorImpl

Parameters:

obj - Object to get type ID for.

Returns:

Type ID.

field

public Object field(Object obj,
           String fieldName)

Specified by:

field in interface IgniteCacheObjectProcessor

Overrides:

field in class IgniteCacheObjectProcessorImpl

Parameters:

obj - Portable object to get field from.

fieldName - Field name.

Returns:

Field value.

hasField

public boolean hasField(Object obj,
               String fieldName)

Checks whether field is set in the object.

Specified by:

hasField in interface IgniteCacheObjectProcessor

Overrides:

hasField in class IgniteCacheObjectProcessorImpl

Parameters:

obj - Object.

fieldName - Field name.

Returns:

true if field is set.

portableContext

public PortableContext portableContext()

Returns:

Portable context.

contextForCache

public CacheObjectContext contextForCache(CacheConfiguration cfg)
                                   throws IgniteCheckedException

Specified by:

contextForCache in interface IgniteCacheObjectProcessor

Overrides:

contextForCache in class IgniteCacheObjectProcessorImpl

Parameters:

cfg - Cache configuration.

Returns:

Cache object context.

Throws:

IgniteCheckedException - If failed.

marshal

public byte[] marshal(CacheObjectContext ctx,
             Object val)
               throws IgniteCheckedException

Specified by:

marshal in interface IgniteCacheObjectProcessor

Overrides:

marshal in class IgniteCacheObjectProcessorImpl

Parameters:

ctx - Cache object context.

val - Value.

Returns:

Value bytes.

Throws:

IgniteCheckedException - If failed.

unmarshal

public Object unmarshal(CacheObjectContext ctx,
               byte[] bytes,
               ClassLoader clsLdr)
                 throws IgniteCheckedException

Specified by:

unmarshal in interface IgniteCacheObjectProcessor

Overrides:

unmarshal in class IgniteCacheObjectProcessorImpl

Parameters:

ctx - Context.

bytes - Bytes.

clsLdr - Class loader.

Returns:

Unmarshalled object.

Throws:

IgniteCheckedException - If failed.

toCacheKeyObject

public KeyCacheObject toCacheKeyObject(CacheObjectContext ctx,
                              Object obj,
                              boolean userObj)

Specified by:

toCacheKeyObject in interface IgniteCacheObjectProcessor

Overrides:

toCacheKeyObject in class IgniteCacheObjectProcessorImpl

Parameters:

ctx - Cache context.

obj - Key value.

userObj - If true then given object is object provided by user and should be copied before stored in cache.

Returns:

Cache key object.

toCacheObject

@Nullable
public CacheObject toCacheObject(CacheObjectContext ctx,
                                 @Nullable
                                 Object obj,
                                 boolean userObj)

Specified by:

toCacheObject in interface IgniteCacheObjectProcessor

Overrides:

toCacheObject in class IgniteCacheObjectProcessorImpl

Parameters:

ctx - Cache context.

obj - Object.

userObj - If true then given object is object provided by user and should be copied before stored in cache.

Returns:

Cache object.

toCacheObject

public CacheObject toCacheObject(CacheObjectContext ctx,
                        byte type,
                        byte[] bytes)

Specified by:

toCacheObject in interface IgniteCacheObjectProcessor

Overrides:

toCacheObject in class IgniteCacheObjectProcessorImpl

Parameters:

ctx - Cache context.

type - Object type.

bytes - Object bytes.

Returns:

Cache object.

toCacheObject

public CacheObject toCacheObject(GridCacheContext ctx,
                        long valPtr,
                        boolean tmp)
                          throws IgniteCheckedException

Specified by:

toCacheObject in interface IgniteCacheObjectProcessor

Overrides:

toCacheObject in class IgniteCacheObjectProcessorImpl

Parameters:

ctx - Context.

valPtr - Value pointer.

tmp - If true can return temporary instance which is valid while entry lock is held.

Returns:

Cache object.

Throws:

IgniteCheckedException - If failed.

unwrapTemporary

public Object unwrapTemporary(GridCacheContext ctx,
                     Object obj)
                       throws BinaryObjectException

Converts temporary off-heap object to heap-based.

Specified by:

unwrapTemporary in interface IgniteCacheObjectProcessor

Overrides:

unwrapTemporary in class IgniteCacheObjectProcessorImpl

Parameters:

ctx - Context.

obj - Object.

Returns:

Heap-based object.

Throws:

BinaryObjectException

toPortable

@Nullable
public Object toPortable(@Nullable
                         Object obj)
                  throws IgniteException

Parameters:

obj - Object.

Returns:

Portable object.

Throws:

IgniteException - In case of error.