org.apache.ignite.internal.processors.cacheobject

Interface IgniteCacheObjectProcessor

All Superinterfaces:

GridComponent, GridProcessor

All Known Subinterfaces:

CacheObjectPortableProcessor

All Known Implementing Classes:

CacheObjectPortableProcessorImpl, IgniteCacheObjectProcessorImpl

public interface IgniteCacheObjectProcessor
extends GridProcessor

Cache objects processor.

Nested Class Summary

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

GridComponent.DiscoveryDataExchangeType

Method Summary

Methods

Modifier and Type	Method and Description
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	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)
void	onUtilityCacheStarted()
CacheObject	prepareForCache(CacheObject obj, GridCacheContext cctx) Prepares cache object for cache (e.g. copies user-provided object if needed).
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)
int	typeId(Object obj)
int	typeId(String typeName)
Object	unmarshal(CacheObjectContext ctx, byte[] bytes, ClassLoader clsLdr)
Object	unwrapTemporary(GridCacheContext ctx, Object obj) Converts temporary off-heap object to heap-based.

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

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

Method Detail

onUtilityCacheStarted

void onUtilityCacheStarted()
                           throws IgniteCheckedException

Throws:

IgniteCheckedException - If failed.

See Also:

GridComponent.onKernalStart()

typeId

int typeId(String typeName)

Parameters:

typeName - Type name.

Returns:

Type ID.

typeId

int typeId(Object obj)

Parameters:

obj - Object to get type ID for.

Returns:

Type ID.

unwrapTemporary

@Nullable
Object unwrapTemporary(GridCacheContext ctx,
                              @Nullable
                              Object obj)
                       throws IgniteException

Converts temporary off-heap object to heap-based.

Parameters:

ctx - Context.

obj - Object.

Returns:

Heap-based object.

Throws:

IgniteException - In case of error.

prepareForCache

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

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

Parameters:

obj - Cache object.

cctx - Cache context.

Returns:

Object to be store in cache.

isPortableObject

boolean isPortableObject(Object obj)

Checks whether object is portable object.

Parameters:

obj - Object to check.

Returns:

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

isPortableEnabled

boolean isPortableEnabled(CacheConfiguration<?,?> ccfg)

Checks whether given class is portable.

Returns:

true If portable objects are enabled.

field

Object field(Object obj,
           String fieldName)

Parameters:

obj - Portable object to get field from.

fieldName - Field name.

Returns:

Field value.

hasField

boolean hasField(Object obj,
               String fieldName)

Checks whether field is set in the object.

Parameters:

obj - Object.

fieldName - Field name.

Returns:

true if field is set.

marshal

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

Parameters:

ctx - Cache object context.

val - Value.

Returns:

Value bytes.

Throws:

IgniteCheckedException - If failed.

unmarshal

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

Parameters:

ctx - Context.

bytes - Bytes.

clsLdr - Class loader.

Returns:

Unmarshalled object.

Throws:

IgniteCheckedException - If failed.

contextForCache

CacheObjectContext contextForCache(CacheConfiguration ccfg)
                                   throws IgniteCheckedException

Parameters:

ccfg - Cache configuration.

Returns:

Cache object context.

Throws:

IgniteCheckedException - If failed.

toCacheKeyObject

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

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
CacheObject toCacheObject(CacheObjectContext ctx,
                                 @Nullable
                                 Object obj,
                                 boolean userObj)

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

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

Parameters:

ctx - Cache context.

type - Object type.

bytes - Object bytes.

Returns:

Cache object.

toCacheObject

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

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.

immutable

boolean immutable(Object obj)

Parameters:

obj - Value.

Returns:

True if object is of known immutable type.