org.apache.ignite.internal.processors.platform.cache

Class PlatformCache

java.lang.Object

org.apache.ignite.internal.processors.platform.PlatformAbstractTarget

org.apache.ignite.internal.processors.platform.cache.PlatformCache

All Implemented Interfaces:

PlatformTarget

public class PlatformCache
extends PlatformAbstractTarget

Native cache wrapper implementation.

Field Summary

Fields

Modifier and Type	Field and Description
static int	OP_CLEAR
static int	OP_CLEAR_ALL
static int	OP_CLEAR_ALL_ASYNC
static int	OP_CLEAR_ASYNC
static int	OP_CLEAR_CACHE
static int	OP_CLEAR_CACHE_ASYNC
static int	OP_CLOSE_LOCK
static int	OP_CONTAINS_KEY
static int	OP_CONTAINS_KEY_ASYNC
static int	OP_CONTAINS_KEYS
static int	OP_CONTAINS_KEYS_ASYNC
static int	OP_ENTER_LOCK
static int	OP_EXIT_LOCK
static int	OP_EXTENSION
static int	OP_GET
static int	OP_GET_ALL
static int	OP_GET_ALL_ASYNC
static int	OP_GET_AND_PUT
static int	OP_GET_AND_PUT_ASYNC
static int	OP_GET_AND_PUT_IF_ABSENT
static int	OP_GET_AND_PUT_IF_ABSENT_ASYNC
static int	OP_GET_AND_REMOVE
static int	OP_GET_AND_REMOVE_ASYNC
static int	OP_GET_AND_REPLACE
static int	OP_GET_AND_REPLACE_ASYNC
static int	OP_GET_ASYNC
static int	OP_GET_CONFIG
static int	OP_GET_NAME
static int	OP_GLOBAL_METRICS
static int	OP_INVOKE
static int	OP_INVOKE_ALL
static int	OP_INVOKE_ALL_ASYNC
static int	OP_INVOKE_ASYNC
static int	OP_IS_LOCAL_LOCKED
static int	OP_ITERATOR
static int	OP_LOAD_ALL
static int	OP_LOAD_CACHE
static int	OP_LOAD_CACHE_ASYNC
static int	OP_LOC_EVICT
static int	OP_LOC_ITERATOR
static int	OP_LOC_LOAD_CACHE
static int	OP_LOC_LOAD_CACHE_ASYNC
static int	OP_LOC_PROMOTE
static int	OP_LOCAL_CLEAR
static int	OP_LOCAL_CLEAR_ALL
static int	OP_LOCAL_METRICS
static int	OP_LOCK
static int	OP_LOCK_ALL
static int	OP_PUT_ALL_ASYNC
static int	OP_PUT_ASYNC
static int	OP_PUT_IF_ABSENT
static int	OP_PUT_IF_ABSENT_ASYNC
static int	OP_QRY_CONTINUOUS
static int	OP_QRY_SCAN
static int	OP_QRY_SQL
static int	OP_QRY_SQL_FIELDS
static int	OP_QRY_TXT
static int	OP_REBALANCE
static int	OP_REMOVE_ALL
static int	OP_REMOVE_ALL_ASYNC
static int	OP_REMOVE_ALL2
static int	OP_REMOVE_ALL2_ASYNC
static int	OP_REMOVE_BOOL
static int	OP_REMOVE_BOOL_ASYNC
static int	OP_REMOVE_OBJ
static int	OP_REMOVE_OBJ_ASYNC
static int	OP_REPLACE_2
static int	OP_REPLACE_2_ASYNC
static int	OP_REPLACE_3
static int	OP_REPLACE_3_ASYNC
static int	OP_SIZE
static int	OP_SIZE_ASYNC
static int	OP_SIZE_LOC
static int	OP_TRY_ENTER_LOCK
static int	OP_WITH_ASYNC
static int	OP_WITH_EXPIRY_POLICY
static int	OP_WITH_KEEP_BINARY
static int	OP_WITH_NO_RETRIES
static int	OP_WITH_SKIP_STORE

Fields inherited from class org.apache.ignite.internal.processors.platform.PlatformAbstractTarget

ERROR, FALSE, log, platformCtx, TRUE

Constructor Summary

Constructors

