org.apache.ignite.internal.processors.cacheobject

Class IgniteCacheObjectProcessorImpl

java.lang.Object

org.apache.ignite.internal.processors.GridProcessorAdapter

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

All Implemented Interfaces:

GridComponent, IgniteCacheObjectProcessor, GridProcessor

Direct Known Subclasses:

CacheObjectBinaryProcessorImpl

public class IgniteCacheObjectProcessorImpl
extends GridProcessorAdapter
implements IgniteCacheObjectProcessor

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, diagnosticLog, log

Constructor Summary

Constructors

Constructor and Description
IgniteCacheObjectProcessorImpl(GridKernalContext ctx)

Method Summary

Modifier and Type	Method and Description
IgniteBinary	binary()
CacheObjectContext	contextForCache(CacheConfiguration ccfg)
Object	field(Object obj, String fieldName)
boolean	hasField(Object obj, String fieldName) Checks whether field is set in the object.
boolean	immutable(Object obj)
boolean	isBinaryEnabled(CacheConfiguration<?,?> ccfg) Checks whether given class is binary.
boolean	isBinaryObject(Object obj) Checks whether object is binary object.
byte[]	marshal(CacheObjectValueContext ctx, Object val)
void	onContinuousProcessorStarted(GridKernalContext ctx)
protected int	partition(CacheObjectContext ctx, GridCacheContext cctx, Object obj)
CacheObject	prepareForCache(CacheObject obj, GridCacheContext cctx) Prepares cache object for cache (e.g. copies user-provided object if needed).
KeyCacheObject	toCacheKeyObject(CacheObjectContext ctx, GridCacheContext cctx, Object obj, boolean userObj)
protected KeyCacheObject	toCacheKeyObject0(CacheObjectContext ctx, GridCacheContext cctx, Object obj, boolean userObj)
CacheObject	toCacheObject(CacheObjectContext ctx, ByteBuffer buf)
IncompleteCacheObject	toCacheObject(CacheObjectContext ctx, ByteBuffer buf, IncompleteCacheObject incompleteObj)
CacheObject	toCacheObject(CacheObjectContext ctx, byte type, byte[] bytes)
CacheObject	toCacheObject(CacheObjectContext ctx, Object obj, boolean userObj)
protected CacheObject	toCacheObject0(Object obj, boolean userObj)
IncompleteCacheObject	toKeyCacheObject(CacheObjectContext ctx, ByteBuffer buf, IncompleteCacheObject incompleteObj)
KeyCacheObject	toKeyCacheObject(CacheObjectContext ctx, byte type, byte[] bytes)
int	typeId(Object obj)
int	typeId(String typeName)
Object	unmarshal(CacheObjectValueContext ctx, byte[] bytes, ClassLoader clsLdr)
Object	unwrapTemporary(GridCacheContext ctx, Object obj) Converts temporary off-heap object to heap-based.

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

assertParameter, collectGridNodeData, collectJoiningNodeData, discoveryDataType, onDisconnected, onGridDataReceived, onJoiningNodeDataReceived, onKernalStart, onKernalStop, onReconnected, printMemoryStats, start, stop, toString, validateNode, 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.GridComponent

collectGridNodeData, collectJoiningNodeData, discoveryDataType, onDisconnected, onGridDataReceived, onJoiningNodeDataReceived, onKernalStart, onKernalStop, onReconnected, printMemoryStats, start, stop, validateNode, validateNode

Constructor Detail

IgniteCacheObjectProcessorImpl

public IgniteCacheObjectProcessorImpl(GridKernalContext ctx)

Parameters:

ctx - Context.

Method Detail

binary

public IgniteBinary binary()

Specified by:

binary in interface IgniteCacheObjectProcessor

Returns:

Ignite binary interface.

prepareForCache

@Nullable
public CacheObject prepareForCache(@Nullable
                                             CacheObject obj,
                                             GridCacheContext cctx)

Prepares cache object for cache (e.g. copies user-provided object if needed).

Specified by:

prepareForCache in interface IgniteCacheObjectProcessor

Parameters:

obj - Cache object.

cctx - Cache context.

Returns:

Object to be store in cache.

marshal

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

Specified by:

marshal in interface IgniteCacheObjectProcessor

Parameters:

ctx - Cache object context.

val - Value.

Returns:

Value bytes.

Throws:

IgniteCheckedException - If failed.

unmarshal

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

Specified by:

unmarshal in interface IgniteCacheObjectProcessor

Parameters:

ctx - Context.

bytes - Bytes.

clsLdr - Class loader.

Returns:

Unmarshalled object.

Throws:

IgniteCheckedException - If failed.

toCacheKeyObject

public KeyCacheObject toCacheKeyObject(CacheObjectContext ctx,
                                       @Nullable
                                       GridCacheContext cctx,
                                       Object obj,
                                       boolean userObj)

Specified by:

toCacheKeyObject in interface IgniteCacheObjectProcessor

