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

Class CacheObjectPortableProcessorImpl

java.lang.Object

org.apache.ignite.internal.processors.GridProcessorAdapter

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

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

All Implemented Interfaces:

GridComponent, CacheObjectPortableProcessor, IgniteCacheObjectProcessor, GridProcessor

public class CacheObjectPortableProcessorImpl
extends IgniteCacheObjectProcessorImpl
implements CacheObjectPortableProcessor

Portable processor implementation.

Nested Class Summary

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

GridComponent.DiscoveryDataExchangeType

Field Summary

Fields

Modifier and Type	Field and Description
static String[]	FIELD_TYPE_NAMES

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

ctx, log

Constructor Summary

Constructors

Constructor and Description
CacheObjectPortableProcessorImpl(GridKernalContext ctx)

Method Summary

Methods

Modifier and Type	Method and Description
void	addMeta(int typeId, PortableMetadata newMeta)
Object	affinityKey(PortableObject po)
PortableBuilder	builder(int typeId)
PortableBuilder	builder(PortableObject portableObj) Creates builder initialized by existing portable object.
PortableBuilder	builder(String clsName)
CacheObjectContext	contextForCache(CacheConfiguration cfg)
Object	field(Object obj, String fieldName)
static int	fieldTypeId(String typeName)
static String	fieldTypeName(int typeId)
static Map<String,String>	fieldTypeNames(Map<String,Integer> typeIds)
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<PortableMetadata>	metadata()
Map<Integer,PortableMetadata>	metadata(Collection<Integer> typeIds)
PortableMetadata	metadata(int typeId)
void	onKernalStop(boolean cancel) Callback to notify that kernal is about to stop.
void	onUtilityCacheStarted()
PortableContext	portableContext()
IgnitePortables	portables()
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)

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

Field Detail

FIELD_TYPE_NAMES

public static final String[] FIELD_TYPE_NAMES

Constructor Detail

CacheObjectPortableProcessorImpl

public CacheObjectPortableProcessorImpl(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

fieldTypeId

public static int fieldTypeId(String typeName)

Parameters:

typeName - Field type name.

Returns:

Field type ID;

fieldTypeName

public static String fieldTypeName(int typeId)

Parameters:

typeId - Field type ID.

Returns:

Field type name.

fieldTypeNames

public static Map<String,String> fieldTypeNames(Map<String,Integer> typeIds)

Parameters:

typeIds - Field type IDs.

Returns:

Field type names.

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 PortableException

Parameters:

obj - Object.

Returns:

Bytes.

Throws:

PortableException - If failed.

unmarshal

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

Parameters:

ptr - Off-heap pointer.

forceHeap - If true creates heap-based object.

Returns:

Object.

Throws:

PortableException - If failed.

marshalToPortable

public Object marshalToPortable(@Nullable
                       Object obj)
                         throws PortableException

Specified by:

marshalToPortable in interface CacheObjectPortableProcessor

Parameters:

obj - Original object.

Returns:

Portable object (in case portable marshaller is used).

Throws:

PortableException

marshaller

public GridPortableMarshaller marshaller()

Returns:

Marshaller.

builder

public PortableBuilder builder(int typeId)

Specified by:

builder in interface CacheObjectPortableProcessor

Parameters:

typeId - Type ID.

Returns:

Builder.

builder

public PortableBuilder builder(String clsName)

Specified by:

builder in interface CacheObjectPortableProcessor

Parameters:

clsName - Class name.

Returns:

Builder.

builder

public PortableBuilder builder(PortableObject portableObj)

Creates builder initialized by existing portable object.

Specified by:

builder in interface CacheObjectPortableProcessor

Parameters:

portableObj - Portable object to edit.

Returns:

Portable builder.

updateMetaData

public void updateMetaData(int typeId,
                  String typeName,
                  @Nullable
                  String affKeyFieldName,
                  Map<String,Integer> fieldTypeIds)
                    throws PortableException

Specified by:

updateMetaData in interface CacheObjectPortableProcessor

Parameters:

typeId - Type ID.

typeName - Type name.

affKeyFieldName - Affinity key field name.

fieldTypeIds - Fields map.

Throws:

PortableException

addMeta

public void addMeta(int typeId,
           PortableMetadata newMeta)
             throws PortableException

Specified by:

addMeta in interface CacheObjectPortableProcessor

Parameters:

typeId - Type ID.

newMeta - New meta data.

Throws:

PortableException

metadata

@Nullable
public PortableMetadata metadata(int typeId)
                          throws PortableException

Specified by:

metadata in interface CacheObjectPortableProcessor

Parameters:

typeId - Type ID.

Returns:

Meta data.

Throws:

PortableException

metadata

public Map<Integer,PortableMetadata> metadata(Collection<Integer> typeIds)
                                       throws PortableException

Specified by:

metadata in interface CacheObjectPortableProcessor

Parameters:

typeIds - Type ID.

Returns:

Meta data.

Throws:

PortableException

metadata

public Collection<PortableMetadata> metadata()
                                      throws PortableException

Specified by:

metadata in interface CacheObjectPortableProcessor

Returns:

Metadata for all types.

Throws:

PortableException

portables

public IgnitePortables portables()
                          throws IgniteException

Specified by:

portables in interface CacheObjectPortableProcessor

Returns:

Portables 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(PortableObject 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 PortableException

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:

PortableException

toPortable

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

Parameters:

obj - Object.

Returns:

Portable object.

Throws:

IgniteException - In case of error.