Constructor and Description
PlatformCache(PlatformContext platformCtx, IgniteCache cache, boolean keepBinary) Constructor.
PlatformCache(PlatformContext platformCtx, IgniteCache cache, boolean keepBinary, PlatformCacheExtension[] exts) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
Exception	convertException(Exception e) Convert caught exception.
protected IgniteInternalFuture	currentFuture()
protected PlatformFutureUtils.Writer	futureWriter(int opId)
protected long	processInLongOutLong(int type, long val) Process IN operation.
protected long	processInStreamOutLong(int type, BinaryRawReaderEx reader, PlatformMemory mem) Process IN operation.
protected Object	processInStreamOutObject(int type, BinaryRawReaderEx reader) Process IN operation with managed object as result.
protected Object	processOutObject(int type) Process OUT operation.
protected void	processOutStream(int type, BinaryRawWriterEx writer) Process OUT operation.
IgniteCache	rawCache()
static void	writeCacheMetrics(BinaryRawWriter writer, CacheMetrics metrics) Writes cache metrics.
long	writeResult(PlatformMemory mem, Object obj) Writes the result to reused stream, if any.
long	writeResult(PlatformMemory mem, Object obj, PlatformWriterClosure clo) Writes the result to reused stream, if any.

Methods inherited from class org.apache.ignite.internal.processors.platform.PlatformAbstractTarget

inLongOutLong, inObjectStreamOutObjectStream, inStreamOutLong, inStreamOutObject, inStreamOutStream, listenFuture, listenFutureForOperation, outObject, outStream, platformContext, processInObjectStreamOutObjectStream, processInStreamOutLong, processInStreamOutStream, readAndListenFuture, readAndListenFuture, readAndListenFuture, readAndListenFuture, readAndListenFuture, throwUnsupported

Methods inherited from class java.lang.Object

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

Field Detail

OP_CLEAR

public static final int OP_CLEAR

See Also:

Constant Field Values

OP_CLEAR_ALL

public static final int OP_CLEAR_ALL

See Also:

Constant Field Values

OP_CONTAINS_KEY

public static final int OP_CONTAINS_KEY

See Also:

Constant Field Values

OP_CONTAINS_KEYS

public static final int OP_CONTAINS_KEYS

See Also:

Constant Field Values

OP_GET

public static final int OP_GET

See Also:

Constant Field Values

OP_GET_ALL

public static final int OP_GET_ALL

See Also:

Constant Field Values

OP_GET_AND_PUT

public static final int OP_GET_AND_PUT

See Also:

Constant Field Values

OP_GET_AND_PUT_IF_ABSENT

public static final int OP_GET_AND_PUT_IF_ABSENT

See Also:

Constant Field Values

OP_GET_AND_REMOVE

public static final int OP_GET_AND_REMOVE

See Also:

Constant Field Values

OP_GET_AND_REPLACE

public static final int OP_GET_AND_REPLACE

See Also:

Constant Field Values

OP_GET_NAME

public static final int OP_GET_NAME

See Also:

Constant Field Values

OP_INVOKE

public static final int OP_INVOKE

See Also:

Constant Field Values

OP_INVOKE_ALL

public static final int OP_INVOKE_ALL

See Also:

Constant Field Values

OP_IS_LOCAL_LOCKED

public static final int OP_IS_LOCAL_LOCKED

See Also:

Constant Field Values

OP_LOAD_CACHE

public static final int OP_LOAD_CACHE

See Also:

Constant Field Values

OP_LOC_EVICT

public static final int OP_LOC_EVICT

See Also:

Constant Field Values

OP_LOC_LOAD_CACHE

public static final int OP_LOC_LOAD_CACHE

See Also:

Constant Field Values

OP_LOC_PROMOTE

public static final int OP_LOC_PROMOTE

See Also:

Constant Field Values

OP_LOCAL_CLEAR

public static final int OP_LOCAL_CLEAR

See Also:

Constant Field Values

OP_LOCAL_CLEAR_ALL

public static final int OP_LOCAL_CLEAR_ALL

See Also:

Constant Field Values

OP_LOCK

public static final int OP_LOCK

See Also:

Constant Field Values

OP_LOCK_ALL

public static final int OP_LOCK_ALL

See Also:

Constant Field Values

OP_LOCAL_METRICS

public static final int OP_LOCAL_METRICS

See Also:

Constant Field Values

OP_PUT_IF_ABSENT

public static final int OP_PUT_IF_ABSENT

See Also:

Constant Field Values

OP_QRY_CONTINUOUS

public static final int OP_QRY_CONTINUOUS

See Also:

Constant Field Values

OP_QRY_SCAN

public static final int OP_QRY_SCAN

See Also:

Constant Field Values

OP_QRY_SQL

public static final int OP_QRY_SQL

See Also:

Constant Field Values

OP_QRY_SQL_FIELDS

public static final int OP_QRY_SQL_FIELDS

See Also:

Constant Field Values

OP_QRY_TXT

public static final int OP_QRY_TXT

See Also:

Constant Field Values

OP_REMOVE_ALL

public static final int OP_REMOVE_ALL

See Also:

Constant Field Values

OP_REMOVE_BOOL

public static final int OP_REMOVE_BOOL

See Also:

Constant Field Values

OP_REMOVE_OBJ

public static final int OP_REMOVE_OBJ

See Also:

Constant Field Values

OP_REPLACE_2

public static final int OP_REPLACE_2

See Also:

Constant Field Values

OP_REPLACE_3

public static final int OP_REPLACE_3

See Also:

Constant Field Values

OP_GET_CONFIG

public static final int OP_GET_CONFIG

See Also:

Constant Field Values

OP_LOAD_ALL

public static final int OP_LOAD_ALL

See Also:

Constant Field Values

OP_CLEAR_CACHE

public static final int OP_CLEAR_CACHE

See Also:

Constant Field Values

OP_WITH_ASYNC

public static final int OP_WITH_ASYNC

See Also:

Constant Field Values

OP_REMOVE_ALL2

public static final int OP_REMOVE_ALL2

See Also:

Constant Field Values

OP_WITH_KEEP_BINARY

public static final int OP_WITH_KEEP_BINARY

See Also:

Constant Field Values

OP_WITH_EXPIRY_POLICY

public static final int OP_WITH_EXPIRY_POLICY

See Also:

Constant Field Values

OP_WITH_NO_RETRIES

public static final int OP_WITH_NO_RETRIES

See Also:

Constant Field Values

OP_WITH_SKIP_STORE

public static final int OP_WITH_SKIP_STORE

See Also:

Constant Field Values

OP_SIZE

public static final int OP_SIZE

See Also:

Constant Field Values

OP_ITERATOR

public static final int OP_ITERATOR

See Also:

Constant Field Values

OP_LOC_ITERATOR

public static final int OP_LOC_ITERATOR

See Also:

Constant Field Values

OP_ENTER_LOCK

public static final int OP_ENTER_LOCK

See Also:

Constant Field Values

OP_EXIT_LOCK

public static final int OP_EXIT_LOCK

See Also:

Constant Field Values

OP_TRY_ENTER_LOCK

public static final int OP_TRY_ENTER_LOCK

See Also:

Constant Field Values

OP_CLOSE_LOCK

public static final int OP_CLOSE_LOCK

See Also:

Constant Field Values

OP_REBALANCE

public static final int OP_REBALANCE

See Also:

Constant Field Values

OP_SIZE_LOC

public static final int OP_SIZE_LOC

See Also:

Constant Field Values

OP_PUT_ASYNC

public static final int OP_PUT_ASYNC

See Also:

Constant Field Values

OP_CLEAR_CACHE_ASYNC

public static final int OP_CLEAR_CACHE_ASYNC

See Also:

Constant Field Values

OP_CLEAR_ALL_ASYNC

public static final int OP_CLEAR_ALL_ASYNC

See Also:

Constant Field Values

OP_REMOVE_ALL2_ASYNC

public static final int OP_REMOVE_ALL2_ASYNC

See Also:

Constant Field Values

OP_SIZE_ASYNC

public static final int OP_SIZE_ASYNC

See Also:

Constant Field Values

OP_CLEAR_ASYNC

public static final int OP_CLEAR_ASYNC

See Also:

Constant Field Values

OP_LOAD_CACHE_ASYNC

public static final int OP_LOAD_CACHE_ASYNC

See Also:

Constant Field Values

OP_LOC_LOAD_CACHE_ASYNC

public static final int OP_LOC_LOAD_CACHE_ASYNC

See Also:

Constant Field Values

OP_PUT_ALL_ASYNC

public static final int OP_PUT_ALL_ASYNC

See Also:

Constant Field Values

OP_REMOVE_ALL_ASYNC

public static final int OP_REMOVE_ALL_ASYNC

See Also:

Constant Field Values

OP_GET_ASYNC

public static final int OP_GET_ASYNC

See Also:

Constant Field Values

OP_CONTAINS_KEY_ASYNC

public static final int OP_CONTAINS_KEY_ASYNC

See Also:

Constant Field Values

OP_CONTAINS_KEYS_ASYNC

public static final int OP_CONTAINS_KEYS_ASYNC

See Also:

Constant Field Values

OP_REMOVE_BOOL_ASYNC

public static final int OP_REMOVE_BOOL_ASYNC

See Also:

Constant Field Values

OP_REMOVE_OBJ_ASYNC

public static final int OP_REMOVE_OBJ_ASYNC

See Also:

Constant Field Values

OP_GET_ALL_ASYNC

public static final int OP_GET_ALL_ASYNC

See Also:

Constant Field Values

OP_GET_AND_PUT_ASYNC

public static final int OP_GET_AND_PUT_ASYNC

See Also:

Constant Field Values

OP_GET_AND_PUT_IF_ABSENT_ASYNC

public static final int OP_GET_AND_PUT_IF_ABSENT_ASYNC