Parameters:

ctx - Cache objects context.

cctx - Cache context if cache is available.

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.

toCacheKeyObject0

protected KeyCacheObject toCacheKeyObject0(CacheObjectContext ctx,
                                           @Nullable
                                           GridCacheContext cctx,
                                           Object obj,
                                           boolean userObj)

Parameters:

obj - Object.

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

Returns:

Key cache object.

toCacheObject

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

Specified by:

toCacheObject in interface IgniteCacheObjectProcessor

Parameters:

ctx - Cache context.

type - Object type.

bytes - Object bytes.

Returns:

Cache object.

toKeyCacheObject

public KeyCacheObject toKeyCacheObject(CacheObjectContext ctx,
                                       byte type,
                                       byte[] bytes)
                                throws IgniteCheckedException

Specified by:

toKeyCacheObject in interface IgniteCacheObjectProcessor

Parameters:

ctx - Cache context.

type - Object type.

bytes - Object bytes.

Returns:

Cache object.

Throws:

IgniteCheckedException

toCacheObject

public CacheObject toCacheObject(CacheObjectContext ctx,
                                 ByteBuffer buf)

Specified by:

toCacheObject in interface IgniteCacheObjectProcessor

Parameters:

ctx - Cache context.

buf - Buffer to read from.

Returns:

Cache object.

toCacheObject

public IncompleteCacheObject toCacheObject(CacheObjectContext ctx,
                                           ByteBuffer buf,
                                           @Nullable
                                           IncompleteCacheObject incompleteObj)
                                    throws IgniteCheckedException

Specified by:

toCacheObject in interface IgniteCacheObjectProcessor

Parameters:

ctx - Cache object context.

buf - Buffer.

incompleteObj - Incomplete cache object or null if it's a first read.

Returns:

Incomplete cache object.

Throws:

IgniteCheckedException - If fail.

toKeyCacheObject

public IncompleteCacheObject toKeyCacheObject(CacheObjectContext ctx,
                                              ByteBuffer buf,
                                              @Nullable
                                              IncompleteCacheObject incompleteObj)
                                       throws IgniteCheckedException

Specified by:

toKeyCacheObject in interface IgniteCacheObjectProcessor

Parameters:

ctx - Cache object context.

buf - Buffer.

incompleteObj - Incomplete cache object or null if it's a first read.

Returns:

Incomplete cache object.

Throws:

IgniteCheckedException - If fail.

toCacheObject

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

Specified by:

toCacheObject in interface IgniteCacheObjectProcessor

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.

toCacheObject0

protected CacheObject toCacheObject0(@Nullable
                                     Object obj,
                                     boolean userObj)

Parameters:

obj - Object.

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

Returns:

Cache object.

partition

protected final int partition(CacheObjectContext ctx,
                              @Nullable
                              GridCacheContext cctx,
                              Object obj)

Parameters:

ctx - Cache objects context.

cctx - Cache context.

obj - Object.

Returns:

Object partition.

contextForCache

public CacheObjectContext contextForCache(CacheConfiguration ccfg)
                                   throws IgniteCheckedException

Specified by:

contextForCache in interface IgniteCacheObjectProcessor

Parameters:

ccfg - Cache configuration.

Returns:

Cache object context.

Throws:

IgniteCheckedException - If failed.

immutable

public boolean immutable(Object obj)

Specified by:

immutable in interface IgniteCacheObjectProcessor

Parameters:

obj - Value.

Returns:

True if object is of known immutable type.

onContinuousProcessorStarted

public void onContinuousProcessorStarted(GridKernalContext ctx)
                                  throws IgniteCheckedException

Specified by:

onContinuousProcessorStarted in interface IgniteCacheObjectProcessor

Parameters:

ctx - Context.

Throws:

IgniteCheckedException - If failed.

typeId

public int typeId(String typeName)

Specified by:

typeId in interface IgniteCacheObjectProcessor

Parameters:

typeName - Type name.

Returns:

Type ID.

unwrapTemporary

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

Converts temporary off-heap object to heap-based.

Specified by:

unwrapTemporary in interface IgniteCacheObjectProcessor

Parameters:

ctx - Context.

obj - Object.

Returns:

Heap-based object.

Throws:

IgniteException - In case of error.

isBinaryObject

public boolean isBinaryObject(Object obj)

Checks whether object is binary object.

Specified by:

isBinaryObject in interface IgniteCacheObjectProcessor

Parameters:

obj - Object to check.

Returns:

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

isBinaryEnabled

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

Checks whether given class is binary.

Specified by:

isBinaryEnabled in interface IgniteCacheObjectProcessor

Returns:

true If binary objects are enabled.

typeId

public int typeId(Object obj)

Specified by:

typeId in interface IgniteCacheObjectProcessor

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

Parameters:

obj - Binary 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

Parameters:

obj - Object.

fieldName - Field name.

Returns:

true if field is set.