org.apache.ignite.internal.processors.cacheobject

Interface IgniteCacheObjectProcessor

All Superinterfaces:

GridComponent, GridProcessor

All Known Subinterfaces:

CacheObjectBinaryProcessor

All Known Implementing Classes:

CacheObjectBinaryProcessorImpl, 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
String	affinityField(String keyType)
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(CacheObjectContext ctx, Object val)
void	onContinuousProcessorStarted(GridKernalContext ctx)
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, GridCacheContext cctx, 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

onContinuousProcessorStarted

void onContinuousProcessorStarted(GridKernalContext ctx)
                                  throws IgniteCheckedException

Parameters:

ctx - Context.

Throws:

IgniteCheckedException - If failed.

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.

isBinaryObject

boolean isBinaryObject(Object obj)

Checks whether object is binary object.

Parameters:

obj - Object to check.

Returns:

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

isBinaryEnabled

boolean isBinaryEnabled(CacheConfiguration<?,?> ccfg)

Checks whether given class is binary.

Returns:

true If binary objects are enabled.

field

Object field(Object obj,
           String fieldName)

Parameters:

obj - Binary 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,
                              @Nullable
                              GridCacheContext cctx,
                              Object obj,
                              boolean userObj)

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.

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.

binary

IgniteBinary binary()

Returns:

Ignite binary interface.

affinityField

String affinityField(String keyType)

Parameters:

keyType - Key type name.

Returns:

Affinity filed name or null.