See Also:

Constant Field Values

OP_GET_AND_REMOVE_ASYNC

public static final int OP_GET_AND_REMOVE_ASYNC

See Also:

Constant Field Values

OP_GET_AND_REPLACE_ASYNC

public static final int OP_GET_AND_REPLACE_ASYNC

See Also:

Constant Field Values

OP_REPLACE_2_ASYNC

public static final int OP_REPLACE_2_ASYNC

See Also:

Constant Field Values

OP_REPLACE_3_ASYNC

public static final int OP_REPLACE_3_ASYNC

See Also:

Constant Field Values

OP_INVOKE_ASYNC

public static final int OP_INVOKE_ASYNC

See Also:

Constant Field Values

OP_INVOKE_ALL_ASYNC

public static final int OP_INVOKE_ALL_ASYNC

See Also:

Constant Field Values

OP_PUT_IF_ABSENT_ASYNC

public static final int OP_PUT_IF_ABSENT_ASYNC

See Also:

Constant Field Values

OP_EXTENSION

public static final int OP_EXTENSION

See Also:

Constant Field Values

OP_GLOBAL_METRICS

public static final int OP_GLOBAL_METRICS

See Also:

Constant Field Values

Constructor Detail

PlatformCache

public PlatformCache(PlatformContext platformCtx,
             IgniteCache cache,
             boolean keepBinary)

Constructor.

Parameters:

platformCtx - Context.

cache - Underlying cache.

keepBinary - Keep binary flag.

PlatformCache

public PlatformCache(PlatformContext platformCtx,
             IgniteCache cache,
             boolean keepBinary,
             PlatformCacheExtension[] exts)

Constructor.

Parameters:

platformCtx - Context.

cache - Underlying cache.

keepBinary - Keep binary flag.

exts - Extensions.

Method Detail

rawCache

public IgniteCache rawCache()

Returns:

Raw cache.

processInStreamOutLong

protected long processInStreamOutLong(int type,
                          BinaryRawReaderEx reader,
                          PlatformMemory mem)
                               throws IgniteCheckedException

Process IN operation.

Overrides:

processInStreamOutLong in class PlatformAbstractTarget

Parameters:

type - Type.

reader - Binary reader.

Returns:

Result.

Throws:

IgniteCheckedException - In case of exception.

writeResult

public long writeResult(PlatformMemory mem,
               Object obj)

Writes the result to reused stream, if any.

writeResult

public long writeResult(PlatformMemory mem,
               Object obj,
               PlatformWriterClosure clo)

Writes the result to reused stream, if any.

processInStreamOutObject

protected Object processInStreamOutObject(int type,
                              BinaryRawReaderEx reader)
                                   throws IgniteCheckedException

Process IN operation with managed object as result.

Overrides:

processInStreamOutObject in class PlatformAbstractTarget

Parameters:

type - Type.

reader - Binary reader.

Returns:

Result.

Throws:

IgniteCheckedException - In case of exception.

processOutStream

protected void processOutStream(int type,
                    BinaryRawWriterEx writer)
                         throws IgniteCheckedException

Process OUT operation.

Overrides:

processOutStream in class PlatformAbstractTarget

Parameters:

type - Type.

writer - Binary writer.

Throws:

IgniteCheckedException - In case of exception.

processOutObject

protected Object processOutObject(int type)
                           throws IgniteCheckedException

Process OUT operation.

Overrides:

processOutObject in class PlatformAbstractTarget

Parameters:

type - Type.

Throws:

IgniteCheckedException - In case of exception.

processInLongOutLong

protected long processInLongOutLong(int type,
                        long val)
                             throws IgniteCheckedException

Process IN operation.

Overrides:

processInLongOutLong in class PlatformAbstractTarget

Parameters:

type - Type.

val - Value.

Returns:

Result.

Throws:

IgniteCheckedException - In case of exception.

convertException

public Exception convertException(Exception e)

Convert caught exception.

Overrides:

convertException in class PlatformAbstractTarget

Parameters:

e - Exception to convert.

Returns:

Converted exception.

currentFuture

protected IgniteInternalFuture currentFuture()
                                      throws IgniteCheckedException

Overrides:

currentFuture in class PlatformAbstractTarget

Returns:

current future.

Throws:

IgniteCheckedException - If failed.

futureWriter

@Nullable
protected PlatformFutureUtils.Writer futureWriter(int opId)

Overrides:

futureWriter in class PlatformAbstractTarget

Parameters:

opId - Operation id.

Returns:

A custom writer for given op id.

writeCacheMetrics

public static void writeCacheMetrics(BinaryRawWriter writer,
                     CacheMetrics metrics)

Writes cache metrics.

Parameters:

writer - Writer.

metrics - Metrics.