| Modifier and Type | Method and Description |
|---|---|
static GridTcpRouter |
GridRouterFactory.startTcpRouter(GridTcpRouterConfiguration cfg)
Starts a TCP router with given configuration.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
GridRouterCommandLineStartup.main(String[] args)
Wrapper method to run router from command-line.
|
void |
GridTcpRouterImpl.start()
Starts router.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridDeploymentException
Deployment or re-deployment failed.
|
class |
GridEmptyProjectionException
This exception defines illegal call on empty projection.
|
class |
GridFutureCancelledException
Future computation cannot be retrieved because it was cancelled.
|
class |
GridFutureTimeoutException
Future computation completion is timed out.
|
class |
GridInterruptedException
This exception is used to wrap standard
InterruptedException into GridException. |
class |
GridTopologyException
This exception is used to indicate error with grid topology (e.g., crashed node, etc.).
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridFuture.cancel()
Cancels this future.
|
void |
Grid.close()
Closes
this instance of grid. |
R |
GridFuture.get()
Synchronously waits for completion of the computation and
returns computation result.
|
R |
GridFuture.get(long timeout)
Synchronously waits for completion of the computation for
up to the timeout specified and returns computation result.
|
R |
GridFuture.get(long timeout,
TimeUnit unit)
Synchronously waits for completion of the computation for
up to the timeout specified and returns computation result.
|
Collection<InetSocketAddress> |
GridAddressResolver.getExternalAddresses(InetSocketAddress addr)
Maps internal address to a collection of external addresses.
|
<K> Map<GridNode,Collection<K>> |
Grid.mapKeysToNodes(String cacheName,
Collection<? extends K> keys)
This method provides ability to detect which cache keys are mapped to which nodes
on cache instance with given name.
|
<K> GridNode |
Grid.mapKeyToNode(String cacheName,
K key)
This method provides ability to detect which cache keys are mapped to which nodes
on cache instance with given name.
|
GridProjectionMetrics |
GridProjection.metrics()
Gets a metrics snapshot for this projection.
|
void |
GridLifecycleBean.onLifecycleEvent(GridLifecycleEventType evt)
This method is called when lifecycle event occurs.
|
void |
Grid.restartNodes()
Restarts nodes satisfying optional set of predicates.
|
void |
Grid.restartNodes(Collection<UUID> ids)
Restarts nodes defined by provided IDs.
|
void |
GridLifecycleAware.start()
Starts grid component, called on grid start.
|
static Grid |
GridGain.start()
Starts grid with default configuration.
|
static Grid |
GridGain.start(GridConfiguration cfg)
Starts grid with given configuration.
|
static Grid |
GridGain.start(String springCfgPath)
Starts all grids specified within given Spring XML configuration file.
|
static Grid |
GridGain.start(URL springCfgUrl)
Starts all grids specified within given Spring XML configuration file URL.
|
GridFuture<Collection<GridTuple3<String,Boolean,String>>> |
Grid.startNodes(Collection<Map<String,Object>> hosts,
Map<String,Object> dflts,
boolean restart,
int timeout,
int maxConn)
Starts one or more nodes on remote host(s).
|
GridFuture<Collection<GridTuple3<String,Boolean,String>>> |
Grid.startNodes(File file,
boolean restart,
int timeout,
int maxConn)
Starts one or more nodes on remote host(s).
|
void |
GridLifecycleAware.stop()
Stops grid component, called on grid shutdown.
|
void |
Grid.stopNodes()
Stops nodes satisfying optional set of predicates.
|
void |
Grid.stopNodes(Collection<UUID> ids)
Stops nodes defined by provided IDs.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridCachePartialUpdateException
Exception thrown from non-transactional cache in case when update succeeded only partially.
|
class |
GridCacheTxHeuristicException
Exception thrown whenever grid transaction enters an unknown state.
|
class |
GridCacheTxOptimisticException
Exception thrown whenever grid transactions fail optimistically.
|
class |
GridCacheTxRollbackException
Exception thrown whenever grid transactions has been automatically rolled back.
|
class |
GridCacheTxTimeoutException
Exception thrown whenever grid transactions time out.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheTx.close()
Ends the transaction.
|
void |
GridCacheTx.commit()
Commits this transaction by initiating
two-phase-commit process. |
boolean |
GridCacheEntry.compact()
Optimizes the size of this entry.
|
boolean |
GridCacheProjection.compact(K key)
Clears serialized value bytes from entry (if any) leaving only object representation.
|
void |
GridCacheProjection.compactAll()
Clears serialized value bytes from cache entries (if any) leaving only object representation.
|
V |
GridCacheEntry.get()
This method has the same semantic as
GridCacheProjection.get(Object) method. |
V |
GridCacheProjection.get(K key)
Retrieves value mapped to the specified key from cache.
|
Map<K,V> |
GridCacheProjection.getAll(Collection<? extends K> keys)
Retrieves values mapped to the specified keys from cache.
|
void |
GridCacheProjection.globalClearAll()
Clears cache on all nodes that store it's data.
|
void |
GridCache.loadCache(GridBiPredicate<K,V> p,
long ttl,
Object... args)
Delegates to
GridCacheStore.loadCache(GridBiInClosure,Object...) method
to load state from the underlying persistent storage. |
boolean |
GridCacheProjection.lock(K key,
long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
Synchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
boolean |
GridCacheEntry.lock(long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
Synchronously acquires lock on a cached object associated with this entry
only if the passed in filter (if any) passes.
|
boolean |
GridCacheProjection.lockAll(Collection<? extends K> keys,
long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
All or nothing synchronous lock for passed in keys.
|
int |
GridCacheEntry.memorySize()
Gets size of serialized key and value in addition to any overhead added by
GridGain itself. |
Iterator<Map.Entry<K,V>> |
GridCache.offHeapIterator()
Gets iterator over keys and values belonging to this cache off-heap memory on local node.
|
long |
GridCache.overflowSize()
Gets size (in bytes) of all entries swapped to disk.
|
V |
GridCacheEntry.peek(Collection<GridCachePeekMode> modes)
This method has the same semantic as
GridCacheProjection.peek(Object, Collection) method. |
V |
GridCacheProjection.peek(K key,
Collection<GridCachePeekMode> modes)
Peeks at cached value using optional set of peek modes.
|
V |
GridCacheProjection.promote(K key)
This method promotes cache entry from offheap by given key, if any, from offheap or swap storage
into memory.
|
void |
GridCacheProjection.promoteAll(Collection<? extends K> keys)
This method unswaps cache entries by given keys, if any, from swap storage
into memory.
|
V |
GridCacheProjection.put(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
Stores given key-value pair in cache.
|
void |
GridCacheProjection.putAll(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>... filter)
Stores given key-value pairs in cache.
|
V |
GridCacheProjection.putIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
boolean |
GridCacheProjection.putx(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
Stores given key-value pair in cache.
|
boolean |
GridCacheProjection.putxIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
V |
GridCacheEntry.reload()
This method has the same semantic as
GridCacheProjection.reload(Object) method. |
V |
GridCacheProjection.reload(K key)
Reloads a single key from persistent storage.
|
void |
GridCacheProjection.reloadAll()
Reloads all currently cached keys form persistent storage.
|
void |
GridCacheProjection.reloadAll(Collection<? extends K> keys)
Reloads specified entries from underlying persistent storage.
|
V |
GridCacheEntry.remove(GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.remove(Object, GridPredicate[]) method. |
V |
GridCacheProjection.remove(K key,
GridPredicate<GridCacheEntry<K,V>>... filter)
Removes given key mapping from cache.
|
boolean |
GridCacheProjection.remove(K key,
V val)
Removes given key mapping from cache if one exists and value is equal to the passed in value.
|
boolean |
GridCacheEntry.remove(V val)
This method has the same semantic as
GridCacheProjection.remove(Object, Object) method. |
void |
GridCacheProjection.removeAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter)
Removes given key mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
GridCacheProjection.removeAll(GridPredicate<GridCacheEntry<K,V>>... filter)
Removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
boolean |
GridCacheEntry.removex(GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.removex(Object, GridPredicate[]) method. |
boolean |
GridCacheProjection.removex(K key,
GridPredicate<GridCacheEntry<K,V>>... filter)
Removes given key mapping from cache.
|
V |
GridCacheProjection.replace(K key,
V val)
Stores given key-value pair in cache only if if there is a previous mapping for it.
|
boolean |
GridCacheProjection.replace(K key,
V oldVal,
V newVal)
Stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
V |
GridCacheEntry.replace(V val)
This method has the same semantic as
GridCacheProjection.replace(Object, Object) method. |
boolean |
GridCacheEntry.replace(V oldVal,
V newVal)
This method has the same semantic as
GridCacheProjection.replace(Object, Object, Object) method. |
boolean |
GridCacheProjection.replacex(K key,
V val)
Stores given key-value pair in cache only if only if there is a previous mapping for it.
|
boolean |
GridCacheEntry.replacex(V val)
This method has the same semantic as
GridCacheProjection.replacex(Object, Object) method. |
void |
GridCacheTx.rollback()
Rolls back this transaction.
|
V |
GridCacheEntry.set(V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.put(Object, Object, GridPredicate[]) method. |
V |
GridCacheEntry.setIfAbsent(V val)
This method has the same semantic as
GridCacheProjection.putIfAbsent(Object, Object) method. |
boolean |
GridCacheEntry.setx(V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.putx(Object, Object, GridPredicate[]) method. |
boolean |
GridCacheEntry.setxIfAbsent(V val)
This method has the same semantic as
GridCacheProjection.putxIfAbsent(Object, Object) method. |
Iterator<Map.Entry<K,V>> |
GridCache.swapIterator()
Gets iterator over keys and values belonging to this cache swap space on local node.
|
long |
GridCache.swapKeys()
Gets number of swap entries (keys).
|
long |
GridCache.swapSize()
Gets size in bytes for swap space.
|
void |
GridCacheEntry.transform(GridClosure<V,V> transformer)
This method has the same semantic as
GridCacheProjection.transform(Object, GridClosure) method. |
void |
GridCacheProjection.transform(K key,
GridClosure<V,V> transformer)
Stores result of applying
valTransform closure to the previous value associated with
given key in cache. |
void |
GridCacheProjection.transformAll(Map<? extends K,? extends GridClosure<V,V>> m)
Stores result of applying transform closures from the given map to previous values associated
with corresponding keys in cache.
|
void |
GridCacheProjection.transformAll(Set<? extends K> keys,
GridClosure<V,V> transformer)
Stores result of applying the specified transform closure to previous values associated
with the specified keys in cache.
|
GridFuture<?> |
GridCacheProjection.transformAllAsync(Set<? extends K> keys,
GridClosure<V,V> transformer)
Stores result of applying the specified transform closure to previous values associated
with the specified keys in cache.
|
<R> R |
GridCacheProjection.transformAndCompute(K key,
GridClosure<V,GridBiTuple<V,R>> transformer)
Applies
transformer closure to the previous value associated with given key in cache,
closure should return GridBiTuple instance where first value is new value stored in cache
and second value is returned as result of this method. |
GridCacheTx |
GridCacheProjection.txStartAffinity(Object affinityKey,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts
affinity-group-locked transaction based on affinity key. |
GridCacheTx |
GridCacheProjection.txStartPartition(int partId,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts
partition-group-locked transaction based on partition ID. |
void |
GridCacheEntry.unlock(GridPredicate<GridCacheEntry<K,V>>... filter)
Unlocks this entry only if current thread owns the lock.
|
void |
GridCacheProjection.unlock(K key,
GridPredicate<GridCacheEntry<K,V>>... filter)
Unlocks given key only if current thread owns the lock.
|
void |
GridCacheProjection.unlockAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter)
Unlocks given keys only if current thread owns the locks.
|
| Modifier and Type | Method and Description |
|---|---|
<T> T |
GridCacheCloner.cloneValue(T val) |
<T> T |
GridCacheDeepCloner.cloneValue(T val) |
<T> T |
GridCacheBasicCloner.cloneValue(T val) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridCacheDataStructureInvalidException
This checked exception gets thrown if attempt to access an invalid data structure has been made.
|
class |
GridCacheDataStructureRemovedException
This checked exception gets thrown if attempt to access a removed data structure has been made.
|
| Modifier and Type | Method and Description |
|---|---|
long |
GridCacheAtomicLong.addAndGet(long l)
Adds
l and gets current value of atomic long. |
long |
GridCacheAtomicSequence.addAndGet(long l)
Adds
l elements to atomic sequence and gets value of atomic sequence. |
GridCacheAtomicLong |
GridCacheDataStructures.atomicLong(String name,
long initVal,
boolean create)
Will get a atomic long from cache and create one if it has not been created yet and
create flag
is true. |
<T> GridCacheAtomicReference<T> |
GridCacheDataStructures.atomicReference(String name,
T initVal,
boolean create)
Will get a atomic reference from cache and create one if it has not been created yet and
create flag
is true. |
GridCacheAtomicSequence |
GridCacheDataStructures.atomicSequence(String name,
long initVal,
boolean create)
Will get an atomic sequence from cache and create one if it has not been created yet and
create flag
is true. |
<T,S> GridCacheAtomicStamped<T,S> |
GridCacheDataStructures.atomicStamped(String name,
T initVal,
S initStamp,
boolean create)
Will get a atomic stamped from cache and create one if it has not been created yet and
create flag
is true. |
void |
GridCacheCountDownLatch.await()
Causes the current thread to wait until the latch has counted down to
zero, unless current thread is interrupted.
|
boolean |
GridCacheCountDownLatch.await(long timeout)
Causes the current thread to wait until the latch has counted down to
zero, unless the thread is interrupted, or the specified waiting time elapses.
|
boolean |
GridCacheCountDownLatch.await(long timeout,
TimeUnit unit)
Causes the current thread to wait until the latch has counted down to
zero, unless the thread is interrupted, or the specified waiting time elapses.
|
boolean |
GridCacheQueue.bounded()
Returns
true if this queue is bounded. |
int |
GridCacheQueue.capacity()
Gets maximum number of elements of the queue.
|
boolean |
GridCacheQueue.collocated()
Returns
true if this queue can be kept on the one node only. |
boolean |
GridCacheSet.collocated()
Returns
true if this set can be kept on the one node only. |
boolean |
GridCacheAtomicLong.compareAndSet(long expVal,
long newVal)
Atomically compares current value to the expected value, and if they are equal, sets current value
to new value.
|
boolean |
GridCacheAtomicReference.compareAndSet(T expVal,
T newVal)
Conditionally sets the new value.
|
boolean |
GridCacheAtomicStamped.compareAndSet(T expVal,
T newVal,
S expStamp,
S newStamp)
Conditionally sets the new value and new stamp.
|
int |
GridCacheCountDownLatch.countDown()
Decrements the count of the latch, releasing all waiting threads
on all nodes if the count reaches zero.
|
int |
GridCacheCountDownLatch.countDown(int val)
Decreases the count of the latch using passed in value,
releasing all waiting threads on all nodes if the count reaches zero.
|
void |
GridCacheCountDownLatch.countDownAll()
Counts down this latch to zero, releasing all waiting threads on all nodes.
|
GridCacheCountDownLatch |
GridCacheDataStructures.countDownLatch(String name,
int cnt,
boolean autoDel,
boolean create)
Gets or creates count down latch.
|
long |
GridCacheAtomicLong.decrementAndGet()
Decrements and gets current value of atomic long.
|
long |
GridCacheAtomicLong.get()
Gets current value of atomic long.
|
T |
GridCacheAtomicReference.get()
Gets current value of an atomic reference.
|
GridBiTuple<T,S> |
GridCacheAtomicStamped.get()
Gets both current value and current stamp of atomic stamped.
|
long |
GridCacheAtomicSequence.get()
Gets current value of atomic sequence.
|
long |
GridCacheAtomicLong.getAndAdd(long l)
Gets current value of atomic long and adds
l. |
long |
GridCacheAtomicSequence.getAndAdd(long l)
Gets current value of atomic sequence and adds
l elements. |
long |
GridCacheAtomicLong.getAndDecrement()
Gets and decrements current value of atomic long.
|
long |
GridCacheAtomicLong.getAndIncrement()
Gets and increments current value of atomic long.
|
long |
GridCacheAtomicSequence.getAndIncrement()
Gets and increments current value of atomic sequence.
|
long |
GridCacheAtomicLong.getAndSet(long l)
Gets current value of atomic long and sets new value
l of atomic long. |
long |
GridCacheAtomicLong.incrementAndGet()
Increments and gets current value of atomic long.
|
long |
GridCacheAtomicSequence.incrementAndGet()
Increments and returns the value of atomic sequence.
|
<T> GridCacheQueue<T> |
GridCacheDataStructures.queue(String name,
int cap,
boolean collocated,
boolean create)
Will get a named queue from cache and create one if it has not been created yet and
create flag
is true. |
boolean |
GridCacheDataStructures.removeAtomicLong(String name)
Remove atomic long from cache.
|
boolean |
GridCacheDataStructures.removeAtomicReference(String name)
Remove atomic reference from cache.
|
boolean |
GridCacheDataStructures.removeAtomicSequence(String name)
Remove sequence from cache.
|
boolean |
GridCacheDataStructures.removeAtomicStamped(String name)
Remove atomic stamped from cache.
|
boolean |
GridCacheDataStructures.removeCountDownLatch(String name)
Removes count down latch from cache.
|
boolean |
GridCacheDataStructures.removeQueue(String name)
Remove queue from cache.
|
boolean |
GridCacheDataStructures.removeQueue(String name,
int batchSize)
Remove queue from cache.
|
boolean |
GridCacheDataStructures.removeSet(String name)
Removes set from cache.
|
<T> GridCacheSet<T> |
GridCacheDataStructures.set(String name,
boolean collocated,
boolean create)
Will get a named set from cache and create one if it has not been created yet and
create flag
is true. |
void |
GridCacheAtomicReference.set(T val)
Unconditionally sets the value.
|
void |
GridCacheAtomicStamped.set(T val,
S stamp)
Unconditionally sets the value and the stamp.
|
S |
GridCacheAtomicStamped.stamp()
Gets current stamp.
|
T |
GridCacheAtomicStamped.value()
Gets current value.
|
| Modifier and Type | Method and Description |
|---|---|
int |
GridCacheQueryFuture.available()
Returns number of elements that are already fetched and can
be returned from
GridCacheQueryFuture.next() method without blocking. |
boolean |
GridCacheQueryFuture.cancel()
Cancels this query future and stop receiving any further results for the query
associated with this future.
|
void |
GridCacheContinuousQuery.close()
Stops continuous query execution.
|
void |
GridCacheContinuousQuery.execute()
Starts continuous query execution on the whole grid.
|
void |
GridCacheContinuousQuery.execute(GridProjection prj)
Starts continuous query execution on provided set of nodes.
|
T |
GridCacheQueryFuture.next()
Returns next element from result set.
|
| Modifier and Type | Method and Description |
|---|---|
protected abstract Iterator<I> |
GridCacheLoadOnlyStoreAdapter.inputIterator(Object... args)
Returns iterator of input records.
|
V |
GridCacheLoadOnlyStoreAdapter.load(GridCacheTx tx,
K key)
Loads value for the key from underlying persistent storage.
|
V |
GridCacheStore.load(GridCacheTx tx,
K key)
Loads value for the key from underlying persistent storage.
|
void |
GridCacheLoadOnlyStoreAdapter.loadAll(GridCacheTx tx,
Collection<? extends K> keys,
GridBiInClosure<K,V> c)
Loads all values for given keys and passes every value to the provided closure.
|
void |
GridCacheStore.loadAll(GridCacheTx tx,
Collection<? extends K> keys,
GridBiInClosure<K,V> c)
Loads all values for given keys and passes every value to the provided closure.
|
void |
GridCacheStoreAdapter.loadAll(GridCacheTx tx,
Collection<? extends K> keys,
GridBiInClosure<K,V> c)
Loads all values for given keys and passes every value to the provided closure.
|
void |
GridCacheLoadOnlyStoreAdapter.loadCache(GridBiInClosure<K,V> c,
Object... args)
Loads all values from underlying persistent storage.
|
void |
GridCacheStore.loadCache(GridBiInClosure<K,V> clo,
Object... args)
Loads all values from underlying persistent storage.
|
void |
GridCacheStoreAdapter.loadCache(GridBiInClosure<K,V> clo,
Object... args)
Default empty implementation.
|
void |
GridCacheLoadOnlyStoreAdapter.put(GridCacheTx tx,
K key,
V val)
Stores a given value in persistent storage.
|
void |
GridCacheStore.put(GridCacheTx tx,
K key,
V val)
Stores a given value in persistent storage.
|
void |
GridCacheLoadOnlyStoreAdapter.putAll(GridCacheTx tx,
Map<? extends K,? extends V> map)
Stores given key value pairs in persistent storage.
|
void |
GridCacheStore.putAll(GridCacheTx tx,
Map<? extends K,? extends V> map)
Stores given key value pairs in persistent storage.
|
void |
GridCacheStoreAdapter.putAll(GridCacheTx tx,
Map<? extends K,? extends V> map)
Stores given key value pairs in persistent storage.
|
void |
GridCacheLoadOnlyStoreAdapter.remove(GridCacheTx tx,
K key)
Removes the value identified by given key from persistent storage.
|
void |
GridCacheStore.remove(GridCacheTx tx,
K key)
Removes the value identified by given key from persistent storage.
|
void |
GridCacheLoadOnlyStoreAdapter.removeAll(GridCacheTx tx,
Collection<? extends K> keys)
Removes all vales identified by given keys from persistent storage.
|
void |
GridCacheStore.removeAll(GridCacheTx tx,
Collection<? extends K> keys)
Removes all vales identified by given keys from persistent storage.
|
void |
GridCacheStoreAdapter.removeAll(GridCacheTx tx,
Collection<? extends K> keys)
Removes all vales identified by given keys from persistent storage.
|
void |
GridCacheLoadOnlyStoreAdapter.txEnd(GridCacheTx tx,
boolean commit)
Tells store to commit or rollback a transaction depending on the value of the
'commit'
parameter. |
void |
GridCacheStore.txEnd(GridCacheTx tx,
boolean commit)
Tells store to commit or rollback a transaction depending on the value of the
'commit'
parameter. |
void |
GridCacheStoreAdapter.txEnd(GridCacheTx tx,
boolean commit)
Default empty implementation for ending transactions.
|
| Modifier and Type | Method and Description |
|---|---|
protected <X> X |
GridCacheJdbcBlobStore.fromBytes(byte[] bytes)
Deserialize object from byte array using marshaller.
|
V |
GridCacheJdbcBlobStore.load(GridCacheTx tx,
K key)
Loads value for the key from underlying persistent storage.
|
void |
GridCacheJdbcBlobStore.put(GridCacheTx tx,
K key,
V val)
Stores a given value in persistent storage.
|
void |
GridCacheJdbcBlobStore.remove(GridCacheTx tx,
K key)
Removes the value identified by given key from persistent storage.
|
protected byte[] |
GridCacheJdbcBlobStore.toBytes(Object obj)
Serialize object to byte array using marshaller.
|
void |
GridCacheJdbcBlobStore.txEnd(GridCacheTx tx,
boolean commit)
Default empty implementation for ending transactions.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridComputeExecutionRejectedException
This exception defines execution rejection.
|
class |
GridComputeTaskCancelledException
This exception indicates that grid task was cancelled.
|
class |
GridComputeTaskTimeoutException
This exception indicates that task execution timed out.
|
class |
GridComputeUserUndeclaredException
This exception is thrown when user's code throws undeclared runtime exception.
|
| Modifier and Type | Method and Description |
|---|---|
GridException |
GridComputeJobResult.getException()
Gets exception produced by execution of remote job, or
null if
remote execution finished normally and did not produce any exceptions. |
| Modifier and Type | Method and Description |
|---|---|
void |
GridComputeJobSibling.cancel()
Sends a request to cancel this sibling.
|
void |
GridCompute.cancelJob(GridUuid jobId)
Cancels job with the given job ID, if it is currently running inside this projection.
|
void |
GridCompute.cancelTask(GridUuid sesId)
Cancels task with the given execution session ID, if it currently running inside this projection.
|
Object |
GridComputeJob.execute()
Executes this job.
|
R |
GridComputeTaskFuture.get()
Synchronously waits for completion of the computation and
returns computation result.
|
R |
GridComputeTaskFuture.get(long timeout)
Synchronously waits for completion of the computation for
up to the timeout specified and returns computation result.
|
R |
GridComputeTaskFuture.get(long timeout,
TimeUnit unit)
Synchronously waits for completion of the computation for
up to the timeout specified and returns computation result.
|
GridNode |
GridComputeLoadBalancer.getBalancedNode(GridComputeJob job,
Collection<GridNode> exclNodes)
Gets the next balanced node according to the underlying load balancing policy.
|
GridComputeJobSibling |
GridComputeTaskSession.getJobSibling(GridUuid jobId)
Gets job sibling for a given ID.
|
Collection<GridComputeJobSibling> |
GridComputeTaskSession.getJobSiblings()
Gets a collection of all grid job siblings.
|
<T> T |
GridComputeTaskSession.loadCheckpoint(String key)
Loads job's state previously saved via
GridComputeTaskSession.saveCheckpoint(String, Object, GridComputeTaskSessionScope, long)
method from an underlying storage for a given key. |
void |
GridCompute.localDeployTask(Class<? extends GridComputeTask> taskCls,
ClassLoader clsLdr)
Explicitly deploys a task with given class loader on the local node.
|
Map<? extends GridComputeJob,GridNode> |
GridComputeTaskSplitAdapter.map(List<GridNode> subgrid,
T arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends GridComputeJob,GridNode> |
GridComputeTask.map(List<GridNode> subgrid,
T arg)
This method is called to map or split grid task into multiple grid jobs.
|
void |
GridComputeJobMasterLeaveAware.onMasterNodeLeft(GridComputeTaskSession ses)
A method which is executed in case master node has left topology during job execution.
|
R |
GridComputeTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
Collection<GridComputeJobSibling> |
GridComputeTaskSession.refreshJobSiblings()
Refreshes collection of job siblings.
|
boolean |
GridComputeTaskSession.removeCheckpoint(String key)
Removes previously saved job's state for a given
key from an underlying storage. |
GridComputeJobResultPolicy |
GridComputeTaskAdapter.result(GridComputeJobResult res,
List<GridComputeJobResult> rcvd)
Default implementation which will wait for all jobs to complete before
calling
GridComputeTask.reduce(List) method. |
GridComputeJobResultPolicy |
GridComputeTask.result(GridComputeJobResult res,
List<GridComputeJobResult> rcvd)
Asynchronous callback invoked every time a result from remote execution is
received.
|
void |
GridComputeTaskSession.saveCheckpoint(String key,
Object state)
Saves intermediate state of a job or task to a storage.
|
void |
GridComputeTaskSession.saveCheckpoint(String key,
Object state,
GridComputeTaskSessionScope scope,
long timeout)
Saves intermediate state of a job to a storage.
|
void |
GridComputeTaskSession.saveCheckpoint(String key,
Object state,
GridComputeTaskSessionScope scope,
long timeout,
boolean overwrite)
Saves intermediate state of a job or task to a storage.
|
void |
GridComputeTaskContinuousMapper.send(Collection<? extends GridComputeJob> jobs)
Sends collection of jobs to nodes automatically picked by the underlying load balancer.
|
void |
GridComputeTaskContinuousMapper.send(GridComputeJob job)
Sends job to a node automatically picked by the underlying load balancer.
|
void |
GridComputeTaskContinuousMapper.send(GridComputeJob job,
GridNode node)
Sends given job to a specific grid node.
|
void |
GridComputeTaskContinuousMapper.send(Map<? extends GridComputeJob,GridNode> mappedJobs)
Sends collection of grid jobs to assigned nodes.
|
void |
GridComputeTaskSession.setAttribute(Object key,
Object val)
Sets session attributed.
|
void |
GridComputeTaskSession.setAttributes(Map<?,?> attrs)
Sets task attributes.
|
protected abstract Collection<? extends GridComputeJob> |
GridComputeTaskSplitAdapter.split(int gridSize,
T arg)
This is a simplified version of
GridComputeTask.map(List, Object) method. |
void |
GridCompute.undeployTask(String taskName)
Makes the best attempt to undeploy a task with given name from this grid projection.
|
boolean |
GridComputeTaskFuture.waitForMap()
Waits until
GridComputeTask.map(List, Object) method completes. |
boolean |
GridComputeTaskFuture.waitForMap(long timeout)
Waits for a specified timeout in milliseconds for
GridComputeTask.map(List, Object)
method to complete. |
boolean |
GridComputeTaskFuture.waitForMap(long timeout,
TimeUnit unit)
Waits for a specified timeout in milliseconds for
GridComputeTask.map(List, Object)
method to complete. |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridifyInterceptor.isGridify(Annotation gridify,
GridifyArgument arg)
This method is called before actual grid-enabling happens.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridifySetToSetAbstractAspect.checkIsSplitToJobsAllowed(GridifyRangeArgument arg,
GridifySetToSet ann)
Check if split allowed for input argument.
|
protected void |
GridifySetToValueAbstractAspect.checkIsSplitToJobsAllowed(GridifyRangeArgument arg,
GridifySetToValue ann)
Check if split allowed for input argument.
|
protected void |
GridifySetToValueAbstractAspect.checkMethodSignature(Method mtd)
Check method signature.
|
protected void |
GridifySetToSetAbstractAspect.checkMethodSignature(Method mtd)
Check method signature.
|
protected Object |
GridifySetToSetAbstractAspect.execute(GridProjection subgrid,
Class<?> cls,
GridifyRangeArgument arg,
GridifyNodeFilter nodeFilter,
int threshold,
int splitSize,
long timeout)
Execute method on grid.
|
protected Object |
GridifySetToValueAbstractAspect.execute(Method mtd,
GridProjection subgrid,
Class<?> cls,
GridifyRangeArgument arg,
GridifyNodeFilter nodeFilter,
int threshold,
int splitSize,
long timeout)
Execute method on grid.
|
Map<? extends GridComputeJob,GridNode> |
GridifyDefaultTask.map(List<GridNode> subgrid,
GridifyArgument arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends GridComputeJob,GridNode> |
GridifyDefaultRangeTask.map(List<GridNode> subgrid,
GridifyRangeArgument arg)
This method is called to map or split grid task into multiple grid jobs.
|
Collection<?> |
GridifyDefaultRangeTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
Object |
GridifyDefaultTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
| Modifier and Type | Method and Description |
|---|---|
GridFuture<?> |
GridDataLoader.addData(K key,
V val)
Adds data for loading on remote node.
|
GridFuture<?> |
GridDataLoader.addData(Map.Entry<K,V> entry)
Adds data for loading on remote node.
|
void |
GridDataLoader.close()
Closes data loader.
|
void |
GridDataLoader.close(boolean cancel)
Loads any remaining data and closes this loader.
|
void |
GridDataLoader.flush()
Loads any remaining data, but doesn't close the loader.
|
void |
GridDataLoader.isolated(boolean isolated)
Sets flag indicating that this data loader should assume that there are no other concurrent updates to the cache.
|
GridFuture<?> |
GridDataLoader.removeData(K key)
Adds key for removal on remote node.
|
void |
GridDataLoader.tryFlush()
Makes an attempt to load remaining data.
|
void |
GridDataLoadCacheUpdater.update(GridCache<K,V> cache,
Collection<Map.Entry<K,V>> entries)
Updates cache with batch of entries.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridDrSenderHubStoreCorruptedException
Exception thrown in case data center replication sender hub store was corrupted.
|
class |
GridDrSenderHubStoreOverflowException
Exception thrown when data center replication sender hub store cannot persist more entries.
|
| Modifier and Type | Method and Description |
|---|---|
GridDrSenderHubStoreCursor |
GridDrSenderHubStore.cursor(byte dataCenterId)
Gets cursor for the given data center ID.
|
GridDrSenderHubStoreEntry |
GridDrSenderHubStoreCursor.next()
Get next entry from that cursor.
|
void |
GridDrSenderHubStore.store(byte[] dataCenterIds,
byte[] data)
Store data.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridDrSenderHubFsStore.clear()
Clears store.
|
GridDrSenderHubStoreCursor |
GridDrSenderHubFsStore.cursor(byte dataCenterId)
Gets cursor for the given data center ID.
|
long |
GridDrSenderHubFsStore.redoBytesSize(byte dataCenterId) |
void |
GridDrSenderHubFsStore.start()
Starts grid component, called on grid start.
|
void |
GridDrSenderHubFsStore.store(byte[] dataCenters,
byte[] data)
Store data.
|
| Modifier and Type | Method and Description |
|---|---|
GridDrSenderHubStoreCursor |
GridDrSenderHubInMemoryStore.cursor(byte dataCenterId)
Gets cursor for the given data center ID.
|
void |
GridDrSenderHubInMemoryStore.store(byte[] dataCenterIds,
byte[] data)
Store data.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridGgfsConcurrentModificationException
GGFS exception indicating that file system structure was modified concurrently. |
class |
GridGgfsCorruptedFileException
Exception thrown when target file's block is not found in data cache.
|
class |
GridGgfsException
GGFS exception thrown by file system components. |
class |
GridGgfsFileNotFoundException
GGFS exception indicating that target resource is not found. |
class |
GridGgfsInvalidHdfsVersionException
Exception thrown when GridGain detects that remote HDFS version differs from version of HDFS libraries
in GridGain classpath.
|
class |
GridGgfsInvalidPathException
GGFS exception indicating that operation target is invalid
(e.g. |
class |
GridGgfsIoException
This exception is used to wrap standard
IOException into GridException. |
class |
GridGgfsOutOfSpaceException
GGFS exception that is thrown when it detected out-of-space condition. |
class |
GridGgfsParentNotDirectoryException
Exception thrown when parent supposed to be a directory is a file.
|
class |
GridGgfsPathAlreadyExistsException
Exception thrown when target path supposed to be created already exists.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<GridGgfsBlockLocation> |
GridGgfs.affinity(GridGgfsPath path,
long start,
long len)
Gets affinity block locations for data blocks of the file, i.e.
|
Collection<GridGgfsBlockLocation> |
GridGgfs.affinity(GridGgfsPath path,
long start,
long len,
long maxLen)
Get affinity block locations for data blocks of the file.
|
GridGgfsOutputStream |
GridGgfs.append(GridGgfsPath path,
boolean create)
Opens an output stream to an existing file for appending data.
|
GridGgfsOutputStream |
GridGgfs.append(GridGgfsPath path,
int bufSize,
boolean create,
Map<String,String> props)
Opens an output stream to an existing file for appending data.
|
GridGgfsOutputStream |
GridGgfs.create(GridGgfsPath path,
boolean overwrite)
Creates a file and opens it for writing.
|
GridGgfsOutputStream |
GridGgfs.create(GridGgfsPath path,
int bufSize,
boolean overwrite,
GridUuid affKey,
int replication,
long blockSize,
Map<String,String> props)
Creates a file and opens it for writing.
|
boolean |
GridGgfs.delete(GridGgfsPath path,
boolean recursive)
Deletes file.
|
<T,R> GridFuture<R> |
GridGgfs.execute(Class<? extends GridGgfsTask<T,R>> taskCls,
GridGgfsRecordResolver rslvr,
Collection<GridGgfsPath> paths,
boolean skipNonExistentFiles,
long maxRangeLen,
T arg)
Executes GGFS task asynchronously with overridden maximum range length (see
GridGgfsConfiguration.getMaximumTaskRangeLength() for more information). |
<T,R> GridFuture<R> |
GridGgfs.execute(Class<? extends GridGgfsTask<T,R>> taskCls,
GridGgfsRecordResolver rslvr,
Collection<GridGgfsPath> paths,
T arg)
Executes GGFS task asynchronously.
|
<T,R> GridFuture<R> |
GridGgfs.execute(GridGgfsTask<T,R> task,
GridGgfsRecordResolver rslvr,
Collection<GridGgfsPath> paths,
boolean skipNonExistentFiles,
long maxRangeLen,
T arg)
Executes GGFS task asynchronously with overridden maximum range length (see
GridGgfsConfiguration.getMaximumTaskRangeLength() for more information). |
<T,R> GridFuture<R> |
GridGgfs.execute(GridGgfsTask<T,R> task,
GridGgfsRecordResolver rslvr,
Collection<GridGgfsPath> paths,
T arg)
Executes GGFS task asynchronously.
|
boolean |
GridGgfs.exists(GridGgfsPath path)
Checks if the specified path exists in the file system.
|
GridFuture<?> |
GridGgfs.format()
Formats the file system removing all existing entries from it.
|
GridGgfsFile |
GridGgfs.info(GridGgfsPath path)
Gets file information for the specified path.
|
Collection<GridGgfsFile> |
GridGgfs.listFiles(GridGgfsPath path)
Lists files under the specified path.
|
Collection<GridGgfsPath> |
GridGgfs.listPaths(GridGgfsPath path)
Lists file paths under the specified path.
|
GridGgfsMetrics |
GridGgfs.metrics()
Gets metrics snapshot for this file system.
|
void |
GridGgfs.mkdirs(GridGgfsPath path)
Creates directories under specified path.
|
void |
GridGgfs.mkdirs(GridGgfsPath path,
Map<String,String> props)
Creates directories under specified path with the specified properties.
|
GridGgfsInputStream |
GridGgfs.open(GridGgfsPath path)
Opens a file for reading.
|
GridGgfsInputStream |
GridGgfs.open(GridGgfsPath path,
int bufSize)
Opens a file for reading.
|
GridGgfsInputStream |
GridGgfs.open(GridGgfsPath path,
int bufSize,
int seqReadsBeforePrefetch)
Opens a file for reading.
|
void |
GridGgfs.rename(GridGgfsPath src,
GridGgfsPath dest)
Renames/moves a file.
|
void |
GridGgfs.resetMetrics()
Resets metrics for this file system.
|
void |
GridGgfs.setTimes(GridGgfsPath path,
long accessTime,
long modificationTime)
Sets last access time and last modification time for a given path.
|
long |
GridGgfs.size(GridGgfsPath path)
Determines size of the file denoted by provided path.
|
GridGgfsPathSummary |
GridGgfs.summary(GridGgfsPath path)
Gets summary (total number of files, total number of directories and total length)
for a given path.
|
GridGgfsFile |
GridGgfs.update(GridGgfsPath path,
Map<String,String> props)
Updates file information for the specified path.
|
| Modifier and Type | Method and Description |
|---|---|
abstract GridGgfsJob |
GridGgfsTask.createJob(GridGgfsPath path,
GridGgfsFileRange range,
GridGgfsTaskArgs<T> args)
Callback invoked during task map procedure to create job that will process specified split
for GGFS file.
|
Object |
GridGgfsJob.execute(GridGgfs ggfs,
GridGgfsFileRange range,
GridGgfsInputStream in)
Executes this job.
|
Object |
GridGgfsInputStreamJobAdapter.execute(GridGgfs ggfs,
GridGgfsFileRange range,
GridGgfsInputStream in)
Executes this job.
|
abstract Object |
GridGgfsInputStreamJobAdapter.execute(GridGgfs ggfs,
GridGgfsRangeInputStream in)
Executes this job.
|
Map<? extends GridComputeJob,GridNode> |
GridGgfsTask.map(List<GridNode> subgrid,
GridGgfsTaskArgs<T> args)
This method is called to map or split grid task into multiple grid jobs.
|
GridGgfsFileRange |
GridGgfsRecordResolver.resolveRecords(GridGgfs ggfs,
GridGgfsInputStream stream,
GridGgfsFileRange suggestedRecord)
Adjusts record start offset and length.
|
| Modifier and Type | Method and Description |
|---|---|
GridGgfsFileRange |
GridGgfsFixedLengthRecordResolver.resolveRecords(GridGgfs ggfs,
GridGgfsInputStream stream,
GridGgfsFileRange suggestedRecord)
Adjusts record start offset and length.
|
GridGgfsFileRange |
GridGgfsByteDelimiterRecordResolver.resolveRecords(GridGgfs ggfs,
GridGgfsInputStream stream,
GridGgfsFileRange suggestedRecord)
Adjusts record start offset and length.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridInternalException
When log debug mode is disabled this exception should be logged in short form - without stack trace.
|
| Modifier and Type | Method and Description |
|---|---|
GridException |
GridJobExecuteResponse.getException() |
GridException |
GridJobResultImpl.getException()
Gets exception produced by execution of remote job, or
null if
remote execution finished normally and did not produce any exceptions. |
GridException |
GridJobExecuteResponse.getFakeException() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridJobResultImpl.onResponse(Object data,
GridException ex,
Map<Object,Object> jobAttrs,
boolean isCancelled) |
void |
GridJobExecuteResponse.setFakeException(GridException fakeEx) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridTaskFutureImpl.cancel()
Default no-op implementation that always returns
false. |
void |
GridJobSiblingImpl.cancel()
Sends a request to cancel this sibling.
|
void |
GridComputeImpl.cancelJob(GridUuid jobId)
Cancels job with the given job ID, if it is currently running inside this projection.
|
boolean |
GridTaskFutureImpl.cancelOnMasterLeave()
Cancel task on master leave event.
|
void |
GridComputeImpl.cancelTask(GridUuid sesId)
Cancels task with the given execution session ID, if it currently running inside this projection.
|
void |
GridKernal.close()
Closes
this instance of grid. |
<T> T |
GridComponentType.create(boolean noOp)
Creates component.
|
<T extends GridComponent> |
GridComponentType.create(GridKernalContext ctx,
boolean noOp)
Creates component.
|
<T> T |
GridComponentType.createOptional()
First tries to find main component class, if it is not found creates no-op implementation.
|
<T> T |
GridComponentType.createOptional(GridKernalContext ctx)
First tries to find main component class, if it is not found creates no-op implementation.
|
GridComputeJobSibling |
GridJobSessionImpl.getJobSibling(GridUuid jobId)
Gets job sibling for a given ID.
|
GridComputeJobSibling |
GridTaskSessionImpl.getJobSibling(GridUuid jobId)
Gets job sibling for a given ID.
|
Collection<GridComputeJobSibling> |
GridJobSessionImpl.getJobSiblings()
Gets a collection of all grid job siblings.
|
Collection<GridComputeJobSibling> |
GridTaskSessionImpl.getJobSiblings()
Gets a collection of all grid job siblings.
|
<T> T |
GridJobSessionImpl.loadCheckpoint(String key)
Loads job's state previously saved via
GridComputeTaskSession.saveCheckpoint(String, Object, GridComputeTaskSessionScope, long)
method from an underlying storage for a given key. |
<T> T |
GridTaskSessionImpl.loadCheckpoint(String key)
Loads job's state previously saved via
GridComputeTaskSession.saveCheckpoint(String, Object, GridComputeTaskSessionScope, long)
method from an underlying storage for a given key. |
protected <T> T |
GridTaskSessionImpl.loadCheckpoint0(GridTaskSessionInternal ses,
String key) |
static GridBiTuple<GridConfiguration,GridSpringResourceContext> |
GridGainEx.loadConfiguration(String springCfgPath)
Loads first found grid configuration specified within given Spring XML configuration file.
|
static GridBiTuple<GridConfiguration,GridSpringResourceContext> |
GridGainEx.loadConfiguration(URL springCfgUrl)
Loads first found grid configuration specified within given Spring XML configuration file.
|
static GridBiTuple<Collection<GridConfiguration>,? extends GridSpringResourceContext> |
GridGainEx.loadConfigurations(String springCfgPath)
Loads all grid configurations specified within given Spring XML configuration file.
|
static GridBiTuple<Collection<GridConfiguration>,? extends GridSpringResourceContext> |
GridGainEx.loadConfigurations(URL springCfgUrl)
Loads all grid configurations specified within given Spring XML configuration file.
|
void |
GridComputeImpl.localDeployTask(Class<? extends GridComputeTask> taskCls,
ClassLoader clsLdr)
Explicitly deploys a task with given class loader on the local node.
|
<K> Map<GridNode,Collection<K>> |
GridKernal.mapKeysToNodes(String cacheName,
Collection<? extends K> keys)
This method provides ability to detect which cache keys are mapped to which nodes
on cache instance with given name.
|
<K> GridNode |
GridKernal.mapKeyToNode(String cacheName,
K key)
This method provides ability to detect which cache keys are mapped to which nodes
on cache instance with given name.
|
GridProjectionMetrics |
GridProjectionAdapter.metrics()
Gets a metrics snapshot for this projection.
|
void |
GridComponent.onKernalStart()
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
void |
GridMessageListenHandler.p2pMarshal(GridKernalContext ctx)
Deploys and marshals inner objects (called only if peer deployment is enabled).
|
void |
GridMessageListenHandler.p2pUnmarshal(UUID nodeId,
GridKernalContext ctx)
Unmarshals inner objects (called only if peer deployment is enabled).
|
Collection<GridComputeJobSibling> |
GridJobSessionImpl.refreshJobSiblings()
Refreshes collection of job siblings.
|
Collection<GridComputeJobSibling> |
GridTaskSessionImpl.refreshJobSiblings()
Refreshes collection of job siblings.
|
boolean |
GridMessageListenHandler.register(UUID nodeId,
UUID routineId,
GridKernalContext ctx)
Registers listener.
|
boolean |
GridJobSessionImpl.removeCheckpoint(String key)
Removes previously saved job's state for a given
key from an underlying storage. |
boolean |
GridTaskSessionImpl.removeCheckpoint(String key)
Removes previously saved job's state for a given
key from an underlying storage. |
protected boolean |
GridTaskSessionImpl.removeCheckpoint0(GridTaskSessionInternal ses,
String key) |
void |
GridKernal.restartNodes()
Restarts nodes satisfying optional set of predicates.
|
void |
GridKernal.restartNodes(Collection<UUID> ids)
Restarts nodes defined by provided IDs.
|
void |
GridJobSessionImpl.saveCheckpoint(String key,
Object state)
Saves intermediate state of a job or task to a storage.
|
void |
GridTaskSessionImpl.saveCheckpoint(String key,
Object state)
Saves intermediate state of a job or task to a storage.
|
void |
GridJobSessionImpl.saveCheckpoint(String key,
Object state,
GridComputeTaskSessionScope scope,
long timeout)
Saves intermediate state of a job to a storage.
|
void |
GridTaskSessionImpl.saveCheckpoint(String key,
Object state,
GridComputeTaskSessionScope scope,
long timeout)
Saves intermediate state of a job to a storage.
|
void |
GridJobSessionImpl.saveCheckpoint(String key,
Object state,
GridComputeTaskSessionScope scope,
long timeout,
boolean overwrite)
Saves intermediate state of a job or task to a storage.
|
void |
GridTaskSessionImpl.saveCheckpoint(String key,
Object state,
GridComputeTaskSessionScope scope,
long timeout,
boolean overwrite)
Saves intermediate state of a job or task to a storage.
|
protected void |
GridTaskSessionImpl.saveCheckpoint0(GridTaskSessionInternal ses,
String key,
Object state,
GridComputeTaskSessionScope scope,
long timeout,
boolean overwrite) |
void |
GridMessagingImpl.send(Object topic,
Collection<?> msgs)
Sends given messages with specified topic to the nodes in this projection.
|
void |
GridMessagingImpl.send(Object topic,
Object msg)
Sends given message with specified topic to the nodes in this projection.
|
void |
GridMessagingImpl.sendOrdered(Object topic,
Object msg,
long timeout)
Sends given message with specified topic to the nodes in this projection.
|
void |
GridJobSessionImpl.setAttribute(Object key,
Object val)
Sets session attributed.
|
void |
GridTaskSessionImpl.setAttribute(Object key,
Object val)
Sets session attributed.
|
void |
GridJobSessionImpl.setAttributes(Map<?,?> attrs)
Sets task attributes.
|
void |
GridTaskSessionImpl.setAttributes(Map<?,?> attrs)
Sets task attributes.
|
static Grid |
GridGainEx.start()
Starts grid with default configuration.
|
void |
GridLoggerProxy.start()
Starts grid component, called on grid start.
|
void |
GridComponent.start()
Starts grid component.
|
static Grid |
GridGainEx.start(GridConfiguration cfg)
Starts grid with given configuration.
|
void |
GridKernal.start(GridConfiguration cfg,
ExecutorService drPool,
GridAbsClosure errHnd) |
static Grid |
GridGainEx.start(GridConfiguration cfg,
GridSpringResourceContext springCtx)
Starts grid with given configuration.
|
static Grid |
GridGainEx.start(GridSpringResourceContext springCtx)
Starts grid with default configuration.
|
static Grid |
GridGainEx.start(String springCfgPath)
Starts all grids specified within given Spring XML configuration file.
|
static Grid |
GridGainEx.start(String springCfgPath,
GridSpringResourceContext springCtx)
Starts all grids specified within given Spring XML configuration file.
|
static Grid |
GridGainEx.start(URL springCfgUrl)
Starts all grids specified within given Spring XML configuration file URL.
|
static Grid |
GridGainEx.start(URL springCfgUrl,
GridSpringResourceContext springCtx)
Starts all grids specified within given Spring XML configuration file URL.
|
GridFuture<Collection<GridTuple3<String,Boolean,String>>> |
GridKernal.startNodes(Collection<Map<String,Object>> hosts,
Map<String,Object> dflts,
boolean restart,
int timeout,
int maxConn)
Starts one or more nodes on remote host(s).
|
GridFuture<Collection<GridTuple3<String,Boolean,String>>> |
GridKernal.startNodes(File file,
boolean restart,
int timeout,
int maxConn)
Starts one or more nodes on remote host(s).
|
void |
GridLoggerProxy.stop()
Stops grid component, called on grid shutdown.
|
void |
GridComponent.stop(boolean cancel)
Stops grid component.
|
void |
GridKernal.stopNodes()
Stops nodes satisfying optional set of predicates.
|
void |
GridKernal.stopNodes(Collection<UUID> ids)
Stops nodes defined by provided IDs.
|
void |
GridComputeImpl.undeployTask(String taskName)
Makes the best attempt to undeploy a task with given name from this grid projection.
|
void |
GridJobSiblingsResponse.unmarshalSiblings(GridMarshaller marsh) |
boolean |
GridTaskFutureImpl.waitForMap()
Waits until
GridComputeTask.map(List, Object) method completes. |
boolean |
GridTaskFutureImpl.waitForMap(long timeout)
Waits for a specified timeout in milliseconds for
GridComputeTask.map(List, Object)
method to complete. |
boolean |
GridTaskFutureImpl.waitForMap(long timeout,
TimeUnit unit)
Waits for a specified timeout in milliseconds for
GridComputeTask.map(List, Object)
method to complete. |
| Constructor and Description |
|---|
GridJobExecuteResponse(UUID nodeId,
GridUuid sesId,
GridUuid jobId,
byte[] gridExBytes,
GridException gridEx,
byte[] resBytes,
Object res,
byte[] jobAttrsBytes,
Map<Object,Object> jobAttrs,
boolean isCancelled) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridManager.addSpiAttributes(Map<String,Object> attrs)
Adds attributes from underlying SPI to map of all attributes.
|
void |
GridManagerAdapter.addSpiAttributes(Map<String,Object> attrs)
Adds attributes from underlying SPI to map of all attributes.
|
void |
GridNoopManagerAdapter.addSpiAttributes(Map<String,Object> attrs)
Adds attributes from underlying SPI to map of all attributes.
|
protected void |
GridManagerAdapter.assertParameter(boolean cond,
String condDesc)
Throws exception with uniform error message if given parameter's assertion condition
is
false. |
void |
GridManagerAdapter.onKernalStart()
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
void |
GridNoopManagerAdapter.onKernalStart()
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
protected void |
GridManagerAdapter.onKernalStart0() |
void |
GridNoopManagerAdapter.start()
Starts grid component.
|
protected void |
GridManagerAdapter.startSpi()
Starts wrapped SPI.
|
void |
GridNoopManagerAdapter.stop(boolean cancel)
Stops grid component.
|
protected void |
GridManagerAdapter.stopSpi()
Stops wrapped SPI.
|
| Modifier and Type | Method and Description |
|---|---|
Serializable |
GridCheckpointManager.loadCheckpoint(GridTaskSessionInternal ses,
String key) |
void |
GridCheckpointManager.start()
Starts grid component.
|
void |
GridCheckpointManager.stop(boolean cancel)
Stops grid component.
|
boolean |
GridCheckpointManager.storeCheckpoint(GridTaskSessionInternal ses,
String key,
Object state,
GridComputeTaskSessionScope scope,
long timeout,
boolean override) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCollisionManager.start()
Starts grid component.
|
void |
GridCollisionManager.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridIoManager.onKernalStart0() |
void |
GridIoManager.send(Collection<? extends GridNode> nodes,
GridTopic topic,
GridTcpCommunicationMessageAdapter msg,
GridIoPolicy plc) |
void |
GridIoManager.send(Collection<? extends GridNode> nodes,
Object topic,
GridTcpCommunicationMessageAdapter msg,
GridIoPolicy plc) |
void |
GridIoManager.send(GridNode node,
GridTopic topic,
GridTcpCommunicationMessageAdapter msg,
GridIoPolicy plc) |
void |
GridIoManager.send(GridNode node,
Object topic,
GridTcpCommunicationMessageAdapter msg,
GridIoPolicy plc) |
void |
GridIoManager.send(UUID nodeId,
GridTopic topic,
GridTcpCommunicationMessageAdapter msg,
GridIoPolicy plc) |
void |
GridIoManager.send(UUID nodeId,
Object topic,
GridTcpCommunicationMessageAdapter msg,
GridIoPolicy plc) |
void |
GridIoManager.sendOrderedMessage(Collection<? extends GridNode> nodes,
Object topic,
long msgId,
GridTcpCommunicationMessageAdapter msg,
GridIoPolicy plc,
long timeout,
boolean skipOnTimeout) |
void |
GridIoManager.sendOrderedMessage(GridNode node,
Object topic,
long msgId,
GridTcpCommunicationMessageAdapter msg,
GridIoPolicy plc,
long timeout,
boolean skipOnTimeout) |
void |
GridIoManager.sendOrderedMessage(UUID nodeId,
Object topic,
long msgId,
GridTcpCommunicationMessageAdapter msg,
GridIoPolicy plc,
long timeout,
boolean skipOnTimeout) |
void |
GridIoManager.sendUserMessage(Collection<? extends GridNode> nodes,
Object msg)
Sends a peer deployable user message.
|
void |
GridIoManager.sendUserMessage(Collection<? extends GridNode> nodes,
Object msg,
Object topic,
boolean ordered,
long timeout)
Sends a peer deployable user message.
|
void |
GridIoManager.start()
Starts grid component.
|
void |
GridIoManager.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
Object |
GridDeployment.annotatedValue(Object target,
Class<? extends Annotation> annCls)
Gets value of annotated field or method.
|
GridDeployment |
GridDeploymentManager.deploy(Class<?> cls,
ClassLoader clsLdr) |
GridDeployment |
GridDeploymentStore.explicitDeploy(Class<?> cls,
ClassLoader clsLdr)
Explicitly deploys class.
|
<T> T |
GridDeployment.newInstance(Class<T> cls) |
void |
GridDeploymentPerVersionStore.onKernalStart()
Kernal started callback.
|
void |
GridDeploymentPerLoaderStore.onKernalStart()
Kernal started callback.
|
void |
GridDeploymentStore.onKernalStart()
Kernal started callback.
|
void |
GridDeploymentManager.onKernalStart0() |
void |
GridDeploymentPerVersionStore.start()
Starts store.
|
void |
GridDeploymentManager.start()
Starts grid component.
|
void |
GridDeploymentPerLoaderStore.start()
Starts store.
|
void |
GridDeploymentStore.start()
Starts store.
|
void |
GridDeploymentManager.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridDiscoveryManager.start()
Starts grid component.
|
void |
GridDiscoveryManager.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridEventStorageManager.start()
Starts grid component.
|
void |
GridEventStorageManager.stop(boolean cancel)
Stops grid component.
|
GridEvent |
GridEventStorageManager.waitForEvent(long timeout,
Runnable c,
GridPredicate<? super GridEvent> p,
int... types) |
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridFailoverContextImpl.getBalancedNode(List<GridNode> top)
Gets the next balanced node for failed job.
|
void |
GridFailoverManager.start()
Starts grid component.
|
void |
GridFailoverManager.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridIndexingManager.onUndeploy(String space,
ClassLoader ldr)
Removes index tables for all classes belonging to given class loader.
|
<K,V> GridCloseableIterator<GridIndexingKeyValueRow<K,V>> |
GridIndexingManager.query(String spi,
String space,
String clause,
Collection<Object> params,
Class<? extends V> resType,
boolean includeBackups,
GridIndexingQueryFilter<K,V>... filters) |
<K,V> GridIndexingFieldsResult |
GridIndexingManager.queryFields(String spi,
String space,
String clause,
Collection<Object> params,
boolean includeBackups,
GridIndexingQueryFilter<K,V>... filters) |
<K,V> GridCloseableIterator<GridIndexingKeyValueRow<K,V>> |
GridIndexingManager.queryText(String spi,
String space,
String clause,
Class<? extends V> resType,
boolean includeBackups,
GridIndexingQueryFilter<K,V>... filters) |
<K> boolean |
GridIndexingManager.remove(String spi,
String space,
K key,
byte[] keyBytes) |
long |
GridIndexingManager.size(String spi,
String space,
Class<?> valType)
Returns number of objects of given type for given space of spi.
|
void |
GridIndexingManager.start() |
void |
GridIndexingManager.stop(boolean cancel) |
<K,V> void |
GridIndexingManager.store(String spi,
String space,
K key,
byte[] keyBytes,
V val,
byte[] valBytes,
byte[] ver,
long expirationTime)
Writes key-value pair to index.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridLoadBalancerManager.getBalancedNode(GridTaskSessionImpl ses,
List<GridNode> top,
GridComputeJob job) |
void |
GridLoadBalancerManager.start()
Starts grid component.
|
void |
GridLoadBalancerManager.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
byte[] |
GridSecureSessionManager.updateSession(GridSecuritySubjectType subjType,
UUID subjId,
GridSecurityContext subjCtx,
Object params)
Generates secure session token.
|
GridSecureSession |
GridSecureSessionManager.validateSession(GridSecuritySubjectType subjType,
UUID subjId,
byte[] tok,
Object params) |
| Modifier and Type | Method and Description |
|---|---|
GridSecureSession |
GridOsSecureSessionManager.validateSession(GridSecuritySubjectType subjType,
UUID subjId,
byte[] tok,
Object params) |
| Modifier and Type | Method and Description |
|---|---|
GridSecurityContext |
GridSecurityManager.authenticate(GridAuthenticationContext ctx)
Authenticates subject via underlying
GridAuthenticationSpis. |
GridSecuritySubject |
GridSecurityManager.authenticatedSubject(UUID subjId)
Gets authenticated node subject.
|
GridSecuritySubject |
GridSecurityImpl.authenticatedSubject(UUID subjId)
Gets security subject based on subject ID.
|
Collection<GridSecuritySubject> |
GridSecurityManager.authenticatedSubjects()
Gets collection of authenticated nodes.
|
Collection<GridSecuritySubject> |
GridSecurityImpl.authenticatedSubjects()
Gets collection of authenticated subjects together with their permissions.
|
GridSecurityContext |
GridSecurityManager.authenticateNode(GridNode node,
GridSecurityCredentials cred)
Authenticates grid node with it's attributes via underlying
GridAuthenticationSpis. |
| Modifier and Type | Method and Description |
|---|---|
GridSecurityContext |
GridOsSecurityManager.authenticate(GridAuthenticationContext authCtx)
Authenticates subject via underlying
GridAuthenticationSpis. |
GridSecurityContext |
GridOsSecurityManager.authenticateNode(GridNode node,
GridSecurityCredentials cred)
Authenticates grid node with it's attributes via underlying
GridAuthenticationSpis. |
| Modifier and Type | Method and Description |
|---|---|
void |
GridSwapSpaceManager.clear(String spaceName) |
<K> GridCloseableIterator<K> |
GridSwapSpaceManager.keysIterator(String spaceName,
ClassLoader ldr)
Gets iterator over space entries.
|
GridCloseableIterator<Map.Entry<byte[],byte[]>> |
GridSwapSpaceManager.rawIterator(String spaceName)
Gets iterator over space entries.
|
GridCloseableIterator<Map.Entry<byte[],byte[]>> |
GridSwapSpaceManager.rawIterator(String spaceName,
int part) |
byte[] |
GridSwapSpaceManager.read(String spaceName,
GridSwapKey key,
ClassLoader ldr)
Reads value from swap.
|
<T> T |
GridSwapSpaceManager.read(String spaceName,
Object key,
ClassLoader ldr)
Reads value from swap.
|
<T> T |
GridSwapSpaceManager.readValue(String spaceName,
GridSwapKey key,
ClassLoader ldr)
Reads value from swap.
|
void |
GridSwapSpaceManager.remove(String spaceName,
GridSwapKey key,
GridInClosure<byte[]> c,
ClassLoader ldr)
Removes value from swap.
|
void |
GridSwapSpaceManager.remove(String spaceName,
Object key,
GridInClosure<byte[]> c,
ClassLoader ldr)
Removes value from swap.
|
void |
GridSwapSpaceManager.removeAll(String spaceName,
Collection<GridSwapKey> keys,
GridBiInClosure<GridSwapKey,byte[]> c,
ClassLoader ldr)
Removes value from swap.
|
void |
GridSwapSpaceManager.start()
Starts grid component.
|
void |
GridSwapSpaceManager.stop(boolean cancel)
Stops grid component.
|
long |
GridSwapSpaceManager.swapKeys(String spaceName)
Gets number of swap entries (keys).
|
long |
GridSwapSpaceManager.swapSize(String spaceName)
Gets size in bytes for swap space.
|
void |
GridSwapSpaceManager.write(String spaceName,
GridSwapKey key,
byte[] val,
ClassLoader ldr)
Writes value to swap.
|
void |
GridSwapSpaceManager.write(String spaceName,
Object key,
Object val,
ClassLoader ldr)
Writes value to swap.
|
<K,V> void |
GridSwapSpaceManager.writeAll(String spaceName,
Iterable<GridCacheBatchSwapEntry<K,V>> swapped,
ClassLoader ldr)
Writes batch to swap.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridProcessor.addAttributes(Map<String,Object> attrs)
Adds attributes from this component to map of all node attributes.
|
void |
GridProcessorAdapter.addAttributes(Map<String,Object> attrs)
Adds attributes from this component to map of all node attributes.
|
protected void |
GridProcessorAdapter.assertParameter(boolean cond,
String condDesc)
Throws exception with uniform error message if given parameter's assertion condition
is
false. |
void |
GridProcessorAdapter.onKernalStart()
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
void |
GridProcessorAdapter.start()
Starts grid component.
|
void |
GridProcessorAdapter.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
Object |
GridAffinityProcessor.affinityKey(String cacheName,
Object key)
Gets affinity key for cache key.
|
<K> Map<GridNode,Collection<K>> |
GridAffinityProcessor.mapKeysToNodes(Collection<? extends K> keys)
Maps keys to nodes on default cache.
|
<K> Map<GridNode,Collection<K>> |
GridAffinityProcessor.mapKeysToNodes(String cacheName,
Collection<? extends K> keys)
Maps keys to nodes for given cache.
|
<K> GridNode |
GridAffinityProcessor.mapKeyToNode(K key)
Maps single key to a node on default cache.
|
<K> GridNode |
GridAffinityProcessor.mapKeyToNode(String cacheName,
K key)
Maps single key to a node.
|
void |
GridAffinityProcessor.onKernalStart()
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridCacheIndexUpdateException
Exception indicating that index update failed during cache entry update.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheProcessor.addAttributes(Map<String,Object> attrs)
Adds attributes from this component to map of all node attributes.
|
protected GridTuple3<GridCacheOperation,V,byte[]> |
GridCacheTxAdapter.applyTransformClosures(GridCacheTxEntry<K,V> txEntry,
boolean metrics) |
protected void |
GridCacheTxAdapter.awaitCompletion()
Awaits transaction completion.
|
void |
GridCacheEvictionManager.batchEvict(Collection<? extends K> keys,
GridCacheVersion obsoleteVer) |
protected void |
GridCacheTxLocalAdapter.batchStoreCommit(Iterable<GridCacheTxEntry<K,V>> writeEntries)
Performs batch database operations.
|
static void |
GridCacheUtils.checkAttributeMismatch(GridLogger log,
GridCacheConfiguration locCfg,
GridCacheConfiguration rmtCfg,
GridNode rmt,
T2<String,String> attr,
boolean fail)
Checks that local and remove configurations have the same value of given attribute.
|
static void |
GridCacheUtils.checkAttributeMismatch(GridLogger log,
String cfgName,
GridNode rmt,
String attrName,
String attrMsg,
Object locVal,
Object rmtVal,
boolean fail)
Checks that cache configuration attribute has the same value in local and remote cache configurations.
|
protected void |
GridCacheAdapter.checkJta()
Checks if cache is working in JTA transaction and enlist cache as XAResource if necessary.
|
static void |
GridCacheUtils.checkStore(GridCacheContext<?,?> ctx)
Checks that cache store is present.
|
protected void |
GridCacheTxLocalAdapter.checkValid(GridPredicate<GridCacheEntry<K,V>>[] filter)
Checks transaction expiration.
|
boolean |
GridCacheMapEntry.clear(GridCacheVersion ver,
boolean readers,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Marks entry as obsolete and, if possible or required, removes it
from swap storage.
|
boolean |
GridCacheEntryEx.clear(GridCacheVersion ver,
boolean readers,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Marks entry as obsolete and, if possible or required, removes it
from swap storage.
|
protected void |
GridCacheMapEntry.clearIndex(V prevVal)
Clears index.
|
void |
GridCacheSwapManager.clearSwap()
Clears swap.
|
<T> T |
GridCacheContext.cloneOnFlag(T obj)
Clones cached object depending on whether or not
GridCacheFlag.CLONE flag
is set thread locally. |
<T> T |
GridCacheContext.cloneValue(T obj)
Clone cached object.
|
void |
GridCacheTxAdapter.close() |
void |
GridCacheTxProxyImpl.close()
Ends the transaction.
|
void |
GridCacheTxProxyImpl.commit()
Commits this transaction by initiating
two-phase-commit process. |
void |
GridCacheTxLocalAdapter.commit()
Commits this transaction by initiating
two-phase-commit process. |
boolean |
GridCacheEvictionEntry.compact()
Optimizes the size of this entry.
|
boolean |
GridCacheEntryImpl.compact()
Optimizes the size of this entry.
|
boolean |
GridCacheFilterEvaluationEntry.compact()
Optimizes the size of this entry.
|
boolean |
GridCacheMapEntry.compact(GridPredicate<GridCacheEntry<K,V>>[] filter)
Optimizes the size of this entry.
|
boolean |
GridCacheEntryEx.compact(GridPredicate<GridCacheEntry<K,V>>[] filter)
Optimizes the size of this entry.
|
boolean |
GridCacheProjectionImpl.compact(K key)
Clears serialized value bytes from entry (if any) leaving only object representation.
|
boolean |
GridCacheAdapter.compact(K key)
Clears serialized value bytes from entry (if any) leaving only object representation.
|
boolean |
GridCacheProxyImpl.compact(K key)
Clears serialized value bytes from entry (if any) leaving only object representation.
|
boolean |
GridCacheAdapter.compact(K key,
GridPredicate<GridCacheEntry<K,V>>... filter) |
void |
GridCacheProjectionImpl.compactAll()
Clears serialized value bytes from cache entries (if any) leaving only object representation.
|
void |
GridCacheAdapter.compactAll()
Clears serialized value bytes from cache entries (if any) leaving only object representation.
|
void |
GridCacheProxyImpl.compactAll()
Clears serialized value bytes from cache entries (if any) leaving only object representation.
|
void |
GridCacheAdapter.compactAll(Iterable<K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter) |
boolean |
GridCacheSwapManager.containsKey(K key,
byte[] keyBytes) |
protected GridCacheValueBytes |
GridCacheMapEntry.createValueBytes(V val)
Create value bytes wrapper from the given object.
|
GridDrEntry<K,V> |
GridCacheMapEntry.drEntry()
Create DR entry for that cache entry.
|
GridDrEntry<K,V> |
GridCacheEntryEx.drEntry()
Create DR entry for that cache entry.
|
protected GridBiTuple<GridCacheOperation,GridDrReceiverConflictContextImpl<K,V>> |
GridCacheTxAdapter.drResolveConflict(GridCacheOperation op,
K key,
V newVal,
byte[] newValBytes,
long newTtl,
long newDrExpireTime,
GridCacheVersion newVer,
GridCacheEntryEx<K,V> old)
Resolve DR conflict.
|
GridDrReceiverConflictContextImpl<K,V> |
GridCacheContext.drResolveConflict(K key,
GridDrEntry<K,V> oldEntry,
GridDrEntry<K,V> newEntry)
Resolve DR conflict.
|
boolean |
GridCacheEvictionManager.evict(GridCacheEntryEx<K,V> entry,
GridCacheVersion obsoleteVer,
boolean explicit,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridCacheBatchSwapEntry<K,V> |
GridCacheMapEntry.evictInBatchInternal(GridCacheVersion obsoleteVer)
Evicts entry when batch evict is performed.
|
GridCacheBatchSwapEntry<K,V> |
GridCacheEntryEx.evictInBatchInternal(GridCacheVersion obsoleteVer)
Evicts entry when batch evict is performed.
|
boolean |
GridCacheMapEntry.evictInternal(boolean swap,
GridCacheVersion obsoleteVer,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
boolean |
GridCacheEntryEx.evictInternal(boolean swap,
GridCacheVersion obsoleteVer,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
protected boolean |
GridCacheTxAdapter.evictNearEntry(GridCacheTxEntry<K,V> e,
boolean primaryOnly) |
boolean |
GridCacheTxLocalEx.finish(boolean commit)
Finishes transaction (either commit or rollback).
|
void |
GridCacheMessage.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridCacheDgcResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridCacheDgcRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridCacheEvictionRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridCacheEvictionResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridCacheStoreManager.forceFlush() |
void |
GridCacheWriteBehindStore.forceFlush()
Forces all entries collected to be flushed to the underlying store.
|
V |
GridCacheEvictionEntry.get()
This method has the same semantic as
GridCacheProjection.get(Object) method. |
V |
GridCacheEntryImpl.get()
This method has the same semantic as
GridCacheProjection.get(Object) method. |
V |
GridCacheFilterEvaluationEntry.get()
This method has the same semantic as
GridCacheProjection.get(Object) method. |
V |
GridCacheProjectionImpl.get(K key)
Retrieves value mapped to the specified key from cache.
|
V |
GridCacheAdapter.get(K key)
Retrieves value mapped to the specified key from cache.
|
V |
GridCacheProxyImpl.get(K key)
Retrieves value mapped to the specified key from cache.
|
V |
GridCacheProjectionEx.get(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter) |
V |
GridCacheProjectionImpl.get(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter) |
V |
GridCacheAdapter.get(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter) |
V |
GridCacheProxyImpl.get(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter) |
V |
GridCacheAdapter.get(K key,
GridPredicate<GridCacheEntry<K,V>> filter) |
Map<K,V> |
GridCacheProjectionImpl.getAll(Collection<? extends K> keys)
Retrieves values mapped to the specified keys from cache.
|
Map<K,V> |
GridCacheAdapter.getAll(Collection<? extends K> keys)
Retrieves values mapped to the specified keys from cache.
|
Map<K,V> |
GridCacheProxyImpl.getAll(Collection<? extends K> keys)
Retrieves values mapped to the specified keys from cache.
|
Map<K,V> |
GridCacheAdapter.getAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>> filter) |
Map<K,V> |
GridCacheProjectionEx.getAllOutTx(List<K> keys)
Gets values from cache.
|
Map<K,V> |
GridCacheProjectionImpl.getAllOutTx(List<K> keys)
Gets values from cache.
|
Map<K,V> |
GridCacheAdapter.getAllOutTx(List<K> keys)
Gets values from cache.
|
Map<K,V> |
GridCacheProxyImpl.getAllOutTx(List<K> keys)
Gets values from cache.
|
V |
GridCacheProjectionEx.getForcePrimary(K key)
Gets value from cache.
|
V |
GridCacheProjectionImpl.getForcePrimary(K key)
Gets value from cache.
|
V |
GridCacheAdapter.getForcePrimary(K key)
Gets value from cache.
|
V |
GridCacheProxyImpl.getForcePrimary(K key)
Gets value from cache.
|
byte[] |
GridCacheMapEntry.getOrMarshalKeyBytes() |
byte[] |
GridCacheEntryEx.getOrMarshalKeyBytes() |
void |
GridCacheProjectionImpl.globalClearAll()
Clears cache on all nodes that store it's data.
|
void |
GridCacheAdapter.globalClearAll()
Clears cache on all nodes that store it's data.
|
void |
GridCacheProxyImpl.globalClearAll()
Clears cache on all nodes that store it's data.
|
boolean |
GridCacheMapEntry.initialValue(K key,
GridCacheSwapEntry<V> unswapped)
Sets new value if current version is 0 using swap entry data.
|
boolean |
GridCacheEntryEx.initialValue(K key,
GridCacheSwapEntry<V> unswapped)
Sets new value if current version is 0 using swap entry data.
|
boolean |
GridCacheMapEntry.initialValue(V val,
byte[] valBytes,
GridCacheVersion ver,
long ttl,
long expireTime,
boolean preload,
long topVer,
GridDrType drType)
Sets new value if current version is 0
|
boolean |
GridCacheEntryEx.initialValue(V val,
byte[] valBytes,
GridCacheVersion ver,
long ttl,
long expireTime,
boolean preload,
long topVer,
GridDrType drType)
Sets new value if current version is 0
|
V |
GridCacheMapEntry.innerGet(GridCacheTxEx<K,V> tx,
boolean readSwap,
boolean readThrough,
boolean failFast,
boolean unmarshal,
boolean updateMetrics,
boolean evt,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
V |
GridCacheEntryEx.innerGet(GridCacheTxEx<K,V> tx,
boolean readSwap,
boolean readThrough,
boolean failFast,
boolean unmarshal,
boolean updateMetrics,
boolean evt,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
V |
GridCacheEntryEx.innerReload(GridPredicate<GridCacheEntry<K,V>>... filter)
Reloads entry from underlying storage.
|
V |
GridCacheMapEntry.innerReload(GridPredicate<GridCacheEntry<K,V>>[] filter)
Reloads entry from underlying storage.
|
GridCacheUpdateTxResult<V> |
GridCacheMapEntry.innerRemove(GridCacheTxEx<K,V> tx,
UUID evtNodeId,
UUID affNodeId,
boolean writeThrough,
boolean retval,
boolean evt,
boolean metrics,
long topVer,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId) |
GridCacheUpdateTxResult<V> |
GridCacheEntryEx.innerRemove(GridCacheTxEx<K,V> tx,
UUID evtNodeId,
UUID affNodeId,
boolean writeThrough,
boolean retval,
boolean evt,
boolean metrics,
long topVer,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId) |
GridCacheUpdateTxResult<V> |
GridCacheMapEntry.innerSet(GridCacheTxEx<K,V> tx,
UUID evtNodeId,
UUID affNodeId,
V val,
byte[] valBytes,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
long topVer,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId) |
GridCacheUpdateTxResult<V> |
GridCacheEntryEx.innerSet(GridCacheTxEx<K,V> tx,
UUID evtNodeId,
UUID affNodeId,
V val,
byte[] valBytes,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
long topVer,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId) |
GridCacheUpdateAtomicResult<K,V> |
GridCacheMapEntry.innerUpdate(GridCacheVersion newVer,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object writeObj,
byte[] valBytes,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean primary,
boolean verCheck,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridDrType drType,
long drTtl,
long drExpireTime,
GridCacheVersion drVer,
boolean drResolve,
boolean intercept,
UUID subjId) |
GridCacheUpdateAtomicResult<K,V> |
GridCacheEntryEx.innerUpdate(GridCacheVersion ver,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object val,
byte[] valBytes,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean primary,
boolean checkVer,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridDrType drType,
long drTtl,
long drExpireTime,
GridCacheVersion drVer,
boolean drResolve,
boolean intercept,
UUID subjId) |
GridBiTuple<Boolean,V> |
GridCacheMapEntry.innerUpdateLocal(GridCacheVersion ver,
GridCacheOperation op,
Object writeObj,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
GridPredicate<GridCacheEntry<K,V>>[] filter,
boolean intercept,
UUID subjId)
Update method for local cache in atomic mode.
|
GridBiTuple<Boolean,V> |
GridCacheEntryEx.innerUpdateLocal(GridCacheVersion ver,
GridCacheOperation op,
Object writeObj,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
GridPredicate<GridCacheEntry<K,V>>[] filter,
boolean intercept,
UUID subjId)
Update method for local cache in atomic mode.
|
static <K,V> void |
GridCacheUtils.inTx(GridCacheProjection<K,V> cache,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
GridInClosureX<GridCacheProjection<K,V>> clo)
Execute closure inside cache transaction.
|
boolean |
GridCacheMapEntry.invalidate(GridCacheVersion curVer,
GridCacheVersion newVer)
Invalidates this entry.
|
boolean |
GridCacheEntryEx.invalidate(GridCacheVersion curVer,
GridCacheVersion newVer)
Invalidates this entry.
|
boolean |
GridCacheMapEntry.invalidate(GridPredicate<GridCacheEntry<K,V>>[] filter)
Invalidates this entry if it passes given filter.
|
boolean |
GridCacheEntryEx.invalidate(GridPredicate<GridCacheEntry<K,V>>[] filter)
Invalidates this entry if it passes given filter.
|
<E> boolean |
GridCacheContext.isAll(E e,
GridPredicate<? super E>[] p)
Same as
GridFunc.isAll(Object, GridPredicate[]), but safely unwraps
exceptions. |
<K,V> boolean |
GridCacheContext.isAll(GridCacheEntryEx<K,V> e,
GridPredicate<GridCacheEntry<K,V>>[] p)
Same as
GridFunc.isAll(Object, GridPredicate[]), but safely unwraps
exceptions. |
GridCloseableIterator<Map.Entry<byte[],GridCacheSwapEntry<V>>> |
GridCacheSwapManager.iterator(int part)
Gets offheap and swap iterator over partition.
|
Iterator<Map.Entry<K,V>> |
GridCacheSwapManager.lazySwapIterator() |
V |
GridCacheWriteBehindStore.load(GridCacheTx tx,
K key)
Loads value for the key from underlying persistent storage.
|
void |
GridCacheWriteBehindStore.loadAll(GridCacheTx tx,
Collection<? extends K> keys,
GridBiInClosure<K,V> c)
Loads all values for given keys and passes every value to the provided closure.
|
boolean |
GridCacheStoreManager.loadAllFromStore(GridCacheTx tx,
Collection<? extends K> keys,
GridBiInClosure<K,V> vis)
Loads data from persistent store.
|
void |
GridCacheWriteBehindStore.loadCache(GridBiInClosure<K,V> clo,
Object... args)
Default empty implementation.
|
void |
GridCacheAdapter.loadCache(GridBiPredicate<K,V> p,
long ttl,
Object[] args)
Delegates to
GridCacheStore.loadCache(GridBiInClosure,Object...) method
to load state from the underlying persistent storage. |
void |
GridCacheProxyImpl.loadCache(GridBiPredicate<K,V> p,
long ttl,
Object[] args)
Delegates to
GridCacheStore.loadCache(GridBiInClosure,Object...) method
to load state from the underlying persistent storage. |
boolean |
GridCacheStoreManager.loadCache(GridInClosure3<K,V,GridCacheVersion> vis,
Object[] args)
Loads data from persistent store.
|
V |
GridCacheStoreManager.loadFromStore(GridCacheTx tx,
K key)
Loads data from persistent store.
|
boolean |
GridCacheProjectionImpl.lock(K key,
long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
Synchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
boolean |
GridCacheAdapter.lock(K key,
long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
Synchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
boolean |
GridCacheProxyImpl.lock(K key,
long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Synchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
boolean |
GridCacheFilterEvaluationEntry.lock(long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
Synchronously acquires lock on a cached object associated with this entry
only if the passed in filter (if any) passes.
|
boolean |
GridCacheEvictionEntry.lock(long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Synchronously acquires lock on a cached object associated with this entry
only if the passed in filter (if any) passes.
|
boolean |
GridCacheEntryImpl.lock(long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Synchronously acquires lock on a cached object associated with this entry
only if the passed in filter (if any) passes.
|
boolean |
GridCacheAdapter.lockAll(Collection<? extends K> keys,
long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
All or nothing synchronous lock for passed in keys.
|
boolean |
GridCacheProjectionImpl.lockAll(Collection<? extends K> keys,
long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter)
All or nothing synchronous lock for passed in keys.
|
boolean |
GridCacheProxyImpl.lockAll(Collection<? extends K> keys,
long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter)
All or nothing synchronous lock for passed in keys.
|
boolean |
GridCacheMapEntry.markObsoleteIfEmpty(GridCacheVersion ver)
Sets obsolete flag if entry value is
null or entry is expired and no
locks are held. |
boolean |
GridCacheEntryEx.markObsoleteIfEmpty(GridCacheVersion ver)
Sets obsolete flag if entry value is
null or entry is expired and no
locks are held. |
void |
GridCacheTxEntry.marshal(GridCacheContext<K,V> ctx) |
void |
GridCacheEntryInfo.marshal(GridCacheContext<K,V> ctx) |
static byte[] |
GridCacheUtils.marshal(GridCacheContext ctx,
Object obj) |
protected LinkedHashMap<byte[],Boolean> |
GridCacheMessage.marshalBooleanLinkedMap(LinkedHashMap<?,Boolean> map,
GridCacheContext<K,V> ctx) |
protected List<byte[]> |
GridCacheMessage.marshalCollection(Collection<?> col,
GridCacheContext<K,V> ctx) |
protected <T> byte[][] |
GridCacheMessage.marshalFilter(GridPredicate<GridCacheEntry<K,V>>[] filter,
GridCacheContext<K,V> ctx) |
protected void |
GridCacheMessage.marshalInfo(GridCacheEntryInfo<K,V> info,
GridCacheContext<K,V> ctx) |
protected void |
GridCacheMessage.marshalInfos(Iterable<? extends GridCacheEntryInfo<K,V>> infos,
GridCacheContext<K,V> ctx) |
protected void |
GridCacheMessage.marshalTx(Iterable<GridCacheTxEntry<K,V>> txEntries,
GridCacheContext<K,V> ctx) |
protected List<GridCacheValueBytes> |
GridCacheMessage.marshalValuesCollection(Collection<?> col,
GridCacheContext<K,V> ctx) |
int |
GridCacheEvictionEntry.memorySize()
Gets size of serialized key and value in addition to any overhead added by
GridGain itself. |
int |
GridCacheMapEntry.memorySize() |
int |
GridCacheEntryImpl.memorySize()
Gets size of serialized key and value in addition to any overhead added by
GridGain itself. |
int |
GridCacheEntryEx.memorySize() |
int |
GridCacheFilterEvaluationEntry.memorySize()
Gets size of serialized key and value in addition to any overhead added by
GridGain itself. |
Iterator<Map.Entry<K,V>> |
GridCacheAdapter.offHeapIterator()
Gets iterator over keys and values belonging to this cache off-heap memory on local node.
|
Iterator<Map.Entry<K,V>> |
GridCacheProxyImpl.offHeapIterator()
Gets iterator over keys and values belonging to this cache off-heap memory on local node.
|
GridCloseableIterator<Map.Entry<byte[],GridCacheSwapEntry<V>>> |
GridCacheSwapManager.offHeapIterator(int part)
Gets offheap iterator over partition.
|
void |
GridCacheProcessor.onKernalStart()
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
void |
GridCacheManager.onKernalStart() |
protected void |
GridCacheAdapter.onKernalStart()
Kernal start callback.
|
void |
GridCacheManagerAdapter.onKernalStart() |
void |
GridCachePreloaderAdapter.onKernalStart()
Kernal start callback.
|
void |
GridCachePreloader.onKernalStart()
Kernal start callback.
|
protected void |
GridCacheDgcManager.onKernalStart0() |
protected void |
GridCacheEvictionManager.onKernalStart0() |
protected void |
GridCacheAffinityManager.onKernalStart0() |
protected void |
GridCacheManagerAdapter.onKernalStart0() |
void |
GridCacheMvccManager.onKernalStart0() |
protected void |
GridCacheVersionManager.onKernalStart0() |
protected void |
GridCacheTtlManager.onKernalStart0() |
static <T> T |
GridCacheUtils.outTx(Callable<T> cmd,
GridCacheContext ctx)
Method executes any Callable out of scope of transaction.
|
long |
GridCacheAdapter.overflowSize()
Gets size (in bytes) of all entries swapped to disk.
|
long |
GridCacheProxyImpl.overflowSize()
Gets size (in bytes) of all entries swapped to disk.
|
V |
GridCacheEvictionEntry.peek(Collection<GridCachePeekMode> modes)
This method has the same semantic as
GridCacheProjection.peek(Object, Collection) method. |
V |
GridCacheEntryImpl.peek(Collection<GridCachePeekMode> modes)
This method has the same semantic as
GridCacheProjection.peek(Object, Collection) method. |
V |
GridCacheProjectionImpl.peek(K key,
Collection<GridCachePeekMode> modes)
Peeks at cached value using optional set of peek modes.
|
V |
GridCacheAdapter.peek(K key,
Collection<GridCachePeekMode> modes)
Peeks at cached value using optional set of peek modes.
|
V |
GridCacheProxyImpl.peek(K key,
Collection<GridCachePeekMode> modes)
Peeks at cached value using optional set of peek modes.
|
GridTuple<V> |
GridCacheMapEntry.peek0(boolean failFast,
GridCachePeekMode mode,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridCacheTxEx<K,V> tx) |
GridTuple<V> |
GridCacheEntryEx.peek0(boolean failFast,
GridCachePeekMode mode,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridCacheTxEx<K,V> tx) |
protected GridTuple<V> |
GridCacheAdapter.peek0(boolean failFast,
K key,
Collection<GridCachePeekMode> modes,
GridCacheTxEx<K,V> tx) |
protected V |
GridCacheAdapter.peek0(K key,
Collection<GridCachePeekMode> modes,
GridCacheTxEx<K,V> tx) |
protected Map<K,V> |
GridCacheAdapter.peekAll0(Collection<? extends K> keys,
Collection<GridCachePeekMode> modes,
GridCacheTxEx<K,V> tx,
Collection<K> skipped) |
V |
GridCacheMapEntry.poke(V val)
This method overwrites current in-memory value with new value.
|
V |
GridCacheEntryEx.poke(V val)
This method overwrites current in-memory value with new value.
|
protected abstract GridFuture<T> |
GridCacheTxLocalAdapter.PostLockClosure2.postLock()
Post lock callback.
|
protected abstract T |
GridCacheTxLocalAdapter.PostLockClosure1.postLock(T val)
Post lock callback.
|
protected Set<K> |
GridCacheTxLocalAdapter.postLockWrite(Iterable<? extends K> keys,
Set<K> failed,
Map<K,V> transformed,
Map<? extends K,? extends GridClosure<V,V>> transformMap,
GridCacheReturn<V> ret,
boolean rmv,
boolean retval,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Post lock processing for put or remove.
|
protected abstract GridFuture<T> |
GridCacheTxLocalAdapter.PostMissClosure.postMiss(T t)
Post lock callback.
|
void |
GridCacheTxEx.prepare()
Prepare state.
|
void |
GridCacheTxLocalAdapter.prepare()
Prepare state.
|
protected void |
GridCacheMessage.prepareFilter(GridPredicate<GridCacheEntry<K,V>>[] filters,
GridCacheContext<K,V> ctx) |
void |
GridCacheMessage.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridCacheDgcResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridCacheDgcRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridCacheEvictionRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridCacheEvictionResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
protected void |
GridCacheMessage.prepareObject(Object o,
GridCacheContext<K,V> ctx) |
protected void |
GridCacheMessage.prepareObjects(Iterable<?> col,
GridCacheContext<K,V> ctx) |
void |
GridCacheTxManager.prepareTx(GridCacheTxEx<K,V> tx)
Handles prepare stage of 2PC.
|
V |
GridCacheProjectionImpl.promote(K key)
This method promotes cache entry from offheap by given key, if any, from offheap or swap storage
into memory.
|
V |
GridCacheAdapter.promote(K key)
This method promotes cache entry from offheap by given key, if any, from offheap or swap storage
into memory.
|
V |
GridCacheProxyImpl.promote(K key)
This method promotes cache entry from offheap by given key, if any, from offheap or swap storage
into memory.
|
void |
GridCacheProjectionImpl.promoteAll(Collection<? extends K> keys)
This method unswaps cache entries by given keys, if any, from swap storage
into memory.
|
void |
GridCacheAdapter.promoteAll(Collection<? extends K> keys)
This method unswaps cache entries by given keys, if any, from swap storage
into memory.
|
void |
GridCacheProxyImpl.promoteAll(Collection<? extends K> keys)
This method unswaps cache entries by given keys, if any, from swap storage
into memory.
|
void |
GridCacheWriteBehindStore.put(GridCacheTx tx,
K key,
V val)
Stores a given value in persistent storage.
|
V |
GridCacheProjectionEx.put(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProjectionImpl.put(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProxyImpl.put(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheAdapter.put(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheTxLocalAdapter.put(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
V |
GridCacheTxLocalEx.put(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
V |
GridCacheAdapter.put(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
Stores given key-value pair in cache.
|
V |
GridCacheProjectionImpl.put(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pair in cache.
|
V |
GridCacheProxyImpl.put(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pair in cache.
|
void |
GridCacheWriteBehindStore.putAll(GridCacheTx tx,
Map<? extends K,? extends V> map)
Stores given key value pairs in persistent storage.
|
void |
GridCacheProjectionImpl.putAll(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pairs in cache.
|
void |
GridCacheAdapter.putAll(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pairs in cache.
|
void |
GridCacheProxyImpl.putAll(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pairs in cache.
|
GridCacheReturn<V> |
GridCacheTxLocalAdapter.putAll(Map<? extends K,? extends V> map,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridCacheReturn<V> |
GridCacheTxLocalEx.putAll(Map<? extends K,? extends V> map,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
void |
GridCacheProjectionEx.putAllDr(Map<? extends K,GridCacheDrInfo<V>> drMap)
Store DR data.
|
void |
GridCacheProjectionImpl.putAllDr(Map<? extends K,GridCacheDrInfo<V>> drMap)
Store DR data.
|
void |
GridCacheAdapter.putAllDr(Map<? extends K,GridCacheDrInfo<V>> drMap)
Store DR data.
|
void |
GridCacheProxyImpl.putAllDr(Map<? extends K,GridCacheDrInfo<V>> drMap)
Store DR data.
|
void |
GridCacheTxLocalAdapter.putAllDr(Map<? extends K,GridCacheDrInfo<V>> drMap) |
void |
GridCacheTxLocalEx.putAllDr(Map<? extends K,GridCacheDrInfo<V>> drMap) |
GridFuture<?> |
GridCacheProjectionEx.putAllDrAsync(Map<? extends K,GridCacheDrInfo<V>> drMap)
Store DR data asynchronously.
|
GridFuture<?> |
GridCacheProjectionImpl.putAllDrAsync(Map<? extends K,GridCacheDrInfo<V>> drMap)
Store DR data asynchronously.
|
GridFuture<?> |
GridCacheAdapter.putAllDrAsync(Map<? extends K,GridCacheDrInfo<V>> drMap)
Store DR data asynchronously.
|
GridFuture<?> |
GridCacheProxyImpl.putAllDrAsync(Map<? extends K,GridCacheDrInfo<V>> drMap)
Store DR data asynchronously.
|
boolean |
GridCacheStoreManager.putAllToStore(GridCacheTx tx,
Map<K,GridBiTuple<V,GridCacheVersion>> map)
Puts key-value pair into storage.
|
V |
GridCacheProjectionImpl.putIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
V |
GridCacheAdapter.putIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
V |
GridCacheProxyImpl.putIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
boolean |
GridCacheStoreManager.putToStore(GridCacheTx tx,
K key,
V val,
GridCacheVersion ver)
Puts key-value pair into storage.
|
boolean |
GridCacheProjectionEx.putx(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProjectionImpl.putx(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheAdapter.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProxyImpl.putx(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheTxLocalAdapter.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
boolean |
GridCacheTxLocalEx.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
boolean |
GridCacheProjectionImpl.putx(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pair in cache.
|
boolean |
GridCacheAdapter.putx(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pair in cache.
|
boolean |
GridCacheProxyImpl.putx(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pair in cache.
|
boolean |
GridCacheTxLocalAdapter.putx(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
boolean |
GridCacheTxLocalEx.putx(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
boolean |
GridCacheProjectionImpl.putxIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
boolean |
GridCacheAdapter.putxIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
boolean |
GridCacheProxyImpl.putxIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
V |
GridCacheMapEntry.rawGetOrUnmarshal() |
V |
GridCacheEntryEx.rawGetOrUnmarshal() |
protected V |
GridCacheMapEntry.rawGetOrUnmarshalUnlocked() |
GridCloseableIterator<Map.Entry<byte[],byte[]>> |
GridCacheSwapManager.rawIterator()
Gets offheap and swap iterator over partition.
|
Collection<GridCacheBatchSwapEntry<K,V>> |
GridCacheSwapManager.readAndRemove(Collection<? extends K> keys) |
protected V |
GridCacheMapEntry.readThrough(GridCacheTxEx<K,V> tx,
K key,
boolean reload,
GridPredicate<GridCacheEntry<K,V>>[] filter,
UUID subjId) |
void |
GridCacheDeploymentManager.registerClass(Class<?> cls) |
void |
GridCacheDeploymentManager.registerClass(Class<?> cls,
ClassLoader ldr) |
void |
GridCacheDeploymentManager.registerClass(Object obj) |
void |
GridCacheDeploymentManager.registerClasses(Iterable<?> objs)
Register local classes.
|
void |
GridCacheDeploymentManager.registerClasses(Object... objs)
Register local classes.
|
protected void |
GridCacheMapEntry.releaseSwap() |
V |
GridCacheEvictionEntry.reload()
This method has the same semantic as
GridCacheProjection.reload(Object) method. |
V |
GridCacheEntryImpl.reload()
This method has the same semantic as
GridCacheProjection.reload(Object) method. |
V |
GridCacheFilterEvaluationEntry.reload()
This method has the same semantic as
GridCacheProjection.reload(Object) method. |
V |
GridCacheProjectionImpl.reload(K key)
Reloads a single key from persistent storage.
|
V |
GridCacheAdapter.reload(K key)
Reloads a single key from persistent storage.
|
V |
GridCacheProxyImpl.reload(K key)
Reloads a single key from persistent storage.
|
V |
GridCacheAdapter.reload(K key,
GridPredicate<GridCacheEntry<K,V>>... filter) |
void |
GridCacheProjectionImpl.reloadAll()
Reloads all currently cached keys form persistent storage.
|
void |
GridCacheAdapter.reloadAll()
Reloads all currently cached keys form persistent storage.
|
void |
GridCacheProxyImpl.reloadAll()
Reloads all currently cached keys form persistent storage.
|
void |
GridCacheProjectionImpl.reloadAll(Collection<? extends K> keys)
Reloads specified entries from underlying persistent storage.
|
void |
GridCacheAdapter.reloadAll(Collection<? extends K> keys)
Reloads specified entries from underlying persistent storage.
|
void |
GridCacheProxyImpl.reloadAll(Collection<? extends K> keys)
Reloads specified entries from underlying persistent storage.
|
Map<K,V> |
GridCacheAdapter.reloadAll(Collection<? extends K> keys,
boolean ret,
GridPredicate<GridCacheEntry<K,V>>... filter) |
void |
GridCacheAdapter.reloadAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter) |
void |
GridCacheAdapter.reloadAll(GridPredicate<GridCacheEntry<K,V>>... filter) |
void |
GridCacheWriteBehindStore.remove(GridCacheTx tx,
K key)
Removes the value identified by given key from persistent storage.
|
V |
GridCacheFilterEvaluationEntry.remove(GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.remove(Object, GridPredicate[]) method. |
V |
GridCacheEvictionEntry.remove(GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.remove(Object, GridPredicate[]) method. |
V |
GridCacheEntryImpl.remove(GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.remove(Object, GridPredicate[]) method. |
V |
GridCacheProjectionEx.remove(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProjectionImpl.remove(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheAdapter.remove(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProxyImpl.remove(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheTxLocalAdapter.remove(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
V |
GridCacheTxLocalEx.remove(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
V |
GridCacheProjectionImpl.remove(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Removes given key mapping from cache.
|
V |
GridCacheAdapter.remove(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Removes given key mapping from cache.
|
V |
GridCacheProxyImpl.remove(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Removes given key mapping from cache.
|
boolean |
GridCacheProjectionImpl.remove(K key,
V val)
Removes given key mapping from cache if one exists and value is equal to the passed in value.
|
boolean |
GridCacheAdapter.remove(K key,
V val)
Removes given key mapping from cache if one exists and value is equal to the passed in value.
|
boolean |
GridCacheProxyImpl.remove(K key,
V val)
Removes given key mapping from cache if one exists and value is equal to the passed in value.
|
boolean |
GridCacheEvictionEntry.remove(V val)
This method has the same semantic as
GridCacheProjection.remove(Object, Object) method. |
boolean |
GridCacheEntryImpl.remove(V val)
This method has the same semantic as
GridCacheProjection.remove(Object, Object) method. |
boolean |
GridCacheFilterEvaluationEntry.remove(V val)
This method has the same semantic as
GridCacheProjection.remove(Object, Object) method. |
void |
GridCacheProjectionImpl.removeAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter)
Removes given key mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
GridCacheAdapter.removeAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter)
Removes given key mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
GridCacheProxyImpl.removeAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Removes given key mappings from cache for entries for which the optionally passed in filters do
pass.
|
GridCacheReturn<V> |
GridCacheTxLocalAdapter.removeAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridCacheReturn<V> |
GridCacheTxLocalEx.removeAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
void |
GridCacheWriteBehindStore.removeAll(GridCacheTx tx,
Collection<? extends K> keys)
Removes all vales identified by given keys from persistent storage.
|
void |
GridCacheProjectionImpl.removeAll(GridPredicate<GridCacheEntry<K,V>>... filter)
Removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
GridCacheAdapter.removeAll(GridPredicate<GridCacheEntry<K,V>>... filter)
Removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
GridCacheProxyImpl.removeAll(GridPredicate<GridCacheEntry<K,V>>[] filter)
Removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
GridCacheProjectionEx.removeAllDr(Map<? extends K,GridCacheVersion> drMap)
Removes DR data.
|
void |
GridCacheProjectionImpl.removeAllDr(Map<? extends K,GridCacheVersion> drMap)
Removes DR data.
|
void |
GridCacheAdapter.removeAllDr(Map<? extends K,GridCacheVersion> drMap)
Removes DR data.
|
void |
GridCacheProxyImpl.removeAllDr(Map<? extends K,GridCacheVersion> drMap)
Removes DR data.
|
void |
GridCacheTxLocalAdapter.removeAllDr(Map<? extends K,GridCacheVersion> drMap) |
void |
GridCacheTxLocalEx.removeAllDr(Map<? extends K,GridCacheVersion> drMap) |
GridFuture<?> |
GridCacheProjectionEx.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
GridFuture<?> |
GridCacheProjectionImpl.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
GridFuture<?> |
GridCacheAdapter.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
GridFuture<?> |
GridCacheProxyImpl.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
boolean |
GridCacheStoreManager.removeAllFromStore(GridCacheTx tx,
Collection<? extends K> keys) |
boolean |
GridCacheStoreManager.removeFromStore(GridCacheTx tx,
K key) |
boolean |
GridCacheFilterEvaluationEntry.removex(GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.removex(Object, GridPredicate[]) method. |
boolean |
GridCacheEvictionEntry.removex(GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.removex(Object, GridPredicate[]) method. |
boolean |
GridCacheEntryImpl.removex(GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.removex(Object, GridPredicate[]) method. |
boolean |
GridCacheProjectionEx.removex(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProjectionImpl.removex(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheAdapter.removex(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProxyImpl.removex(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheTxLocalAdapter.removex(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
boolean |
GridCacheTxLocalEx.removex(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
boolean |
GridCacheAdapter.removex(K key,
GridPredicate<GridCacheEntry<K,V>>... filter)
Removes given key mapping from cache.
|
boolean |
GridCacheProjectionImpl.removex(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Removes given key mapping from cache.
|
boolean |
GridCacheProxyImpl.removex(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Removes given key mapping from cache.
|
GridCacheReturn<V> |
GridCacheProjectionEx.removex(K key,
V val)
Removes given key mapping from cache if one exists and value is equal to the passed in value.
|
GridCacheReturn<V> |
GridCacheProjectionImpl.removex(K key,
V val)
Removes given key mapping from cache if one exists and value is equal to the passed in value.
|
GridCacheReturn<V> |
GridCacheAdapter.removex(K key,
V val)
Removes given key mapping from cache if one exists and value is equal to the passed in value.
|
GridCacheReturn<V> |
GridCacheProxyImpl.removex(K key,
V val)
Removes given key mapping from cache if one exists and value is equal to the passed in value.
|
V |
GridCacheProjectionImpl.replace(K key,
V val)
Stores given key-value pair in cache only if if there is a previous mapping for it.
|
V |
GridCacheAdapter.replace(K key,
V val)
Stores given key-value pair in cache only if if there is a previous mapping for it.
|
V |
GridCacheProxyImpl.replace(K key,
V val)
Stores given key-value pair in cache only if if there is a previous mapping for it.
|
boolean |
GridCacheProjectionImpl.replace(K key,
V oldVal,
V newVal)
Stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
boolean |
GridCacheAdapter.replace(K key,
V oldVal,
V newVal)
Stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
boolean |
GridCacheProxyImpl.replace(K key,
V oldVal,
V newVal)
Stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
V |
GridCacheEvictionEntry.replace(V val)
This method has the same semantic as
GridCacheProjection.replace(Object, Object) method. |
V |
GridCacheEntryImpl.replace(V val)
This method has the same semantic as
GridCacheProjection.replace(Object, Object) method. |
V |
GridCacheFilterEvaluationEntry.replace(V val)
This method has the same semantic as
GridCacheProjection.replace(Object, Object) method. |
boolean |
GridCacheEvictionEntry.replace(V oldVal,
V newVal)
This method has the same semantic as
GridCacheProjection.replace(Object, Object, Object) method. |
boolean |
GridCacheEntryImpl.replace(V oldVal,
V newVal)
This method has the same semantic as
GridCacheProjection.replace(Object, Object, Object) method. |
boolean |
GridCacheFilterEvaluationEntry.replace(V oldVal,
V newVal)
This method has the same semantic as
GridCacheProjection.replace(Object, Object, Object) method. |
boolean |
GridCacheProjectionImpl.replacex(K key,
V val)
Stores given key-value pair in cache only if only if there is a previous mapping for it.
|
boolean |
GridCacheAdapter.replacex(K key,
V val)
Stores given key-value pair in cache only if only if there is a previous mapping for it.
|
boolean |
GridCacheProxyImpl.replacex(K key,
V val)
Stores given key-value pair in cache only if only if there is a previous mapping for it.
|
GridCacheReturn<V> |
GridCacheProjectionEx.replacex(K key,
V oldVal,
V newVal)
Stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
GridCacheReturn<V> |
GridCacheProjectionImpl.replacex(K key,
V oldVal,
V newVal)
Stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
GridCacheReturn<V> |
GridCacheAdapter.replacex(K key,
V oldVal,
V newVal)
Stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
GridCacheReturn<V> |
GridCacheProxyImpl.replacex(K key,
V oldVal,
V newVal)
Stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
boolean |
GridCacheEvictionEntry.replacex(V val)
This method has the same semantic as
GridCacheProjection.replacex(Object, Object) method. |
boolean |
GridCacheEntryImpl.replacex(V val)
This method has the same semantic as
GridCacheProjection.replacex(Object, Object) method. |
boolean |
GridCacheFilterEvaluationEntry.replacex(V val)
This method has the same semantic as
GridCacheProjection.replacex(Object, Object) method. |
void |
GridCacheTxProxyImpl.rollback()
Rolls back this transaction.
|
boolean |
GridCacheIoManager.safeSend(Collection<? extends GridNode> nodes,
GridCacheMessage<K,V> msg,
GridPredicate<GridNode> fallback)
Sends message and automatically accounts for lefts nodes.
|
protected V |
GridCacheMapEntry.saveValueForIndexUnlocked()
This method will return current value only if clearIndex(V) will require previous value (this is the case
for Mongo caches).
|
void |
GridCacheIoManager.send(GridNode node,
GridCacheMessage<K,V> msg)
Sends communication message.
|
void |
GridCacheIoManager.send(GridNode node,
GridCacheMessage<K,V> msg,
GridIoPolicy plc)
Sends communication message.
|
void |
GridCacheIoManager.send(UUID nodeId,
GridCacheMessage<K,V> msg)
Sends communication message.
|
void |
GridCacheIoManager.sendOrderedMessage(GridNode node,
Object topic,
long msgId,
GridCacheMessage<K,V> msg,
long timeout) |
V |
GridCacheFilterEvaluationEntry.set(V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.put(Object, Object, GridPredicate[]) method. |
V |
GridCacheEvictionEntry.set(V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.put(Object, Object, GridPredicate[]) method. |
V |
GridCacheEntryImpl.set(V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.put(Object, Object, GridPredicate[]) method. |
V |
GridCacheEvictionEntry.setIfAbsent(V val)
This method has the same semantic as
GridCacheProjection.putIfAbsent(Object, Object) method. |
V |
GridCacheEntryImpl.setIfAbsent(V val)
This method has the same semantic as
GridCacheProjection.putIfAbsent(Object, Object) method. |
V |
GridCacheFilterEvaluationEntry.setIfAbsent(V val)
This method has the same semantic as
GridCacheProjection.putIfAbsent(Object, Object) method. |
boolean |
GridCacheFilterEvaluationEntry.setx(V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.putx(Object, Object, GridPredicate[]) method. |
boolean |
GridCacheEvictionEntry.setx(V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.putx(Object, Object, GridPredicate[]) method. |
boolean |
GridCacheEntryImpl.setx(V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.putx(Object, Object, GridPredicate[]) method. |
boolean |
GridCacheEvictionEntry.setxIfAbsent(V val)
This method has the same semantic as
GridCacheProjection.putxIfAbsent(Object, Object) method. |
boolean |
GridCacheEntryImpl.setxIfAbsent(V val)
This method has the same semantic as
GridCacheProjection.putxIfAbsent(Object, Object) method. |
boolean |
GridCacheFilterEvaluationEntry.setxIfAbsent(V val)
This method has the same semantic as
GridCacheProjection.putxIfAbsent(Object, Object) method. |
void |
GridCacheProcessor.start()
Starts grid component.
|
void |
GridCacheWriteBehindStore.start()
Performs all the initialization logic for write-behind cache store.
|
void |
GridCacheAdapter.start()
Starts this cache.
|
void |
GridCachePreloaderAdapter.start()
Starts preloading.
|
void |
GridCachePreloader.start()
Starts preloading.
|
void |
GridCacheManager.start(GridCacheContext<K,V> cctx)
Starts manager.
|
void |
GridCacheManagerAdapter.start(GridCacheContext<K,V> cctx)
Starts manager.
|
void |
GridCacheIoManager.start0() |
protected void |
GridCacheStoreManager.start0() |
void |
GridCacheDgcManager.start0() |
void |
GridCacheEvictionManager.start0() |
void |
GridCacheAffinityManager.start0() |
void |
GridCacheSwapManager.start0() |
protected void |
GridCacheManagerAdapter.start0() |
protected void |
GridCacheMvccManager.start0() |
void |
GridCacheVersionManager.start0() |
protected void |
GridCacheTxManager.start0() |
void |
GridCacheDeploymentManager.start0() |
protected void |
GridCacheTtlManager.start0() |
void |
GridCacheWriteBehindStore.stop()
Performs shutdown logic for store.
|
void |
GridCacheProcessor.stop(boolean cancel)
Stops grid component.
|
Iterator<Map.Entry<K,V>> |
GridCacheAdapter.swapIterator()
Gets iterator over keys and values belonging to this cache swap space on local node.
|
Iterator<Map.Entry<K,V>> |
GridCacheProxyImpl.swapIterator()
Gets iterator over keys and values belonging to this cache swap space on local node.
|
GridCloseableIterator<Map.Entry<byte[],GridCacheSwapEntry<V>>> |
GridCacheSwapManager.swapIterator(int part)
Gets swap space iterator over partition.
|
long |
GridCacheAdapter.swapKeys()
Gets number of swap entries (keys).
|
long |
GridCacheSwapManager.swapKeys()
Gets number of swap entries (keys).
|
long |
GridCacheProxyImpl.swapKeys()
Gets number of swap entries (keys).
|
long |
GridCacheAdapter.swapSize()
Gets size in bytes for swap space.
|
long |
GridCacheSwapManager.swapSize() |
long |
GridCacheProxyImpl.swapSize()
Gets size in bytes for swap space.
|
void |
GridCacheEvictionEntry.transform(GridClosure<V,V> transformer)
This method has the same semantic as
GridCacheProjection.transform(Object, GridClosure) method. |
void |
GridCacheEntryImpl.transform(GridClosure<V,V> transformer)
This method has the same semantic as
GridCacheProjection.transform(Object, GridClosure) method. |
void |
GridCacheFilterEvaluationEntry.transform(GridClosure<V,V> transformer)
This method has the same semantic as
GridCacheProjection.transform(Object, GridClosure) method. |
void |
GridCacheProjectionImpl.transform(K key,
GridClosure<V,V> transformer)
Stores result of applying
valTransform closure to the previous value associated with
given key in cache. |
void |
GridCacheAdapter.transform(K key,
GridClosure<V,V> transformer)
Stores result of applying
valTransform closure to the previous value associated with
given key in cache. |
void |
GridCacheProxyImpl.transform(K key,
GridClosure<V,V> transformer)
Stores result of applying
valTransform closure to the previous value associated with
given key in cache. |
boolean |
GridCacheTxLocalAdapter.transform(K key,
GridClosure<V,V> transformer) |
boolean |
GridCacheTxLocalEx.transform(K key,
GridClosure<V,V> valTransform) |
void |
GridCacheProjectionImpl.transformAll(Map<? extends K,? extends GridClosure<V,V>> m)
Stores result of applying transform closures from the given map to previous values associated
with corresponding keys in cache.
|
void |
GridCacheAdapter.transformAll(Map<? extends K,? extends GridClosure<V,V>> m)
Stores result of applying transform closures from the given map to previous values associated
with corresponding keys in cache.
|
void |
GridCacheProxyImpl.transformAll(Map<? extends K,? extends GridClosure<V,V>> m)
Stores result of applying transform closures from the given map to previous values associated
with corresponding keys in cache.
|
void |
GridCacheTxLocalAdapter.transformAll(Map<? extends K,? extends GridClosure<V,V>> map) |
void |
GridCacheTxLocalEx.transformAll(Map<? extends K,? extends GridClosure<V,V>> map) |
void |
GridCacheProjectionImpl.transformAll(Set<? extends K> keys,
GridClosure<V,V> transformer)
Stores result of applying the specified transform closure to previous values associated
with the specified keys in cache.
|
void |
GridCacheAdapter.transformAll(Set<? extends K> keys,
GridClosure<V,V> transformer)
Stores result of applying the specified transform closure to previous values associated
with the specified keys in cache.
|
void |
GridCacheProxyImpl.transformAll(Set<? extends K> keys,
GridClosure<V,V> transformer)
Stores result of applying the specified transform closure to previous values associated
with the specified keys in cache.
|
GridFuture<?> |
GridCacheProjectionImpl.transformAllAsync(Set<? extends K> keys,
GridClosure<V,V> transformer)
Stores result of applying the specified transform closure to previous values associated
with the specified keys in cache.
|
GridFuture<?> |
GridCacheAdapter.transformAllAsync(Set<? extends K> keys,
GridClosure<V,V> transformer)
Stores result of applying the specified transform closure to previous values associated
with the specified keys in cache.
|
GridFuture<?> |
GridCacheProxyImpl.transformAllAsync(Set<? extends K> keys,
GridClosure<V,V> transformer)
Stores result of applying the specified transform closure to previous values associated
with the specified keys in cache.
|
<R> R |
GridCacheProjectionImpl.transformAndCompute(K key,
GridClosure<V,GridBiTuple<V,R>> transformer)
Applies
transformer closure to the previous value associated with given key in cache,
closure should return GridBiTuple instance where first value is new value stored in cache
and second value is returned as result of this method. |
<R> R |
GridCacheAdapter.transformAndCompute(K key,
GridClosure<V,GridBiTuple<V,R>> transformer)
Applies
transformer closure to the previous value associated with given key in cache,
closure should return GridBiTuple instance where first value is new value stored in cache
and second value is returned as result of this method. |
<R> R |
GridCacheProxyImpl.transformAndCompute(K key,
GridClosure<V,GridBiTuple<V,R>> transformer)
Applies
transformer closure to the previous value associated with given key in cache,
closure should return GridBiTuple instance where first value is new value stored in cache
and second value is returned as result of this method. |
<R> R |
GridCacheTxLocalAdapter.transformCompute(K key,
GridClosure<V,GridBiTuple<V,R>> transformer) |
<R> R |
GridCacheTxLocalEx.transformCompute(K key,
GridClosure<V,GridBiTuple<V,R>> transformer) |
void |
GridCacheStoreManager.txEnd(GridCacheTx tx,
boolean commit) |
void |
GridCacheWriteBehindStore.txEnd(GridCacheTx tx,
boolean commit)
Tells store to commit or rollback a transaction depending on the value of the
'commit'
parameter. |
GridCacheTx |
GridCacheProjectionImpl.txStartAffinity(Object affinityKey,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts
affinity-group-locked transaction based on affinity key. |
GridCacheTx |
GridCacheAdapter.txStartAffinity(Object affinityKey,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts
affinity-group-locked transaction based on affinity key. |
GridCacheTx |
GridCacheProxyImpl.txStartAffinity(Object affinityKey,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts
affinity-group-locked transaction based on affinity key. |
GridCacheTx |
GridCacheProjectionImpl.txStartPartition(int partId,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts
partition-group-locked transaction based on partition ID. |
GridCacheTx |
GridCacheAdapter.txStartPartition(int partId,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts
partition-group-locked transaction based on partition ID. |
GridCacheTx |
GridCacheProxyImpl.txStartPartition(int partId,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts
partition-group-locked transaction based on partition ID. |
void |
GridCacheFilterEvaluationEntry.unlock(GridPredicate<GridCacheEntry<K,V>>... filter)
Unlocks this entry only if current thread owns the lock.
|
void |
GridCacheEvictionEntry.unlock(GridPredicate<GridCacheEntry<K,V>>[] filter)
Unlocks this entry only if current thread owns the lock.
|
void |
GridCacheEntryImpl.unlock(GridPredicate<GridCacheEntry<K,V>>[] filter)
Unlocks this entry only if current thread owns the lock.
|
void |
GridCacheAdapter.unlock(K key,
GridPredicate<GridCacheEntry<K,V>>... filter)
Unlocks given key only if current thread owns the lock.
|
void |
GridCacheProjectionImpl.unlock(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Unlocks given key only if current thread owns the lock.
|
void |
GridCacheProxyImpl.unlock(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Unlocks given key only if current thread owns the lock.
|
void |
GridCacheProjectionImpl.unlockAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Unlocks given keys only if current thread owns the locks.
|
void |
GridCacheProxyImpl.unlockAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Unlocks given keys only if current thread owns the locks.
|
void |
GridCacheTxEntry.unmarshal(GridCacheContext<K,V> ctx,
ClassLoader clsLdr)
Unmarshalls entry.
|
void |
GridCacheEntryInfo.unmarshal(GridCacheContext<K,V> ctx,
ClassLoader clsLdr)
Unmarshalls entry.
|
protected <K1> LinkedHashMap<K1,Boolean> |
GridCacheMessage.unmarshalBooleanLinkedMap(Map<byte[],Boolean> byteMap,
GridCacheContext<K,V> ctx,
ClassLoader ldr) |
protected <T> List<T> |
GridCacheMessage.unmarshalCollection(Collection<byte[]> byteCol,
GridCacheContext<K,V> ctx,
ClassLoader ldr) |
protected <T> GridPredicate<GridCacheEntry<K,V>>[] |
GridCacheMessage.unmarshalFilter(byte[][] byteCol,
GridCacheContext<K,V> ctx,
ClassLoader ldr) |
protected void |
GridCacheMessage.unmarshalInfo(GridCacheEntryInfo<K,V> info,
GridCacheContext<K,V> ctx,
ClassLoader ldr) |
protected void |
GridCacheMessage.unmarshalInfos(Iterable<? extends GridCacheEntryInfo<K,V>> infos,
GridCacheContext<K,V> ctx,
ClassLoader ldr) |
protected void |
GridCacheMessage.unmarshalTx(Iterable<GridCacheTxEntry<K,V>> txEntries,
GridCacheContext<K,V> ctx,
ClassLoader ldr) |
void |
GridCacheEntryInfo.unmarshalValue(GridCacheContext<K,V> ctx,
ClassLoader ldr) |
protected <T> List<T> |
GridCacheMessage.unmarshalValueBytesCollection(Collection<GridCacheValueBytes> byteCol,
GridCacheContext<K,V> ctx,
ClassLoader ldr) |
V |
GridCacheMapEntry.unswap()
Unswaps an entry.
|
V |
GridCacheEntryEx.unswap() |
V |
GridCacheMapEntry.unswap(boolean ignoreFlags)
Unswaps an entry.
|
V |
GridCacheEntryEx.unswap(boolean ignoreFlags)
Unswap ignoring flags.
|
protected void |
GridCacheMapEntry.updateIndex(V val,
byte[] valBytes,
long expireTime,
GridCacheVersion ver,
V prevVal)
Updates cache index.
|
void |
GridCacheTxLocalAdapter.userCommit() |
void |
GridCacheTxLocalEx.userCommit() |
protected void |
GridCacheTxLocalAdapter.userPrepare() |
void |
GridCacheTxLocalAdapter.userRollback() |
void |
GridCacheTxLocalEx.userRollback() |
GridCacheValueBytes |
GridCacheMapEntry.valueBytes(GridCacheVersion ver)
Gets cached serialized value bytes.
|
GridCacheValueBytes |
GridCacheEntryEx.valueBytes(GridCacheVersion ver)
Gets cached serialized value bytes.
|
boolean |
GridCacheMapEntry.versionedValue(V val,
GridCacheVersion curVer,
GridCacheVersion newVer)
Sets new value if passed in version matches the current version
(used for read-through only).
|
boolean |
GridCacheEntryEx.versionedValue(V val,
GridCacheVersion curVer,
GridCacheVersion newVer)
Sets new value if passed in version matches the current version
(used for read-through only).
|
GridCacheEntry<K,V> |
GridCacheMapEntry.wrapFilterLocked()
Wraps this map entry into cache entry for filter evaluation inside entry lock.
|
GridCacheEntry<K,V> |
GridCacheEntryEx.wrapFilterLocked()
Wraps this map entry into cache entry for filter evaluation inside entry lock.
|
| Modifier and Type | Method and Description |
|---|---|
long |
GridCacheAtomicLongImpl.addAndGet(long l)
Adds
l and gets current value of atomic long. |
long |
GridCacheAtomicSequenceImpl.addAndGet(long l)
Adds
l elements to atomic sequence and gets value of atomic sequence. |
Object |
GridCacheAnnotationHelper.annotatedValue(Object target)
Returns annotated value.
|
GridCacheAtomicLong |
GridCacheDataStructuresManager.atomicLong(String name,
long initVal,
boolean create)
Gets an atomic long from cache or creates one if it's not cached.
|
GridCacheAtomicLong |
GridCacheDataStructuresProxy.atomicLong(String name,
long initVal,
boolean create)
Will get a atomic long from cache and create one if it has not been created yet and
create flag
is true. |
GridCacheAtomicLong |
GridCacheDataStructuresImpl.atomicLong(String name,
long initVal,
boolean create)
Will get a atomic long from cache and create one if it has not been created yet and
create flag
is true. |
<T> GridCacheAtomicReference<T> |
GridCacheDataStructuresManager.atomicReference(String name,
T initVal,
boolean create)
Gets an atomic reference from cache or creates one if it's not cached.
|
<T> GridCacheAtomicReference<T> |
GridCacheDataStructuresProxy.atomicReference(String name,
T initVal,
boolean create)
Will get a atomic reference from cache and create one if it has not been created yet and
create flag
is true. |
<T> GridCacheAtomicReference<T> |
GridCacheDataStructuresImpl.atomicReference(String name,
T initVal,
boolean create)
Will get a atomic reference from cache and create one if it has not been created yet and
create flag
is true. |
GridCacheAtomicSequence |
GridCacheDataStructuresProxy.atomicSequence(String name,
long initVal,
boolean create)
Will get an atomic sequence from cache and create one if it has not been created yet and
create flag
is true. |
GridCacheAtomicSequence |
GridCacheDataStructuresImpl.atomicSequence(String name,
long initVal,
boolean create)
Will get an atomic sequence from cache and create one if it has not been created yet and
create flag
is true. |
<T,S> GridCacheAtomicStamped<T,S> |
GridCacheDataStructuresManager.atomicStamped(String name,
T initVal,
S initStamp,
boolean create)
Gets an atomic stamped from cache or creates one if it's not cached.
|
<T,S> GridCacheAtomicStamped<T,S> |
GridCacheDataStructuresProxy.atomicStamped(String name,
T initVal,
S initStamp,
boolean create)
Will get a atomic stamped from cache and create one if it has not been created yet and
create flag
is true. |
<T,S> GridCacheAtomicStamped<T,S> |
GridCacheDataStructuresImpl.atomicStamped(String name,
T initVal,
S initStamp,
boolean create)
Will get a atomic stamped from cache and create one if it has not been created yet and
create flag
is true. |
void |
GridCacheCountDownLatchImpl.await()
Causes the current thread to wait until the latch has counted down to
zero, unless current thread is interrupted.
|
boolean |
GridCacheCountDownLatchImpl.await(long timeout)
Causes the current thread to wait until the latch has counted down to
zero, unless the thread is interrupted, or the specified waiting time elapses.
|
boolean |
GridCacheCountDownLatchImpl.await(long timeout,
TimeUnit unit)
Causes the current thread to wait until the latch has counted down to
zero, unless the thread is interrupted, or the specified waiting time elapses.
|
boolean |
GridCacheQueueProxy.bounded()
Returns
true if this queue is bounded. |
int |
GridCacheQueueProxy.capacity()
Gets maximum number of elements of the queue.
|
int |
GridCacheQueueAdapter.capacity()
Gets maximum number of elements of the queue.
|
boolean |
GridCacheQueueProxy.collocated()
Returns
true if this queue can be kept on the one node only. |
boolean |
GridCacheSetProxy.collocated()
Returns
true if this set can be kept on the one node only. |
boolean |
GridCacheAtomicLongImpl.compareAndSet(long expVal,
long newVal)
Atomically compares current value to the expected value, and if they are equal, sets current value
to new value.
|
boolean |
GridCacheAtomicReferenceImpl.compareAndSet(T expVal,
T newVal)
Conditionally sets the new value.
|
boolean |
GridCacheAtomicStampedImpl.compareAndSet(T expVal,
T newVal,
S expStamp,
S newStamp)
Conditionally sets the new value and new stamp.
|
int |
GridCacheCountDownLatchImpl.countDown()
Decrements the count of the latch, releasing all waiting threads
on all nodes if the count reaches zero.
|
int |
GridCacheCountDownLatchImpl.countDown(int val)
Decreases the count of the latch using passed in value,
releasing all waiting threads on all nodes if the count reaches zero.
|
void |
GridCacheCountDownLatchImpl.countDownAll()
Counts down this latch to zero, releasing all waiting threads on all nodes.
|
GridCacheCountDownLatch |
GridCacheDataStructuresManager.countDownLatch(String name,
int cnt,
boolean autoDel,
boolean create)
Gets or creates count down latch.
|
GridCacheCountDownLatch |
GridCacheDataStructuresProxy.countDownLatch(String name,
int cnt,
boolean autoDel,
boolean create)
Gets or creates count down latch.
|
GridCacheCountDownLatch |
GridCacheDataStructuresImpl.countDownLatch(String name,
int cnt,
boolean autoDel,
boolean create)
Gets or creates count down latch.
|
long |
GridCacheAtomicLongImpl.decrementAndGet()
Decrements and gets current value of atomic long.
|
long |
GridCacheAtomicLongImpl.get()
Gets current value of atomic long.
|
T |
GridCacheAtomicReferenceImpl.get()
Gets current value of an atomic reference.
|
long |
GridCacheAtomicSequenceImpl.get()
Gets current value of atomic sequence.
|
GridBiTuple<T,S> |
GridCacheAtomicStampedImpl.get()
Gets both current value and current stamp of atomic stamped.
|
long |
GridCacheAtomicLongImpl.getAndAdd(long l)
Gets current value of atomic long and adds
l. |
long |
GridCacheAtomicSequenceImpl.getAndAdd(long l)
Gets current value of atomic sequence and adds
l elements. |
long |
GridCacheAtomicLongImpl.getAndDecrement()
Gets and decrements current value of atomic long.
|
long |
GridCacheAtomicLongImpl.getAndIncrement()
Gets and increments current value of atomic long.
|
long |
GridCacheAtomicSequenceImpl.getAndIncrement()
Gets and increments current value of atomic sequence.
|
long |
GridCacheAtomicLongImpl.getAndSet(long l)
Gets current value of atomic long and sets new value
l of atomic long. |
long |
GridCacheAtomicLongImpl.incrementAndGet()
Increments and gets current value of atomic long.
|
long |
GridCacheAtomicSequenceImpl.incrementAndGet()
Increments and returns the value of atomic sequence.
|
<T> GridCacheQueue<T> |
GridCacheDataStructuresManager.queue(String name,
int cap,
boolean colloc,
boolean create)
Gets a queue from cache or creates one if it's not cached.
|
<T> GridCacheQueue<T> |
GridCacheDataStructuresProxy.queue(String name,
int cap,
boolean collocated,
boolean create)
Will get a named queue from cache and create one if it has not been created yet and
create flag
is true. |
<T> GridCacheQueue<T> |
GridCacheDataStructuresImpl.queue(String name,
int cap,
boolean collocated,
boolean create)
Will get a named queue from cache and create one if it has not been created yet and
create flag
is true. |
boolean |
GridCacheDataStructuresManager.removeAtomicLong(String name)
Removes atomic long from cache.
|
boolean |
GridCacheDataStructuresProxy.removeAtomicLong(String name)
Remove atomic long from cache.
|
boolean |
GridCacheDataStructuresImpl.removeAtomicLong(String name)
Remove atomic long from cache.
|
boolean |
GridCacheDataStructuresManager.removeAtomicReference(String name)
Removes atomic reference from cache.
|
boolean |
GridCacheDataStructuresProxy.removeAtomicReference(String name)
Remove atomic reference from cache.
|
boolean |
GridCacheDataStructuresImpl.removeAtomicReference(String name)
Remove atomic reference from cache.
|
boolean |
GridCacheDataStructuresProxy.removeAtomicSequence(String name)
Remove sequence from cache.
|
boolean |
GridCacheDataStructuresImpl.removeAtomicSequence(String name)
Remove sequence from cache.
|
boolean |
GridCacheDataStructuresManager.removeAtomicStamped(String name)
Removes atomic stamped from cache.
|
boolean |
GridCacheDataStructuresProxy.removeAtomicStamped(String name)
Remove atomic stamped from cache.
|
boolean |
GridCacheDataStructuresImpl.removeAtomicStamped(String name)
Remove atomic stamped from cache.
|
boolean |
GridCacheDataStructuresManager.removeCountDownLatch(String name)
Removes count down latch from cache.
|
boolean |
GridCacheDataStructuresProxy.removeCountDownLatch(String name)
Removes count down latch from cache.
|
boolean |
GridCacheDataStructuresImpl.removeCountDownLatch(String name)
Removes count down latch from cache.
|
protected abstract void |
GridCacheQueueAdapter.removeItem(long rmvIdx)
Removes item with given index from queue.
|
protected void |
GridTransactionalCacheQueueImpl.removeItem(long rmvIdx)
Removes item with given index from queue.
|
protected void |
GridAtomicCacheQueueImpl.removeItem(long rmvIdx)
Removes item with given index from queue.
|
boolean |
GridCacheDataStructuresProxy.removeQueue(String name)
Remove queue from cache.
|
boolean |
GridCacheDataStructuresImpl.removeQueue(String name)
Remove queue from cache.
|
boolean |
GridCacheDataStructuresManager.removeQueue(String name,
int batchSize)
Removes queue from cache.
|
boolean |
GridCacheDataStructuresProxy.removeQueue(String name,
int batchSize)
Remove queue from cache.
|
boolean |
GridCacheDataStructuresImpl.removeQueue(String name,
int batchSize)
Remove queue from cache.
|
boolean |
GridCacheDataStructuresManager.removeSequence(String name)
Removes sequence from cache.
|
boolean |
GridCacheDataStructuresManager.removeSet(String name)
Removes set.
|
boolean |
GridCacheDataStructuresProxy.removeSet(String name)
Removes set from cache.
|
boolean |
GridCacheDataStructuresImpl.removeSet(String name)
Removes set from cache.
|
GridCacheAtomicSequence |
GridCacheDataStructuresManager.sequence(String name,
long initVal,
boolean create)
Gets a sequence from cache or creates one if it's not cached.
|
<T> GridCacheSet<T> |
GridCacheDataStructuresManager.set(String name,
boolean collocated,
boolean create)
Gets a set from cache or creates one if it's not cached.
|
<T> GridCacheSet<T> |
GridCacheDataStructuresProxy.set(String name,
boolean collocated,
boolean create)
Will get a named set from cache and create one if it has not been created yet and
create flag
is true. |
<T> GridCacheSet<T> |
GridCacheDataStructuresImpl.set(String name,
boolean collocated,
boolean create)
Will get a named set from cache and create one if it has not been created yet and
create flag
is true. |
void |
GridCacheAtomicReferenceImpl.set(T val)
Unconditionally sets the value.
|
void |
GridCacheAtomicStampedImpl.set(T val,
S stamp)
Unconditionally sets the value and the stamp.
|
S |
GridCacheAtomicStampedImpl.stamp()
Gets current stamp.
|
T |
GridCacheAtomicStampedImpl.value()
Gets current value.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridDistributedUnlockRequest.addKey(K key,
byte[] bytes,
GridCacheContext<K,V> ctx) |
void |
GridDistributedLockRequest.addKeyBytes(K key,
byte[] keyBytes,
GridCacheTxEntry<K,V> writeEntry,
boolean retVal,
Collection<GridCacheMvccCandidate<K>> cands,
GridCacheVersion drVer,
GridCacheContext<K,V> ctx)
Adds a key.
|
void |
GridDistributedLockResponse.addValueBytes(V val,
byte[] valBytes,
GridCacheContext<K,V> ctx) |
void |
GridDistributedTxRemoteAdapter.commit()
Commits this transaction by initiating
two-phase-commit process. |
void |
GridDistributedTxPrepareResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDistributedTxPrepareRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDistributedTxFinishRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDistributedLockRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDistributedBaseMessage.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDistributedUnlockRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDistributedLockResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridCachePessimisticCheckCommittedTxResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDistributedTxRemoteAdapter.forceCommit()
Forces commit for this tx.
|
V |
GridPartitionedCacheEntryImpl.peek(Collection<GridCachePeekMode> modes)
This method has the same semantic as
GridCacheProjection.peek(Object, Collection) method. |
void |
GridDistributedTxRemoteAdapter.prepare()
Prepare phase.
|
void |
GridDistributedTxPrepareResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedTxPrepareRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedTxFinishRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedLockRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedBaseMessage.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedUnlockRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedLockResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridCachePessimisticCheckCommittedTxResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtLockRequest.addDhtKey(K key,
byte[] keyBytes,
GridCacheTxEntry<K,V> writeEntry,
GridCacheVersion drVer,
boolean invalidateEntry,
GridCacheContext<K,V> ctx)
Adds a DHT key.
|
GridFuture<Boolean> |
GridDhtTxLocalAdapter.addEntry(long msgId,
GridCacheTxEntry<K,V> e) |
void |
GridDhtUnlockRequest.addNearKey(K key,
byte[] keyBytes,
GridCacheContext<K,V> ctx)
Adds a Near key.
|
void |
GridDhtLockRequest.addNearKey(K key,
byte[] keyBytes,
GridCacheContext<K,V> ctx)
Adds a Near key.
|
boolean |
GridDhtPartitionTopology.afterExchange(GridDhtPartitionExchangeId exchId)
Post-initializes this topology.
|
void |
GridDhtPartitionTopology.beforeExchange(GridDhtPartitionExchangeId exchId)
Pre-initializes this topology.
|
long |
GridDhtCacheAdapter.beginMultiUpdate()
Starts multi-update lock.
|
boolean |
GridDhtCacheEntry.clearInternal(GridCacheVersion ver,
boolean swap)
Marks entry as obsolete and, if possible or required, removes it
from swap storage.
|
void |
GridDhtCacheAdapter.endMultiUpdate()
Ends multi-update lock.
|
boolean |
GridDhtTxLocalAdapter.finish(boolean commit)
Finishes transaction (either commit or rollback).
|
boolean |
GridDhtTxLocal.finish(boolean commit)
Finishes transaction (either commit or rollback).
|
void |
GridDhtTxPrepareResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtUnlockRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtAffinityAssignmentResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtLockRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtTxPrepareRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtTxFinishRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtLockResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtCacheAdapter.loadCache(GridBiPredicate<K,V> p,
long ttl,
Object[] args)
Delegates to
GridCacheStore.loadCache(GridBiInClosure,Object...) method
to load state from the underlying persistent storage. |
int |
GridDhtCacheEntry.memorySize() |
void |
GridDhtLocalPartition.onDeferredDelete(K key,
GridCacheVersion ver) |
void |
GridDhtCacheAdapter.onKernalStart()
Kernal start callback.
|
V |
GridDhtCacheEntryImpl.peek(Collection<GridCachePeekMode> modes)
This method has the same semantic as
GridCacheProjection.peek(Object, Collection) method. |
void |
GridDhtTxPrepareResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtAffinityAssignmentResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtLockRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtTxPrepareRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtTxFinishRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtLockResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
V |
GridDhtCacheAdapter.reload(K key,
GridPredicate<GridCacheEntry<K,V>>... filter) |
void |
GridDhtTxLocalAdapter.rollback()
Rolls back this transaction.
|
void |
GridDhtTransactionalCacheAdapter.start()
Starts this cache.
|
void |
GridDhtCache.start()
Starts this cache.
|
GridDiscoveryTopologySnapshot |
GridDhtTopologyFuture.topologySnapshot()
Gets a topology snapshot for the topology version represented by the future.
|
| Modifier and Type | Method and Description |
|---|---|
GridException |
GridDhtAtomicUpdateResponse.error() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtAtomicUpdateResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtAtomicUpdateRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridNearAtomicUpdateResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridNearAtomicUpdateRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
V |
GridDhtAtomicCache.peek(K key,
Collection<GridCachePeekMode> modes)
Peeks at cached value using optional set of peek modes.
|
void |
GridDhtAtomicUpdateResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtAtomicUpdateRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearAtomicUpdateResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearAtomicUpdateRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
V |
GridDhtAtomicCache.put(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
void |
GridDhtAtomicCache.putAll(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pairs in cache.
|
void |
GridDhtAtomicCache.putAllDr(Map<? extends K,GridCacheDrInfo<V>> drMap)
Store DR data.
|
V |
GridDhtAtomicCache.putIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
boolean |
GridDhtAtomicCache.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridDhtAtomicCache.putx(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pair in cache.
|
boolean |
GridDhtAtomicCache.putxIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
V |
GridDhtAtomicCache.remove(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridDhtAtomicCache.remove(K key,
V val)
Removes given key mapping from cache if one exists and value is equal to the passed in value.
|
void |
GridDhtAtomicCache.removeAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter)
Removes given key mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
GridDhtAtomicCache.removeAll(GridPredicate<GridCacheEntry<K,V>>[] filter)
Removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
GridDhtAtomicCache.removeAllDr(Map<? extends K,GridCacheVersion> drMap)
Removes DR data.
|
boolean |
GridDhtAtomicCache.removex(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridCacheReturn<V> |
GridDhtAtomicCache.removex(K key,
V val)
Removes given key mapping from cache if one exists and value is equal to the passed in value.
|
V |
GridDhtAtomicCache.replace(K key,
V val)
Stores given key-value pair in cache only if if there is a previous mapping for it.
|
boolean |
GridDhtAtomicCache.replace(K key,
V oldVal,
V newVal)
Stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
boolean |
GridDhtAtomicCache.replacex(K key,
V val)
Stores given key-value pair in cache only if only if there is a previous mapping for it.
|
GridCacheReturn<V> |
GridDhtAtomicCache.replacex(K key,
V oldVal,
V newVal)
Stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
void |
GridDhtAtomicCache.start()
Starts this cache.
|
void |
GridDhtAtomicCache.transform(K key,
GridClosure<V,V> transformer)
Stores result of applying
valTransform closure to the previous value associated with
given key in cache. |
void |
GridDhtAtomicCache.transformAll(Map<? extends K,? extends GridClosure<V,V>> m)
Stores result of applying transform closures from the given map to previous values associated
with corresponding keys in cache.
|
<R> R |
GridDhtAtomicCache.transformAndCompute(K key,
GridClosure<V,GridBiTuple<V,R>> transformer)
Applies
transformer closure to the previous value associated with given key in cache,
closure should return GridBiTuple instance where first value is new value stored in cache
and second value is returned as result of this method. |
GridCacheEntry<K,V> |
GridDhtAtomicCacheEntry.wrapFilterLocked()
Wraps this map entry into cache entry for filter evaluation inside entry lock.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridDhtDetachedCacheEntry.clearIndex(V val)
Clears index.
|
V |
GridDhtColocatedCache.peek(K key,
Collection<GridCachePeekMode> modes)
Peeks at cached value using optional set of peek modes.
|
void |
GridDhtDetachedCacheEntry.resetFromPrimary(V val,
byte[] valBytes,
GridCacheVersion ver)
Sets value to detached entry so it can be retrieved in transactional gets.
|
void |
GridDhtColocatedCache.start()
Starts this cache.
|
protected void |
GridDhtDetachedCacheEntry.updateIndex(V val,
byte[] valBytes,
long expireTime,
GridCacheVersion ver,
V old)
Updates cache index.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtPartitionSupplyMessage.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtPartitionsSingleMessage.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtPartitionDemandMessage.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtForceKeysResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtPartitionsFullMessage.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtForceKeysRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtPreloader.onKernalStart()
Kernal start callback.
|
void |
GridDhtPartitionSupplyMessage.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtPartitionsSingleMessage.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtPartitionDemandMessage.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtForceKeysResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtPartitionsFullMessage.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtForceKeysRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
GridDiscoveryTopologySnapshot |
GridDhtPartitionsExchangeFuture.topologySnapshot()
Gets a topology snapshot for the topology version represented by the future.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearTxRemote.addEntries(ClassLoader ldr,
Iterable<GridCacheTxEntry<K,V>> entries)
Adds entries to started near remote tx.
|
void |
GridNearLockRequest.addKeyBytes(K key,
byte[] keyBytes,
boolean retVal,
GridCacheVersion dhtVer,
GridCacheTxEntry<K,V> writeEntry,
GridCacheVersion drVer,
GridCacheContext<K,V> ctx)
Adds a key.
|
void |
GridNearLockResponse.addValueBytes(V val,
byte[] valBytes,
boolean filterPassed,
GridCacheVersion dhtVer,
GridCacheVersion mappedVer,
GridCacheContext<K,V> ctx) |
boolean |
GridNearCacheAdapter.compact(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
void |
GridNearLockRequest.filter(GridPredicate<GridCacheEntry<K,V>>[] filter,
GridCacheContext<K,V> ctx) |
void |
GridNearGetResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridNearTxPrepareResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridNearGetRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr) |
void |
GridNearTxFinishResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridNearLockRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridNearCacheAdapter.loadCache(GridBiPredicate<K,V> p,
long ttl,
Object[] args)
Delegates to
GridCacheStore.loadCache(GridBiInClosure,Object...) method
to load state from the underlying persistent storage. |
boolean |
GridNearCacheEntry.loadedValue(GridCacheTxEx tx,
UUID primaryNodeId,
V val,
byte[] valBytes,
GridCacheVersion ver,
GridCacheVersion dhtVer,
GridCacheVersion expVer,
long ttl,
long expireTime,
boolean evt,
long topVer,
UUID subjId) |
int |
GridNearCacheEntry.memorySize() |
Iterator<Map.Entry<K,V>> |
GridNearCacheAdapter.offHeapIterator()
Gets iterator over keys and values belonging to this cache off-heap memory on local node.
|
V |
GridNearCacheAdapter.peek(K key,
Collection<GridCachePeekMode> modes)
Peeks at cached value using optional set of peek modes.
|
void |
GridNearGetResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearTxPrepareResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearGetRequest.prepareMarshal(GridCacheContext<K,V> ctx) |
void |
GridNearTxFinishResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearLockRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
V |
GridNearCacheAdapter.promote(K key)
This method promotes cache entry from offheap by given key, if any, from offheap or swap storage
into memory.
|
void |
GridNearCacheAdapter.promoteAll(Collection<? extends K> keys)
This method unswaps cache entries by given keys, if any, from swap storage
into memory.
|
V |
GridNearAtomicCache.put(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
void |
GridNearAtomicCache.putAll(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pairs in cache.
|
void |
GridNearAtomicCache.putAllDr(Map<? extends K,GridCacheDrInfo<V>> drMap)
Store DR data.
|
GridFuture<?> |
GridNearAtomicCache.putAllDrAsync(Map<? extends K,GridCacheDrInfo<V>> drMap)
Store DR data asynchronously.
|
V |
GridNearAtomicCache.putIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
boolean |
GridNearAtomicCache.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridNearAtomicCache.putx(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pair in cache.
|
boolean |
GridNearAtomicCache.putxIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
protected V |
GridNearCacheEntry.readThrough(GridCacheTxEx<K,V> tx,
K key,
boolean reload,
GridPredicate<GridCacheEntry<K,V>>[] filter,
UUID subjId) |
V |
GridNearCacheAdapter.reload(K key,
GridPredicate<GridCacheEntry<K,V>>... filter) |
void |
GridNearCacheAdapter.reloadAll()
Reloads all currently cached keys form persistent storage.
|
void |
GridNearCacheAdapter.reloadAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter) |
V |
GridNearAtomicCache.remove(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridNearAtomicCache.remove(K key,
V val)
Removes given key mapping from cache if one exists and value is equal to the passed in value.
|
void |
GridNearAtomicCache.removeAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter)
Removes given key mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
GridNearAtomicCache.removeAll(GridPredicate<GridCacheEntry<K,V>>[] filter)
Removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
GridNearAtomicCache.removeAllDr(Map<? extends K,GridCacheVersion> drMap)
Removes DR data.
|
GridFuture<?> |
GridNearAtomicCache.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
boolean |
GridNearAtomicCache.removex(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridCacheReturn<V> |
GridNearAtomicCache.removex(K key,
V val)
Removes given key mapping from cache if one exists and value is equal to the passed in value.
|
V |
GridNearAtomicCache.replace(K key,
V val)
Stores given key-value pair in cache only if if there is a previous mapping for it.
|
boolean |
GridNearAtomicCache.replace(K key,
V oldVal,
V newVal)
Stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
boolean |
GridNearAtomicCache.replacex(K key,
V val)
Stores given key-value pair in cache only if only if there is a previous mapping for it.
|
GridCacheReturn<V> |
GridNearAtomicCache.replacex(K key,
V oldVal,
V newVal)
Stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
boolean |
GridNearCacheEntry.resetFromPrimary(V val,
byte[] valBytes,
GridCacheVersion ver,
GridCacheVersion dhtVer,
UUID primaryNodeId)
This method should be called only when lock is owned on this entry.
|
void |
GridNearTransactionalCache.start()
Starts this cache.
|
void |
GridNearAtomicCache.start()
Starts this cache.
|
GridNearTxRemote<K,V> |
GridNearTransactionalCache.startRemoteTx(ClassLoader ldr,
UUID nodeId,
GridDhtTxPrepareRequest<K,V> req)
Called while processing dht tx prepare request.
|
GridNearTxRemote<K,V> |
GridNearTransactionalCache.startRemoteTx(UUID nodeId,
GridDhtLockRequest<K,V> req) |
GridNearTxRemote<K,V> |
GridNearTransactionalCache.startRemoteTxForFinish(UUID nodeId,
GridDhtTxFinishRequest<K,V> req) |
Iterator<Map.Entry<K,V>> |
GridNearCacheAdapter.swapIterator()
Gets iterator over keys and values belonging to this cache swap space on local node.
|
long |
GridNearCacheAdapter.swapKeys()
Gets number of swap entries (keys).
|
long |
GridNearCacheAdapter.swapSize()
Gets size in bytes for swap space.
|
void |
GridNearAtomicCache.transform(K key,
GridClosure<V,V> transformer)
Stores result of applying
valTransform closure to the previous value associated with
given key in cache. |
void |
GridNearAtomicCache.transformAll(Map<? extends K,? extends GridClosure<V,V>> m)
Stores result of applying transform closures from the given map to previous values associated
with corresponding keys in cache.
|
<R> R |
GridNearAtomicCache.transformAndCompute(K key,
GridClosure<V,GridBiTuple<V,R>> transformer)
Applies
transformer closure to the previous value associated with given key in cache,
closure should return GridBiTuple instance where first value is new value stored in cache
and second value is returned as result of this method. |
void |
GridNearAtomicCache.unlockAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter)
Unlocks given keys only if current thread owns the locks.
|
protected void |
GridNearCacheEntry.updateIndex(V val,
byte[] valBytes,
long expireTime,
GridCacheVersion ver,
V old)
Updates cache index.
|
| Constructor and Description |
|---|
GridNearTxRemote(ClassLoader ldr,
UUID nodeId,
UUID nearNodeId,
long rmtThreadId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
boolean invalidate,
long timeout,
Collection<GridCacheTxEntry<K,V>> writeEntries,
GridCacheContext<K,V> ctx,
int txSize,
Object grpLockKey,
UUID subjId)
This constructor is meant for optimistic transactions.
|
GridNearTxRemote(UUID nodeId,
UUID nearNodeId,
GridCacheVersion nearXidVer,
long rmtThreadId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
boolean invalidate,
long timeout,
K key,
byte[] keyBytes,
V val,
byte[] valBytes,
GridCacheVersion drVer,
GridCacheContext<K,V> ctx,
int txSize,
Object grpLockKey,
UUID subjId)
This constructor is meant for pessimistic transactions.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheDrManager.beforeExchange(long topVer,
boolean left)
Process partitions "before exchange" event.
|
Collection<GridDrStateTransferDescriptor> |
GridCacheDrManager.listStateTransfers()
List currently active state transfers.
|
void |
GridCacheDrManager.pause()
Pauses data center replication.
|
void |
GridCacheDrManager.resume()
Resumes data center replication.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridOsCacheDrManager.beforeExchange(long topVer,
boolean left)
Process partitions "before exchange" event.
|
Collection<GridDrStateTransferDescriptor> |
GridOsCacheDrManager.listStateTransfers()
List currently active state transfers.
|
void |
GridOsCacheDrManager.onKernalStart() |
void |
GridOsCacheDrManager.pause()
Pauses data center replication.
|
void |
GridOsCacheDrManager.resume()
Resumes data center replication.
|
void |
GridOsCacheDrManager.start(GridCacheContext<K,V> cctx)
Starts manager.
|
| Modifier and Type | Method and Description |
|---|---|
abstract void |
GridCacheJtaManagerAdapter.checkJta()
Checks if cache is working in JTA transaction and enlist cache as XAResource if necessary.
|
void |
GridCacheNoopJtaManager.checkJta()
Checks if cache is working in JTA transaction and enlist cache as XAResource if necessary.
|
abstract void |
GridCacheJtaManagerAdapter.createTmLookup(GridCacheConfiguration ccfg)
Creates transaction manager finder.
|
void |
GridCacheNoopJtaManager.createTmLookup(GridCacheConfiguration ccfg)
Creates transaction manager finder.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridLocalCache.unlockAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Unlocks given keys only if current thread owns the locks.
|
| Modifier and Type | Method and Description |
|---|---|
V |
GridLocalAtomicCache.get(K key,
GridPredicate<GridCacheEntry<K,V>> filter) |
Map<K,V> |
GridLocalAtomicCache.getAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>> filter) |
V |
GridLocalAtomicCache.put(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
void |
GridLocalAtomicCache.putAll(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pairs in cache.
|
V |
GridLocalAtomicCache.putIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
boolean |
GridLocalAtomicCache.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridLocalAtomicCache.putx(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pair in cache.
|
boolean |
GridLocalAtomicCache.putxIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
V |
GridLocalAtomicCache.remove(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridLocalAtomicCache.remove(K key,
V val)
Removes given key mapping from cache if one exists and value is equal to the passed in value.
|
void |
GridLocalAtomicCache.removeAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter)
Removes given key mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
GridLocalAtomicCache.removeAll(GridPredicate<GridCacheEntry<K,V>>[] filter)
Removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
boolean |
GridLocalAtomicCache.removex(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridCacheReturn<V> |
GridLocalAtomicCache.removex(K key,
V val)
Removes given key mapping from cache if one exists and value is equal to the passed in value.
|
V |
GridLocalAtomicCache.replace(K key,
V val)
Stores given key-value pair in cache only if if there is a previous mapping for it.
|
boolean |
GridLocalAtomicCache.replace(K key,
V oldVal,
V newVal)
Stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
boolean |
GridLocalAtomicCache.replacex(K key,
V val)
Stores given key-value pair in cache only if only if there is a previous mapping for it.
|
GridCacheReturn<V> |
GridLocalAtomicCache.replacex(K key,
V oldVal,
V newVal)
Stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
void |
GridLocalAtomicCache.start()
Starts this cache.
|
void |
GridLocalAtomicCache.transform(K key,
GridClosure<V,V> transformer)
Stores result of applying
valTransform closure to the previous value associated with
given key in cache. |
void |
GridLocalAtomicCache.transformAll(Map<? extends K,? extends GridClosure<V,V>> m)
Stores result of applying transform closures from the given map to previous values associated
with corresponding keys in cache.
|
<R> R |
GridLocalAtomicCache.transformAndCompute(K key,
GridClosure<V,GridBiTuple<V,R>> transformer)
Applies
transformer closure to the previous value associated with given key in cache,
closure should return GridBiTuple instance where first value is new value stored in cache
and second value is returned as result of this method. |
void |
GridLocalAtomicCache.unlockAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter)
Unlocks given keys only if current thread owns the locks.
|
| Modifier and Type | Method and Description |
|---|---|
int |
GridCacheQueryErrorFuture.available()
Returns number of elements that are already fetched and can
be returned from
GridCacheQueryFuture.next() method without blocking. |
boolean |
GridCacheQueryFutureAdapter.cancel()
Default no-op implementation that always returns
false. |
protected void |
GridCacheDistributedQueryFuture.cancelQuery() |
protected void |
GridCacheLocalQueryFuture.cancelQuery() |
protected abstract void |
GridCacheQueryFutureAdapter.cancelQuery() |
void |
GridCacheQueryResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridCacheQueryRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
Collection<R> |
GridCacheQueryFutureAdapter.get()
Synchronously waits for completion of the computation and
returns computation result.
|
Collection<R> |
GridCacheQueryFutureAdapter.get(long timeout,
TimeUnit unit)
Synchronously waits for completion of the computation for
up to the timeout specified and returns computation result.
|
T |
GridCacheQueryErrorFuture.next()
Returns next element from result set.
|
void |
GridCacheQueryResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridCacheQueryRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
boolean |
GridCacheQueryManager.remove(K key,
byte[] keyBytes) |
long |
GridCacheQueryManager.size(Class<?> valType)
Gets number of objects of given type in index.
|
Collection<GridCacheSqlMetadata> |
GridCacheQueriesEx.sqlMetadata()
Gets SQL metadata.
|
Collection<GridCacheSqlMetadata> |
GridCacheQueryManager.sqlMetadata()
Gets SQL metadata.
|
Collection<GridCacheSqlMetadata> |
GridCacheQueriesImpl.sqlMetadata()
Gets SQL metadata.
|
Collection<GridCacheSqlMetadata> |
GridCacheQueriesProxy.sqlMetadata()
Gets SQL metadata.
|
void |
GridCacheQueryManager.start0() |
void |
GridCacheDistributedQueryManager.start0() |
void |
GridCacheLocalQueryManager.start0() |
void |
GridCacheQueryManager.store(K key,
byte[] keyBytes,
V val,
byte[] valBytes,
GridCacheVersion ver,
long expirationTime)
Writes key-value pair to index.
|
void |
GridCacheQueryAdapter.validate() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheContinuousQueryAdapter.close()
Stops continuous query execution.
|
void |
GridCacheContinuousQueryAdapter.execute()
Starts continuous query execution on the whole grid.
|
void |
GridCacheContinuousQueryAdapter.execute(GridProjection prj)
Starts continuous query execution on provided set of nodes.
|
void |
GridCacheContinuousQueryAdapter.execute(GridProjection prj,
boolean internal)
Starts continuous query execution.
|
void |
GridCacheContinuousQueryManager.onEntryUpdate(GridCacheEntryEx<K,V> e,
K key,
V val,
GridCacheValueBytes valBytes,
boolean unwind) |
| Modifier and Type | Method and Description |
|---|---|
Map<? extends GridComputeJob,GridNode> |
GridCacheQueryJdbcTask.map(List<GridNode> subgrid,
byte[] arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends GridComputeJob,GridNode> |
GridCacheQueryJdbcMetadataTask.map(List<GridNode> subgrid,
String cacheName)
This method is called to map or split grid task into multiple grid jobs.
|
byte[] |
GridCacheQueryJdbcMetadataTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
Boolean |
GridCacheQueryJdbcValidationTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
byte[] |
GridCacheQueryJdbcTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
GridComputeJobResultPolicy |
GridCacheQueryJdbcTask.result(GridComputeJobResult res,
List<GridComputeJobResult> rcvd)
Default implementation which will wait for all jobs to complete before
calling
GridComputeTask.reduce(List) method. |
protected Collection<? extends GridComputeJob> |
GridCacheQueryJdbcValidationTask.split(int gridSize,
String cacheName)
This is a simplified version of
GridComputeTask.map(List, Object) method. |
| Modifier and Type | Method and Description |
|---|---|
void |
GridClockSyncProcessor.addAttributes(Map<String,Object> attrs)
Adds attributes from this component to map of all node attributes.
|
static GridClockMessage |
GridClockMessage.fromBytes(byte[] buf,
int off,
int len)
Constructs message from bytes.
|
void |
GridClockSyncProcessor.onKernalStart()
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
void |
GridClockServer.sendPacket(GridClockMessage msg,
InetAddress addr,
int port)
Sends packet to remote node.
|
void |
GridClockSyncProcessor.start()
Starts grid component.
|
void |
GridClockServer.start(GridKernalContext ctx)
Starts server.
|
void |
GridClockSyncProcessor.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridClosureProcessor.start()
Starts grid component.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridContinuousProcessor.addNotification(UUID nodeId,
UUID routineId,
Object obj,
Object orderedTopic) |
void |
GridContinuousHandler.p2pMarshal(GridKernalContext ctx)
Deploys and marshals inner objects (called only if peer deployment is enabled).
|
void |
GridContinuousHandler.p2pUnmarshal(UUID nodeId,
GridKernalContext ctx)
Unmarshals inner objects (called only if peer deployment is enabled).
|
boolean |
GridContinuousHandler.register(UUID nodeId,
UUID routineId,
GridKernalContext ctx)
Registers listener.
|
void |
GridContinuousProcessor.start()
Starts grid component.
|
void |
GridContinuousProcessor.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
GridFuture<?> |
GridDataLoaderImpl.addData(K key,
V val)
Adds data for loading on remote node.
|
GridFuture<?> |
GridDataLoaderImpl.addData(Map.Entry<K,V> entry)
Adds data for loading on remote node.
|
void |
GridDataLoaderImpl.close()
Closes data loader.
|
void |
GridDataLoaderImpl.close(boolean cancel) |
void |
GridDataLoaderImpl.flush()
Loads any remaining data, but doesn't close the loader.
|
void |
GridDataLoaderImpl.isolated(boolean isolated)
Sets flag indicating that this data loader should assume that there are no other concurrent updates to the cache.
|
GridFuture<?> |
GridDataLoaderImpl.removeData(K key)
Adds key for removal on remote node.
|
void |
GridDataLoaderProcessor.start()
Starts grid component.
|
protected static <K,V> void |
GridDataLoadCacheUpdaters.updateAll(GridCacheProjection<K,V> cache,
Collection<K> rmvCol,
Map<K,V> putMap)
Updates cache.
|
| Modifier and Type | Method and Description |
|---|---|
static GridTuple4<GridUuid,String,Integer,Integer> |
GridDrUtils.batchRequestHeader(byte[] data)
Get batch request header.
|
static byte[] |
GridDrUtils.marshal(GridDrExternalBatchRequest req)
Marshal batch request.
|
static byte[] |
GridDrUtils.marshal(GridDrExternalBatchResponse resp)
Marshal batch response.
|
static byte[] |
GridDrUtils.marshal(GridDrExternalHandshakeRequest req)
Marshal handshake request.
|
static byte[] |
GridDrUtils.marshal(GridDrExternalHandshakeResponse resp)
Marshal handshake response.
|
void |
GridDrRawEntry.marshal(GridMarshaller marsh)
Perform internal marshal of this entry before it will be serialized.
|
static Object |
GridDrUtils.unmarshal(byte[] data)
Unmarshal DR message.
|
void |
GridDrRawEntry.unmarshal(GridMarshaller marsh)
Perform internal unmarshal of this entry.
|
void |
GridDrRawEntry.unmarshalKey(GridMarshaller marsh)
Perform internal key unmarshal of this entry.
|
void |
GridDrDataLoadCacheUpdater.update(GridCache<K,V> cache0,
Collection<Map.Entry<K,V>> col)
Updates cache with batch of entries.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridDrExternalBatchRequest.prepare() |
| Modifier and Type | Method and Description |
|---|---|
abstract void |
GridEmailProcessorAdapter.sendNow(String subj,
String body,
boolean html)
Sends given email to all admin emails, if any, in the current thread blocking until it's either
successfully sent or failed.
|
abstract void |
GridEmailProcessorAdapter.sendNow(String subj,
String body,
boolean html,
Collection<String> addrs)
Sends given email in the current thread blocking until it's either successfully sent or failed.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridGgfsHelper.validateCacheConfiguration(GridCacheConfiguration cfg)
Validate cache configuration for GGFS.
|
void |
GridNoopGgfsHelper.validateCacheConfiguration(GridCacheConfiguration cfg)
Validate cache configuration for GGFS.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<GridComputeJobSibling> |
GridJobProcessor.requestJobSiblings(GridComputeTaskSession ses) |
void |
GridJobProcessor.setAttributes(GridJobSessionImpl ses,
Map<?,?> attrs) |
void |
GridJobProcessor.start()
Starts grid component.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridJobMetricsProcessor.start()
Starts grid component.
|
void |
GridJobMetricsProcessor.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridOffHeapProcessor.contains(String spaceName,
int part,
Object key,
byte[] keyBytes)
Checks if offheap space contains value for the given key.
|
byte[] |
GridOffHeapProcessor.get(String spaceName,
int part,
Object key,
byte[] keyBytes)
Gets value bytes from offheap space for the given key.
|
<T> T |
GridOffHeapProcessor.getValue(String spaceName,
int part,
Object key,
byte[] keyBytes,
ClassLoader ldr)
Gets value from offheap space for the given key.
|
void |
GridOffHeapProcessor.put(String spaceName,
int part,
Object key,
byte[] keyBytes,
byte[] valBytes)
Puts the given value to offheap space for the given key.
|
byte[] |
GridOffHeapProcessor.remove(String spaceName,
int part,
Object key,
byte[] keyBytes)
Removes value from offheap space for the given key.
|
boolean |
GridOffHeapProcessor.removex(String spaceName,
int part,
Object key,
byte[] keyBytes)
Removes value from offheap space for the given key.
|
void |
GridOffHeapProcessor.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridPortProcessor.start()
Starts grid component.
|
void |
GridPortProcessor.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridResourceProcessor.cleanup(GridLifecycleBean lifecycleBean)
Cleans up resources from given lifecycle beans.
|
void |
GridResourceProcessor.cleanup(GridSpi spi)
Cleans up resources from given SPI implementation.
|
void |
GridResourceProcessor.cleanupGeneric(Object obj) |
void |
GridResourceProcessor.inject(GridDeployment dep,
Class<?> taskCls,
GridComputeJob job,
GridComputeTaskSession ses,
GridJobContextImpl jobCtx)
Injects held resources into given
job. |
void |
GridResourceProcessor.inject(GridDeployment dep,
Class<?> depCls,
Object target)
Injects resources into generic class.
|
void |
GridResourceProcessor.inject(GridDeployment dep,
GridComputeTask<?,?> task,
GridTaskSessionImpl ses,
GridComputeLoadBalancer balancer,
GridComputeTaskContinuousMapper mapper)
Injects held resources into given grid task.
|
void |
GridResourceProcessor.inject(GridLifecycleBean lifecycleBean)
Injects held resources into given lifecycle bean.
|
void |
GridResourceJobContextInjector.inject(org.gridgain.grid.kernal.processors.resource.GridResourceField field,
Object target,
Class<?> depCls,
GridDeployment dep)
Injects resource into field.
|
void |
GridResourceLoggerInjector.inject(org.gridgain.grid.kernal.processors.resource.GridResourceField field,
Object target,
Class<?> depCls,
GridDeployment dep)
Injects resource into field.
|
void |
GridResourceJobContextInjector.inject(org.gridgain.grid.kernal.processors.resource.GridResourceMethod mtd,
Object target,
Class<?> depCls,
GridDeployment dep)
Injects resource with a setter method.
|
void |
GridResourceLoggerInjector.inject(org.gridgain.grid.kernal.processors.resource.GridResourceMethod mtd,
Object target,
Class<?> depCls,
GridDeployment dep)
Injects resource with a setter method.
|
void |
GridResourceProcessor.inject(GridSpi spi)
Injects held resources into given SPI implementation.
|
void |
GridResourceProcessor.injectBasicResource(Object target,
Class<? extends Annotation> annCls,
Object rsrc)
This method is declared public as it is used from tests as well.
|
void |
GridResourceProcessor.injectBasicResource(Object target,
Class<? extends Annotation> annCls,
Object rsrc,
GridDeployment dep,
Class<?> depCls)
This method is declared public as it is used from tests as well.
|
void |
GridResourceProcessor.injectCacheName(Object obj,
String cacheName)
Injects cache name into given object.
|
void |
GridResourceProcessor.injectGeneric(Object obj) |
void |
GridResourceProcessor.invokeAnnotated(GridDeployment dep,
Object target,
Class<? extends Annotation> annCls) |
void |
GridResourceProcessor.start()
Starts grid component.
|
Object |
GridSpringResourceContext.unwrapTarget(Object target)
Return original object if AOP used with proxy objects.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridRestProcessor.addAttributes(Map<String,Object> attrs)
Adds attributes from this component to map of all node attributes.
|
GridRestResponse |
GridRestProtocolHandler.handle(GridRestRequest req) |
void |
GridRestProcessor.onKernalStart()
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
void |
GridRestProcessor.start()
Starts grid component.
|
void |
GridRestProtocol.start(GridRestProtocolHandler hnd)
Starts protocol.
|
| Modifier and Type | Method and Description |
|---|---|
protected GridCacheProjectionEx<Object,Object> |
GridCacheCommandHandler.localCache(String cacheName)
Used for test purposes.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridRestProtocolAdapter.assertParameter(boolean cond,
String condDesc) |
| Modifier and Type | Method and Description |
|---|---|
GridClientMessage |
GridTcpRestParser.decode(GridNioSession ses,
ByteBuffer buf)
This method is called when input bytes are available on the underlying network connection.
|
Object |
GridTcpRestDirectParser.decode(GridNioSession ses,
ByteBuffer buf)
This method is called when input bytes are available on the underlying network connection.
|
ByteBuffer |
GridTcpRestParser.encode(GridNioSession ses,
Object msg0)
This method is called whenever a message should be sent to the network connection
and network buffer is ready to be filled with bytes.
|
ByteBuffer |
GridTcpRestDirectParser.encode(GridNioSession ses,
Object msg)
This method is called whenever a message should be sent to the network connection
and network buffer is ready to be filled with bytes.
|
protected GridClientMarshaller |
GridTcpRestParser.marshaller(GridNioSession ses)
Returns marshaller from session, if no marshaller found - init it with default.
|
protected GridClientMessage |
GridTcpRestParser.parseClientMessage(GridNioSession ses,
GridTcpRestParser.ParserState state)
Parses
GridClientMessage from raw bytes. |
void |
GridTcpRestProtocol.start(GridRestProtocolHandler hnd)
Starts protocol.
|
| Constructor and Description |
|---|
GridMemcachedMessageWrapper(GridMemcachedMessage msg,
GridMarshaller jdkMarshaller) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridTaskSessionProcessor.start()
Starts session processor.
|
void |
GridTaskSessionProcessor.stop(boolean cancel)
Stops session processor.
|
| Modifier and Type | Method and Description |
|---|---|
Map<Class<?>,Object> |
GridSpringProcessor.loadBeans(URL cfgUrl,
Class<?>... beanClasses)
Loads bean instances that match the given types from given configuration file.
|
GridBiTuple<Collection<GridConfiguration>,? extends GridSpringResourceContext> |
GridSpringProcessor.loadConfigurations(URL cfgUrl,
String... excludedProps)
Loads all grid configurations specified within given configuration file.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridStreamerRouteFailedException
Exception thrown when router did not return route map.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridStreamProcessor.addAttributes(Map<String,Object> attrs)
Adds attributes from this component to map of all node attributes.
|
void |
GridStreamerImpl.addEvent(Object evt,
Object... evts)
Submits group of events for processing.
|
void |
GridStreamerImpl.addEvents(Collection<?> evts)
Submits group of events for processing.
|
void |
GridStreamerImpl.addEventsToStage(String stageName,
Collection<?> evts)
Submits events to streamer.
|
void |
GridStreamerImpl.addEventToStage(String stageName,
Object evt,
Object... evts)
Submits group of events to streamer.
|
void |
GridStreamerContextDelegate.broadcast(GridInClosure<GridStreamerContext> clo)
Queries all streamer nodes deployed within grid.
|
void |
GridStreamerContextImpl.broadcast(GridInClosure<GridStreamerContext> clo)
Queries all streamer nodes deployed within grid.
|
void |
GridStreamerContextDelegate.broadcast(GridInClosure<GridStreamerContext> clo,
Collection<GridNode> nodes)
Queries streamer nodes deployed within grid.
|
void |
GridStreamerContextImpl.broadcast(GridInClosure<GridStreamerContext> clo,
Collection<GridNode> nodes)
Queries streamer nodes deployed within grid.
|
boolean |
GridStreamerStageExecutionFuture.cancel()
Default no-op implementation that always returns
false. |
void |
GridStreamProcessor.onKernalStart()
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
<R> Collection<R> |
GridStreamerContextDelegate.query(GridClosure<GridStreamerContext,R> clo)
Queries all streamer nodes deployed within grid.
|
<R> Collection<R> |
GridStreamerContextImpl.query(GridClosure<GridStreamerContext,R> clo)
Queries all streamer nodes deployed within grid.
|
<R> Collection<R> |
GridStreamerContextDelegate.query(GridClosure<GridStreamerContext,R> clo,
Collection<GridNode> nodes)
Queries streamer nodes deployed within grid.
|
<R> Collection<R> |
GridStreamerContextImpl.query(GridClosure<GridStreamerContext,R> clo,
Collection<GridNode> nodes)
Queries streamer nodes deployed within grid.
|
<R1,R2> R2 |
GridStreamerContextDelegate.reduce(GridClosure<GridStreamerContext,R1> clo,
GridReducer<R1,R2> rdc)
Queries all streamer nodes deployed within grid.
|
<R1,R2> R2 |
GridStreamerContextImpl.reduce(GridClosure<GridStreamerContext,R1> clo,
GridReducer<R1,R2> rdc)
Queries all streamer nodes deployed within grid.
|
<R1,R2> R2 |
GridStreamerContextDelegate.reduce(GridClosure<GridStreamerContext,R1> clo,
GridReducer<R1,R2> rdc,
Collection<GridNode> nodes)
Queries streamer nodes deployed within grid.
|
<R1,R2> R2 |
GridStreamerContextImpl.reduce(GridClosure<GridStreamerContext,R1> clo,
GridReducer<R1,R2> rdc,
Collection<GridNode> nodes)
Queries streamer nodes deployed within grid.
|
Map<String,Collection<?>> |
GridStreamerStageWrapper.run(GridStreamerContext ctx,
Collection<Object> evts)
Stage execution routine.
|
void |
GridStreamerImpl.scheduleExecutions(GridStreamerStageExecutionFuture fut,
Map<UUID,GridStreamerExecutionBatch> execs)
Schedules batch executions either on local or on remote nodes.
|
void |
GridStreamerEx.scheduleExecutions(GridStreamerStageExecutionFuture fut,
Map<UUID,GridStreamerExecutionBatch> execs)
Schedules batch executions either on local or on remote nodes.
|
void |
GridStreamerImpl.start() |
void |
GridStreamProcessor.start()
Starts grid component.
|
void |
GridStreamProcessor.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
Map<? extends GridComputeJob,GridNode> |
GridStreamerReduceTask.map(List<GridNode> subgrid,
Void arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends GridComputeJob,GridNode> |
GridStreamerBroadcastTask.map(List<GridNode> subgrid,
Void arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends GridComputeJob,GridNode> |
GridStreamerQueryTask.map(List<GridNode> subgrid,
Void arg)
This method is called to map or split grid task into multiple grid jobs.
|
R2 |
GridStreamerReduceTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
Void |
GridStreamerBroadcastTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
Collection<R> |
GridStreamerQueryTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
GridComputeJobResultPolicy |
GridStreamerReduceTask.result(GridComputeJobResult res,
List<GridComputeJobResult> rcvd)
Default implementation which will wait for all jobs to complete before
calling
GridComputeTask.reduce(List) method. |
GridComputeJobResultPolicy |
GridStreamerBroadcastTask.result(GridComputeJobResult res,
List<GridComputeJobResult> rcvd)
Default implementation which will wait for all jobs to complete before
calling
GridComputeTask.reduce(List) method. |
GridComputeJobResultPolicy |
GridStreamerQueryTask.result(GridComputeJobResult res,
List<GridComputeJobResult> rcvd)
Default implementation which will wait for all jobs to complete before
calling
GridComputeTask.reduce(List) method. |
| Modifier and Type | Method and Description |
|---|---|
void |
GridTaskProcessor.setAttributes(GridTaskSessionImpl ses,
Map<?,?> attrs) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridTimeoutProcessor.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridVersionProcessor.registerLocal(Class<?> cls,
Class<? extends GridVersionConverter> converterCls,
GridProductVersion fromVer)
Locally registers converter for a class.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridOsVersionProcessor.registerLocal(Class<?> cls,
Class<? extends GridVersionConverter> converterCls,
GridProductVersion fromVer)
Locally registers converter for a class.
|
| Modifier and Type | Method and Description |
|---|---|
Object |
VisorJob.execute()
Executes this job.
|
Map<? extends GridComputeJob,GridNode> |
VisorMultiNodeTask.map(List<GridNode> subgrid,
GridBiTuple<Set<UUID>,A> arg)
This method is called to map or split grid task into multiple grid jobs.
|
R |
VisorOneNodeTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
GridComputeJobResultPolicy |
VisorMultiNodeTask.result(GridComputeJobResult res,
List<GridComputeJobResult> rcvd)
Asynchronous callback invoked every time a result from remote execution is
received.
|
protected abstract R |
VisorJob.run(A arg)
Execution logic of concrete task.
|
| Modifier and Type | Method and Description |
|---|---|
static GridBiTuple<List<Object[]>,Map.Entry<Object,Object>> |
VisorQueryUtils.fetchScanQueryRows(GridCacheQueryFuture<Map.Entry<Object,Object>> fut,
Map.Entry<Object,Object> savedNext,
int pageSize)
Fetch rows from SCAN query future.
|
static GridBiTuple<List<Object[]>,List<?>> |
VisorQueryUtils.fetchSqlQueryRows(GridCacheQueryFuture<List<?>> fut,
List<?> savedNext,
int pageSize)
Collects rows from sql query future, first time creates meta and column names arrays.
|
Iterable<GridBiTuple<UUID,VisorLicense>> |
VisorLicenseCollectTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
Iterable<VisorCacheAggregatedMetrics> |
VisorCacheCollectMetricsTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
Map<UUID,GridBiTuple<Long,Long>> |
VisorGcTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
Iterable<? extends VisorGridEvent> |
VisorEventsCollectTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
Void |
VisorAckTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
| Modifier and Type | Method and Description |
|---|---|
byte[] |
GridAbstractMarshaller.marshal(Object obj)
Marshals object to byte array.
|
byte[] |
GridMarshaller.marshal(Object obj)
Marshals object to byte array.
|
void |
GridMarshaller.marshal(Object obj,
OutputStream out)
Marshals object to the output stream.
|
<T> T |
GridAbstractMarshaller.unmarshal(byte[] arr,
ClassLoader clsLdr)
Unmarshals object from byte array using given class loader.
|
<T> T |
GridMarshaller.unmarshal(byte[] arr,
ClassLoader clsLdr)
Unmarshals object from byte array using given class loader.
|
<T> T |
GridMarshaller.unmarshal(InputStream in,
ClassLoader clsLdr)
Unmarshals object from the output stream using given class loader.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridJdkMarshaller.marshal(Object obj,
OutputStream out)
Marshals object to the output stream.
|
<T> T |
GridJdkMarshaller.unmarshal(InputStream in,
ClassLoader clsLdr)
Unmarshals object from the output stream using given class loader.
|
| Modifier and Type | Method and Description |
|---|---|
byte[] |
GridOptimizedMarshaller.marshal(Object obj)
Marshals object to byte array.
|
void |
GridOptimizedMarshaller.marshal(Object obj,
OutputStream out)
Marshals object to the output stream.
|
void |
GridOptimizedMarshaller.setClassNamesPath(String path)
Specifies a name of the file which lists all class names to be optimized.
|
<T> T |
GridOptimizedMarshaller.unmarshal(byte[] arr,
ClassLoader clsLdr)
Unmarshals object from byte array using given class loader.
|
<T> T |
GridOptimizedMarshaller.unmarshal(InputStream in,
ClassLoader clsLdr)
Unmarshals object from the output stream using given class loader.
|
| Constructor and Description |
|---|
GridOptimizedMarshaller(boolean requireSer,
List<String> clsNames,
String clsNamesPath,
int poolSize)
Initializes marshaller with given serialization flag.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridMessagingListenActor.respond(Object respMsg)
Responds to the original sender node with given message and continues to listen for the new messages.
|
protected void |
GridMessagingListenActor.respond(UUID id,
Object respMsg)
Responds to the provided node with given message and continues to listen for the new messages.
|
void |
GridMessaging.send(Object topic,
Collection<?> msgs)
Sends given messages with specified topic to the nodes in this projection.
|
void |
GridMessaging.send(Object topic,
Object msg)
Sends given message with specified topic to the nodes in this projection.
|
void |
GridMessaging.sendOrdered(Object topic,
Object msg,
long timeout)
Sends given message with specified topic to the nodes in this projection.
|
protected void |
GridMessagingListenActor.stop(Object respMsg)
This method sends the response message to the original sender node and instructs underlying
implementation to stop receiving new messages and unregister the message listener.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridProductLicenseException
This exception is thrown when license violation is detected.
|
| Modifier and Type | Method and Description |
|---|---|
R |
GridSchedulerFuture.get()
Waits for the completion of the next scheduled execution and returns its result.
|
R |
GridSchedulerFuture.get(long timeout)
Waits for the completion of the next scheduled execution for
specified amount of time and returns its result.
|
R |
GridSchedulerFuture.get(long timeout,
TimeUnit unit)
Waits for the completion of the next scheduled execution for
specified amount of time and returns its result.
|
R |
GridSchedulerFuture.last()
Gets result of the last execution of scheduled task, or
null if task has not been executed, or has not
produced a result yet. |
long |
GridSchedulerFuture.nextExecutionTime()
Gets next execution time of scheduled task.
|
long[] |
GridSchedulerFuture.nextExecutionTimes(int cnt,
long start)
Gets an array of the next execution times after passed
start timestamp. |
| Modifier and Type | Method and Description |
|---|---|
GridSecuritySubject |
GridSecurity.authenticatedSubject(UUID subjId)
Gets security subject based on subject ID.
|
Collection<GridSecuritySubject> |
GridSecurity.authenticatedSubjects()
Gets collection of authenticated subjects together with their permissions.
|
GridSecurityCredentials |
GridSecurityCredentialsProvider.credentials()
Gets security credentials.
|
GridSecurityCredentials |
GridSecurityCredentialsBasicProvider.credentials()
Gets security credentials.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridSegmentationResolver.isValidSegment()
Checks whether segment is valid.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridSpiException
Exception thrown by SPI implementations.
|
class |
GridSpiMultiException
Grid SPI exception which may contain more than one failure.
|
| Modifier and Type | Method and Description |
|---|---|
GridSecuritySubject |
GridSpiContext.authenticatedSubject(UUID subjId)
Gets security subject based on subject ID.
|
Collection<GridSecuritySubject> |
GridSpiContext.authenticatedSubjects()
Gets collection of authenticated subjects together with their permissions.
|
void |
GridSpiCloseableIterator.close()
Closes the iterator and frees all the resources held by the iterator.
|
<K,V> V |
GridSpiContext.get(String cacheName,
K key)
Gets object from cache.
|
<K,V> V |
GridSpiContext.put(String cacheName,
K key,
V val,
long ttl)
Puts object in cache.
|
<K,V> V |
GridSpiContext.putIfAbsent(String cacheName,
K key,
V val,
long ttl)
Puts object into cache if there was no previous object associated with
given key.
|
<T> T |
GridSpiContext.readFromOffheap(String spaceName,
int part,
Object key,
byte[] keyBytes,
ClassLoader ldr)
Reads object from off-heap.
|
<T> T |
GridSpiContext.readFromSwap(String spaceName,
GridSwapKey key,
ClassLoader ldr)
Reads object from swap.
|
<K,V> V |
GridSpiContext.remove(String cacheName,
K key)
Removes object from cache.
|
boolean |
GridSpiContext.removeFromOffheap(String spaceName,
int part,
Object key,
byte[] keyBytes)
Removes data from off-heap memory.
|
void |
GridSpiContext.removeFromSwap(String spaceName,
Object key,
ClassLoader ldr)
Removes object from swap.
|
void |
GridSpiContext.writeToOffheap(String spaceName,
int part,
Object key,
byte[] keyBytes,
Object val,
byte[] valBytes,
ClassLoader ldr)
Writes data to off-heap memory.
|
void |
GridSpiContext.writeToSwap(String spaceName,
Object key,
Object val,
ClassLoader ldr)
Writes object to swap.
|
| Modifier and Type | Method and Description |
|---|---|
Map<GridSecurityCredentials,GridSecurityPermissionSet> |
GridAuthenticationAclProvider.acl()
Gets per-user access control map.
|
| Modifier and Type | Method and Description |
|---|---|
protected GridCommunicationClient |
GridTcpCommunicationSpi.createNioClient(GridNode node) |
protected GridCommunicationClient |
GridTcpCommunicationSpi.createShmemClient(GridNode node,
Integer port) |
protected GridCommunicationClient |
GridTcpCommunicationSpi.createTcpClient(GridNode node)
Establish TCP connection to remote node and returns client.
|
| Modifier and Type | Method and Description |
|---|---|
GridSecurityContext |
GridDiscoverySpiNodeAuthenticator.authenticateNode(GridNode node,
GridSecurityCredentials cred)
Security credentials.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridFailoverContext.getBalancedNode(List<GridNode> top)
Gets the next balanced node for failed job.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridLoadBalancingSpi.getBalancedNode(GridComputeTaskSession ses,
List<GridNode> top,
GridComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridAdaptiveLoadBalancingSpi.getBalancedNode(GridComputeTaskSession ses,
List<GridNode> top,
GridComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridRoundRobinLoadBalancingSpi.getBalancedNode(GridComputeTaskSession ses,
List<GridNode> top,
GridComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridStreamer.addEvent(Object evt,
Object... evts)
Submits group of events for processing.
|
void |
GridStreamer.addEvents(Collection<?> evts)
Submits group of events for processing.
|
void |
GridStreamer.addEventsToStage(String stageName,
Collection<?> evts)
Submits events to streamer.
|
void |
GridStreamer.addEventToStage(String stageName,
Object evt,
Object... evts)
Submits group of events to streamer.
|
void |
GridStreamerContext.broadcast(GridInClosure<GridStreamerContext> clo)
Queries all streamer nodes deployed within grid.
|
void |
GridStreamerContext.broadcast(GridInClosure<GridStreamerContext> clo,
Collection<GridNode> nodes)
Queries streamer nodes deployed within grid.
|
void |
GridStreamerWindow.clearEvicted()
Clears all evicted entries.
|
E |
GridStreamerWindow.dequeue()
Dequeues last element from windows.
|
Collection<E> |
GridStreamerWindow.dequeue(int cnt)
Dequeues up to
cnt elements from window. |
Collection<E> |
GridStreamerWindow.dequeueAll()
Dequeues all elements from window.
|
boolean |
GridStreamerWindow.enqueue(E... evts)
Adds events to window.
|
boolean |
GridStreamerWindow.enqueue(E evt)
Adds single event to window.
|
boolean |
GridStreamerWindow.enqueueAll(Collection<E> evts)
Adds all events to window.
|
E |
GridStreamerWindow.pollEvicted()
If window supports eviction, this method will return next evicted element.
|
Collection<E> |
GridStreamerWindow.pollEvicted(int cnt)
If window supports eviction, this method will return up to
cnt evicted elements. |
Collection<E> |
GridStreamerWindow.pollEvictedAll()
If window supports eviction, this method will return all available evicted elements.
|
Collection<E> |
GridStreamerWindow.pollEvictedBatch()
If window supports batch eviction, this method will poll next evicted batch from window.
|
<R> Collection<R> |
GridStreamerContext.query(GridClosure<GridStreamerContext,R> clo)
Queries all streamer nodes deployed within grid.
|
<R> Collection<R> |
GridStreamerContext.query(GridClosure<GridStreamerContext,R> clo,
Collection<GridNode> nodes)
Queries streamer nodes deployed within grid.
|
<R1,R2> R2 |
GridStreamerContext.reduce(GridClosure<GridStreamerContext,R1> clo,
GridReducer<R1,R2> rdc)
Queries all streamer nodes deployed within grid.
|
<R1,R2> R2 |
GridStreamerContext.reduce(GridClosure<GridStreamerContext,R1> clo,
GridReducer<R1,R2> rdc,
Collection<GridNode> nodes)
Queries streamer nodes deployed within grid.
|
Map<String,Collection<?>> |
GridStreamerStage.run(GridStreamerContext ctx,
Collection<IN> evts)
Stage execution routine.
|
| Modifier and Type | Method and Description |
|---|---|
protected abstract void |
GridStreamerIndexProviderAdapter.add(E evt,
K key,
GridStreamerIndexUpdateSync sync)
Add event to the index.
|
void |
GridStreamerIndexProviderAdapter.add(GridStreamerIndexUpdateSync sync,
E evt)
Add event to the index.
|
void |
GridStreamerIndexProvider.add(GridStreamerIndexUpdateSync sync,
E evt)
Adds an event to index.
|
protected void |
GridStreamerIndexProviderAdapter.lockIndexKey(GridStreamerIndexProviderAdapter.IndexKey<V> key,
GridStreamerIndexUpdateSync sync)
Lock updates on particular key.
|
V |
GridStreamerIndexUpdater.onAdded(GridStreamerIndexEntry<E,K,V> entry,
E evt)
Callback invoked whenever an event is being added to the window.
|
protected abstract void |
GridStreamerIndexProviderAdapter.remove(E evt,
K key,
GridStreamerIndexUpdateSync sync)
Remove event from the index.
|
void |
GridStreamerIndexProviderAdapter.remove(GridStreamerIndexUpdateSync sync,
E evt)
Remove event from the index.
|
void |
GridStreamerIndexProvider.remove(GridStreamerIndexUpdateSync sync,
E evt)
Removes an event from index.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridStreamerHashIndexProvider.add(E evt,
K key,
GridStreamerIndexUpdateSync sync)
Add event to the index.
|
protected void |
GridStreamerHashIndexProvider.remove(E evt,
K key,
GridStreamerIndexUpdateSync sync)
Remove event from the index.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridStreamerTreeIndexProvider.add(E evt,
K key,
GridStreamerIndexUpdateSync sync)
Add event to the index.
|
protected void |
GridStreamerTreeIndexProvider.remove(E evt,
K key,
GridStreamerIndexUpdateSync sync)
Remove event from the index.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridStreamerBoundedTimeWindow.checkConfiguration()
Check window configuration.
|
void |
GridStreamerBoundedTimeBatchWindow.checkConfiguration()
Check window configuration.
|
void |
GridStreamerBoundedSizeBatchWindow.checkConfiguration()
Check window configuration.
|
protected abstract void |
GridStreamerWindowAdapter.checkConfiguration()
Check window configuration.
|
void |
GridStreamerWindowAdapter.clearEvicted()
Clears all evicted entries.
|
E |
GridStreamerWindowAdapter.dequeue()
Dequeues last element from windows.
|
Collection<E> |
GridStreamerWindowAdapter.dequeue(int cnt)
Dequeues up to
cnt elements from window. |
Collection<E> |
GridStreamerWindowAdapter.dequeueAll()
Dequeues all elements from window.
|
boolean |
GridStreamerWindowAdapter.enqueue(E... evts)
Adds events to window.
|
boolean |
GridStreamerWindowAdapter.enqueue(E evt)
Adds single event to window.
|
boolean |
GridStreamerWindowAdapter.enqueueAll(Collection<E> evts)
Adds all events to window.
|
E |
GridStreamerWindowAdapter.pollEvicted()
If window supports eviction, this method will return next evicted element.
|
Collection<E> |
GridStreamerWindowAdapter.pollEvicted(int cnt)
If window supports eviction, this method will return up to
cnt evicted elements. |
Collection<E> |
GridStreamerWindowAdapter.pollEvictedAll()
If window supports eviction, this method will return all available evicted elements.
|
Collection<E> |
GridStreamerWindowAdapter.pollEvictedBatch()
If window supports batch eviction, this method will poll next evicted batch from window.
|
void |
GridStreamerWindowAdapter.start()
Starts grid component, called on grid start.
|
protected void |
GridStreamerWindowAdapter.updateIndexes(E evt,
boolean rmv)
Update indexes.
|
| Modifier and Type | Method and Description |
|---|---|
static GridException |
GridUtils.cast(Throwable t)
Casts this throwable as
GridException. |
static GridException |
GridUtils.exceptionWithSuppressed(String msg,
Collection<Throwable> suppressed)
Creates
GridException with the collection of suppressed exceptions. |
| Modifier and Type | Method and Description |
|---|---|
T |
GridCircularBuffer.add(T t,
GridInClosureX<T> c) |
static GridBiTuple<Object,Object> |
GridUtils.addLog4jNoOpLogger()
Adds no-op logger to remove no-appender warning.
|
void |
GridCloseableIteratorAdapter.close()
Closes the iterator and frees all the resources held by the iterator.
|
void |
GridWeakIterator.close()
Closes iterator.
|
void |
GridCloseableIteratorAdapterEx.close()
Closes the iterator and frees all the resources held by the iterator.
|
void |
GridEmptyCloseableIterator.close()
Closes the iterator and frees all the resources held by the iterator.
|
static byte[] |
GridUtils.decodeHex(char[] data)
Converts an array of characters representing hexidecimal values into an
array of bytes of those same values.
|
static <T> T |
GridUtils.field(Class<?> cls,
String fieldName)
Gets field value.
|
Object |
GridReflectionCache.firstFieldValue(Object o)
Gets field value for object.
|
Object |
GridReflectionCache.firstMethodValue(Object o)
Gets method return value for object.
|
static Constructor<?> |
GridUtils.forceEmptyConstructor(Class<?> cls)
Gets empty constructor for class even if the class does not have empty constructor
declared.
|
static <T> T |
GridUtils.forceNewInstance(Class<?> cls)
Creates new instance of a class even if it does not have public constructor.
|
static <T> T |
GridUtils.get(Future<T> fut)
Gets result from the given future with right exception handling.
|
boolean |
GridCloseableIteratorAdapter.hasNextX()
This method is the same as
Iterator.hasNext(), but allows for failure
with exception. |
boolean |
GridCloseableIteratorAdapterEx.hasNextX()
This method is the same as
Iterator.hasNext(), but allows for failure
with exception. |
T |
GridAtomicInitializer.init(Callable<T> c)
Executes initialization operation only once.
|
static <T> T |
GridUtils.invoke(Class<?> cls,
Object obj,
String mtdName,
Class[] paramTypes,
Object... params)
Invokes method.
|
static <T> T |
GridUtils.newInstance(Class<T> cls)
Creates new instance of a class only if it has an empty constructor (can be non-public).
|
T |
GridCloseableIteratorAdapter.nextX()
This method is the same as
Iterator.next(), but allows for failure
with exception. |
T |
GridCloseableIteratorAdapterEx.nextX()
This method is the same as
Iterator.next(), but allows for failure
with exception. |
protected void |
GridCloseableIteratorAdapter.onClose()
Invoked on iterator close.
|
protected void |
GridCloseableIteratorAdapterEx.onClose()
Invoked on iterator close.
|
protected void |
GridSpiCloseableIteratorWrapper.onClose()
Invoked on iterator close.
|
protected abstract boolean |
GridCloseableIteratorAdapter.onHasNext() |
protected abstract boolean |
GridCloseableIteratorAdapterEx.onHasNext() |
protected boolean |
GridSpiCloseableIteratorWrapper.onHasNext() |
protected abstract T |
GridCloseableIteratorAdapter.onNext() |
protected abstract T |
GridCloseableIteratorAdapterEx.onNext() |
protected T |
GridSpiCloseableIteratorWrapper.onNext() |
protected void |
GridCloseableIteratorAdapter.onRemove()
Called on remove from iterator.
|
protected void |
GridCloseableIteratorAdapterEx.onRemove()
Called on remove from iterator.
|
static Calendar |
GridUtils.parseIsoDate(String str) |
static void |
GridUtils.removeLog4jNoOpLogger(GridBiTuple<Object,Object> t)
Removes previously added no-op logger via method
GridUtils.addLog4jNoOpLogger(). |
void |
GridCloseableIteratorAdapter.removeX()
This method is the same as
Iterator.remove(), but allows for failure
with exception. |
void |
GridCloseableIteratorAdapterEx.removeX()
This method is the same as
Iterator.remove(), but allows for failure
with exception. |
static Collection<InetSocketAddress> |
GridUtils.resolveAddresses(GridAddressResolver addrRslvr,
Iterable<String> addrs,
int port)
Resolves all not loopback addresses and collect results.
|
static GridBiTuple<Collection<String>,Collection<String>> |
GridUtils.resolveLocalAddresses(InetAddress locAddr)
Returns host names consistent with
GridUtils.resolveLocalHost(String). |
static File |
GridUtils.resolveWorkDirectory(String path,
boolean delIfExist)
Resolves work directory.
|
static void |
GridUtils.setWorkDirectory(String userWorkDir,
String userGgHome) |
static void |
GridUtils.startLifecycleAware(Iterable<?> objs)
For each object provided by the given
Iterable checks if it implements
GridLifecycleAware interface and executes GridLifecycleAware.start() method. |
static <T> T |
GridUtils.staticField(Class<?> cls,
String fieldName)
Gets static field value.
|
protected static int |
GridUtils.toDigit(char ch,
int index)
Converts a hexadecimal character to an integer.
|
static Collection<InetAddress> |
GridUtils.toInetAddresses(Collection<String> addrs,
Collection<String> hostNames)
Returns tha list of resolved inet addresses.
|
static Collection<InetAddress> |
GridUtils.toInetAddresses(GridNode node)
Returns tha list of resolved inet addresses.
|
static <R> R |
GridUtils.wrapThreadLoader(ClassLoader ldr,
Callable<R> c)
Sets thread context class loader to the given loader, executes the closure, and then
resets thread context class loader to its initial value.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridFutureAdapter.cancel()
Default no-op implementation that always returns
false. |
boolean |
GridEmbeddedFuture.cancel()
Default no-op implementation that always returns
false. |
boolean |
GridFutureAdapterEx.cancel()
Default no-op implementation that always returns
false. |
boolean |
GridCompoundFuture.cancel()
Default no-op implementation that always returns
false. |
R |
GridFutureAdapter.get()
Synchronously waits for completion of the computation and
returns computation result.
|
R |
GridFutureAdapterEx.get()
Synchronously waits for completion of the computation and
returns computation result.
|
T |
GridFinishedFutureEx.get()
Synchronously waits for completion of the computation and
returns computation result.
|
T |
GridFinishedFuture.get()
Synchronously waits for completion of the computation and
returns computation result.
|
R |
GridFutureAdapter.get(long timeout)
Synchronously waits for completion of the computation for
up to the timeout specified and returns computation result.
|
R |
GridFutureAdapterEx.get(long timeout)
Synchronously waits for completion of the computation for
up to the timeout specified and returns computation result.
|
T |
GridFinishedFutureEx.get(long timeout)
Synchronously waits for completion of the computation for
up to the timeout specified and returns computation result.
|
T |
GridFinishedFuture.get(long timeout)
Synchronously waits for completion of the computation for
up to the timeout specified and returns computation result.
|
R |
GridFutureAdapter.get(long timeout,
TimeUnit unit)
Synchronously waits for completion of the computation for
up to the timeout specified and returns computation result.
|
R |
GridFutureAdapterEx.get(long timeout,
TimeUnit unit)
Synchronously waits for completion of the computation for
up to the timeout specified and returns computation result.
|
T |
GridFinishedFutureEx.get(long timeout,
TimeUnit unit)
Synchronously waits for completion of the computation for
up to the timeout specified and returns computation result.
|
T |
GridFinishedFuture.get(long timeout,
TimeUnit unit)
Synchronously waits for completion of the computation for
up to the timeout specified and returns computation result.
|
protected R |
GridFutureAdapter.get0(long nanosTimeout) |
protected R |
GridFutureAdapterEx.get0(long nanosTimeout) |
| Modifier and Type | Method and Description |
|---|---|
GridifyArgument |
GridifyArgumentBuilder.createJobArgument(GridifyRangeArgument arg,
Collection<?> input)
Create
GridifyArgument for job. |
GridifyRangeArgument |
GridifyArgumentBuilder.createTaskArgument(GridifyRangeArgument arg,
Collection<?> input)
Create
GridifyRangeArgument for task. |
Object |
GridifyJobAdapter.execute()
Provides default implementation for execution of grid-enabled methods.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridIpcEndpointBindException
Represents exception occurred during IPC endpoint binding.
|
| Modifier and Type | Method and Description |
|---|---|
GridIpcEndpoint |
GridIpcServerEndpoint.accept()
Accepts client IPC connection.
|
static GridIpcEndpoint |
GridIpcEndpointFactory.connectEndpoint(String endpointAddr,
GridLogger log)
Connects to open server IPC endpoint.
|
InputStream |
GridIpcEndpoint.inputStream()
Gets input stream associated with this IPC endpoint.
|
OutputStream |
GridIpcEndpoint.outputStream()
Gets output stream associated with this IPC endpoint.
|
void |
GridIpcServerEndpoint.start()
Starts configured endpoint implementation.
|
| Modifier and Type | Method and Description |
|---|---|
GridIpcEndpoint |
GridIpcServerTcpEndpoint.accept()
Accepts client IPC connection.
|
InputStream |
GridIpcClientTcpEndpoint.inputStream()
Gets input stream associated with this IPC endpoint.
|
OutputStream |
GridIpcClientTcpEndpoint.outputStream()
Gets output stream associated with this IPC endpoint.
|
void |
GridIpcServerTcpEndpoint.start()
Starts configured endpoint implementation.
|
| Constructor and Description |
|---|
GridIpcClientTcpEndpoint(String host,
int port)
Creates and connects client IPC endpoint.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridIpcOutOfSystemResourcesException
Thrown when IPC runs out of system resources (for example, no more free shared memory is
available in operating system).
|
class |
GridIpcSharedMemoryOperationTimedoutException
Thrown when IPC operation (such as
Object.wait(long))
has timed out. |
| Modifier and Type | Method and Description |
|---|---|
GridIpcEndpoint |
GridIpcSharedMemoryServerEndpoint.accept()
Accepts client IPC connection.
|
static void |
GridIpcSharedMemoryNativeLoader.load() |
int |
GridIpcSharedMemorySpace.read(byte[] buf,
int off,
int len,
long timeout)
Blocks until at least 1 byte is read.
|
int |
GridIpcSharedMemorySpace.read(ByteBuffer buf,
int off,
int len,
long timeout)
Blocks until at least 1 byte is read.
|
void |
GridIpcSharedMemoryServerEndpoint.start()
Starts configured endpoint implementation.
|
int |
GridIpcSharedMemorySpace.unreadCount() |
void |
GridIpcSharedMemorySpace.write(byte[] buf,
int off,
int len,
long timeout) |
void |
GridIpcSharedMemorySpace.write(ByteBuffer buf,
int off,
int len,
long timeout) |
| Constructor and Description |
|---|
GridIpcSharedMemoryClientEndpoint(int port,
GridLogger parent)
Creates and connects client IPC endpoint and starts background checker thread to avoid deadlocks on other party
crash.
|
GridIpcSharedMemoryClientEndpoint(int port,
int timeout,
GridLogger parent)
Creates and connects client IPC endpoint and starts background checker thread to avoid deadlocks on other party
crash.
|
GridIpcSharedMemorySpace(String tokFileName,
int writerPid,
int readerPid,
int size,
boolean reader,
GridLogger parent)
This will allocate system resources for the space.
|
GridIpcSharedMemorySpace(String tokFileName,
int writerPid,
int readerPid,
int size,
boolean reader,
int shmemId,
GridLogger parent)
This should be called in order to attach to already allocated system resources.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridPlainAbsClosure.apply()
Applies this closure.
|
R |
GridPlainOutClosure.apply() |
R |
GridPlainClosure.apply(T arg) |
void |
GridPlainInClosure.apply(T arg) |
R |
GridPlainClosure2.apply(T1 arg1,
T2 arg2) |
abstract T |
GridOutClosureX.applyx()
Out-closure body that can throw
GridException. |
abstract R |
GridReducer2X.applyx()
Reducer body that can throw
GridException. |
abstract R |
GridReducerX.applyx()
Reducer body that can throw
GridException. |
abstract void |
GridAbsClosureX.applyx()
Closure body that can throw
GridException. |
abstract boolean |
GridAbsPredicateX.applyx()
Predicate body that can throw
GridException. |
abstract R |
GridReducer3X.applyx()
Reducer body that can throw
GridException. |
abstract R |
GridClosureX.applyx(E e)
Closure body that can throw
GridException. |
abstract boolean |
GridPredicateX.applyx(E1 e)
Predicate body that can throw
GridException. |
abstract boolean |
GridPredicate2X.applyx(E1 e1,
E2 e2)
Predicate body that can throw
GridException. |
abstract void |
GridInClosure2X.applyx(E1 e1,
E2 e2)
In-closure body that can throw
GridException. |
abstract R |
GridClosure2X.applyx(E1 e1,
E2 e2)
Closure body that can throw
GridException. |
abstract R |
GridClosure3X.applyx(E1 e1,
E2 e2,
E3 e3)
Closure body that can throw
GridException. |
abstract boolean |
GridPredicate3X.applyx(E1 e1,
E2 e2,
E3 e3)
Predicate body that can throw
GridException. |
abstract void |
GridInClosure3X.applyx(E1 e1,
E2 e2,
E3 e3)
In-closure body that can throw
GridException. |
abstract void |
GridInClosureX.applyx(T t)
In-closure body that can throw
GridException. |
static <T> void |
GridFunc.awaitAll(Collection<GridFuture<T>> futs)
Waits until all passed futures will be executed.
|
static <T> void |
GridFunc.awaitAll(GridFuture<T>... futs)
Waits until all passed futures will be executed.
|
static <T> void |
GridFunc.awaitAll(long timeout,
Collection<GridFuture<T>> futs)
Waits until all passed futures will be executed.
|
static <T,R> R |
GridFunc.awaitAll(long timeout,
GridReducer<T,R> rdc,
Collection<GridFuture<T>> futs)
Awaits for all futures to complete and optionally reduces all results into one.
|
void |
GridCloseableIterator.close()
Closes the iterator and frees all the resources held by the iterator.
|
Object |
GridComputeJobWrapper.execute()
Executes this job.
|
R |
GridPlainFuture.get()
Synchronously waits for completion and returns result.
|
R |
GridPlainFutureAdapter.get()
Synchronously waits for completion and returns result.
|
R |
GridPlainFuture.get(long timeout,
TimeUnit unit)
Synchronously waits for completion and returns result.
|
R |
GridPlainFutureAdapter.get(long timeout,
TimeUnit unit)
Synchronously waits for completion and returns result.
|
boolean |
GridIterator.hasNextX()
This method is the same as
Iterator.hasNext(), but allows for failure
with exception. |
boolean |
GridIterableAdapter.hasNextX()
This method is the same as
Iterator.hasNext(), but allows for failure
with exception. |
T |
GridIterator.nextX()
This method is the same as
Iterator.next(), but allows for failure
with exception. |
T |
GridIterableAdapter.nextX()
This method is the same as
Iterator.next(), but allows for failure
with exception. |
void |
GridIterator.removeX()
This method is the same as
Iterator.remove(), but allows for failure
with exception. |
void |
GridIterableAdapter.removeX()
This method is the same as
Iterator.remove(), but allows for failure
with exception. |
| Modifier and Type | Class and Description |
|---|---|
class |
GridNioException
Nio specific exception.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridNioFilterChain.onExceptionCaught(GridNioSession ses,
GridException e)
Starts chain notification from head to tail.
|
void |
GridNioAsyncNotifyFilter.onExceptionCaught(GridNioSession ses,
GridException ex)
Invoked when exception is caught in filter processing.
|
void |
GridConnectionBytesVerifyFilter.onExceptionCaught(GridNioSession ses,
GridException ex)
Invoked when exception is caught in filter processing.
|
void |
GridNioFilter.onExceptionCaught(GridNioSession ses,
GridException ex)
Invoked when exception is caught in filter processing.
|
void |
GridNioCodecFilter.onExceptionCaught(GridNioSession ses,
GridException ex)
Invoked when exception is caught in filter processing.
|
void |
GridNioFilterAdapter.proceedExceptionCaught(GridNioSession ses,
GridException e)
Forwards GridNioException event to the next logical filter in filter chain.
|
void |
GridNioFilter.proceedExceptionCaught(GridNioSession ses,
GridException e)
Forwards GridNioException event to the next logical filter in filter chain.
|
| Modifier and Type | Method and Description |
|---|---|
GridNioServer<T> |
GridNioServer.Builder.build()
Finishes building the instance.
|
boolean |
GridNioFuture.cancel()
Cancels this future.
|
boolean |
GridNioFinishedFuture.cancel()
Cancels this future.
|
boolean |
GridNioFutureImpl.cancel()
Default no-op implementation that always returns
false. |
byte[] |
GridBufferedParser.decode(GridNioSession ses,
ByteBuffer buf)
This method is called when input bytes are available on the underlying network connection.
|
Object |
GridDirectParser.decode(GridNioSession ses,
ByteBuffer buf)
This method is called when input bytes are available on the underlying network connection.
|
Object |
GridNioParser.decode(GridNioSession ses,
ByteBuffer buf)
This method is called when input bytes are available on the underlying network connection.
|
void |
GridCommunicationClient.doHandshake(GridInClosure2X<InputStream,OutputStream> handshakeC)
Executes the given handshake closure on opened client passing underlying IO streams.
|
void |
GridTcpNioCommunicationClient.doHandshake(GridInClosure2X<InputStream,OutputStream> handshakeC)
Executes the given handshake closure on opened client passing underlying IO streams.
|
void |
GridShmemCommunicationClient.doHandshake(GridInClosure2X<InputStream,OutputStream> handshakeC)
Executes the given handshake closure on opened client passing underlying IO streams.
|
void |
GridTcpCommunicationClient.doHandshake(GridInClosure2X<InputStream,OutputStream> handshakeC)
Executes the given handshake closure on opened client passing underlying IO streams.
|
ByteBuffer |
GridBufferedParser.encode(GridNioSession ses,
Object msg)
This method is called whenever a message should be sent to the network connection
and network buffer is ready to be filled with bytes.
|
ByteBuffer |
GridDirectParser.encode(GridNioSession ses,
Object msg)
This method is called whenever a message should be sent to the network connection
and network buffer is ready to be filled with bytes.
|
ByteBuffer |
GridNioParser.encode(GridNioSession ses,
Object msg)
This method is called whenever a message should be sent to the network connection
and network buffer is ready to be filled with bytes.
|
R |
GridNioFuture.get()
Synchronously waits for completion of the operation and
returns operation result.
|
R |
GridNioFinishedFuture.get()
Synchronously waits for completion of the operation and
returns operation result.
|
R |
GridNioFutureImpl.get()
Synchronously waits for completion of the operation and
returns operation result.
|
R |
GridNioFuture.get(long timeout)
Synchronously waits for completion of the operation for
up to the timeout specified and returns operation result.
|
R |
GridNioFinishedFuture.get(long timeout)
Synchronously waits for completion of the operation for
up to the timeout specified and returns operation result.
|
R |
GridNioFutureImpl.get(long timeout)
Synchronously waits for completion of the operation for
up to the timeout specified and returns operation result.
|
R |
GridNioFuture.get(long timeout,
TimeUnit unit)
Synchronously waits for completion of the operation for
up to the timeout specified and returns operation result.
|
R |
GridNioFinishedFuture.get(long timeout,
TimeUnit unit)
Synchronously waits for completion of the operation for
up to the timeout specified and returns operation result.
|
R |
GridNioFutureImpl.get(long timeout,
TimeUnit unit)
Synchronously waits for completion of the operation for
up to the timeout specified and returns operation result.
|
protected R |
GridNioFutureImpl.get0(long nanosTimeout) |
void |
GridNioAsyncNotifyFilter.onExceptionCaught(GridNioSession ses,
GridException ex)
Invoked when exception is caught in filter processing.
|
void |
GridConnectionBytesVerifyFilter.onExceptionCaught(GridNioSession ses,
GridException ex)
Invoked when exception is caught in filter processing.
|
void |
GridNioFilter.onExceptionCaught(GridNioSession ses,
GridException ex)
Invoked when exception is caught in filter processing.
|
void |
GridNioCodecFilter.onExceptionCaught(GridNioSession ses,
GridException ex)
Invoked when exception is caught in filter processing.
|
void |
GridNioFilterChain.onMessageReceived(GridNioSession ses,
Object msg)
Starts chain notification from head to tail.
|
void |
GridNioAsyncNotifyFilter.onMessageReceived(GridNioSession ses,
Object msg)
Invoked when a new messages received.
|
void |
GridConnectionBytesVerifyFilter.onMessageReceived(GridNioSession ses,
Object msg)
Invoked when a new messages received.
|
void |
GridNioFilter.onMessageReceived(GridNioSession ses,
Object msg)
Invoked when a new messages received.
|
void |
GridNioCodecFilter.onMessageReceived(GridNioSession ses,
Object msg)
Invoked when a new messages received.
|
GridNioFuture<?> |
GridNioFilterChain.onPauseReads(GridNioSession ses)
Starts chain notification from tail to head.
|
GridNioFuture<?> |
GridNioFilterAdapter.onPauseReads(GridNioSession ses)
Pauses reads for session.
|
GridNioFuture<?> |
GridNioFilter.onPauseReads(GridNioSession ses)
Pauses reads for session.
|
GridNioFuture<?> |
GridNioFilterChain.onResumeReads(GridNioSession ses)
Starts chain notification from tail to head.
|
GridNioFuture<?> |
GridNioFilterAdapter.onResumeReads(GridNioSession ses)
Resumes reads for session.
|
GridNioFuture<?> |
GridNioFilter.onResumeReads(GridNioSession ses)
Resumes reads for session.
|
GridNioFuture<Boolean> |
GridNioFilterChain.onSessionClose(GridNioSession ses)
Starts chain notification from tail to head.
|
GridNioFuture<Boolean> |
GridNioAsyncNotifyFilter.onSessionClose(GridNioSession ses)
Invoked when a session close request is performed on session.
|
GridNioFuture<Boolean> |
GridConnectionBytesVerifyFilter.onSessionClose(GridNioSession ses)
Invoked when a session close request is performed on session.
|
GridNioFuture<Boolean> |
GridNioFilter.onSessionClose(GridNioSession ses)
Invoked when a session close request is performed on session.
|
GridNioFuture<Boolean> |
GridNioCodecFilter.onSessionClose(GridNioSession ses)
Invoked when a session close request is performed on session.
|
void |
GridNioFilterChain.onSessionClosed(GridNioSession ses)
Starts chain notification from head to tail.
|
void |
GridNioAsyncNotifyFilter.onSessionClosed(GridNioSession ses)
Invoked after session get closed.
|
void |
GridConnectionBytesVerifyFilter.onSessionClosed(GridNioSession ses)
Invoked after session get closed.
|
void |
GridNioFilter.onSessionClosed(GridNioSession ses)
Invoked after session get closed.
|
void |
GridNioCodecFilter.onSessionClosed(GridNioSession ses)
Invoked after session get closed.
|
void |
GridNioFilterChain.onSessionIdleTimeout(GridNioSession ses)
Called when session is idle for longer time that is
allowed by NIO server.
|
void |
GridNioAsyncNotifyFilter.onSessionIdleTimeout(GridNioSession ses)
Called when session is idle for longer time that is
allowed by NIO server.
|
void |
GridConnectionBytesVerifyFilter.onSessionIdleTimeout(GridNioSession ses)
Called when session is idle for longer time that is
allowed by NIO server.
|
void |
GridNioFilter.onSessionIdleTimeout(GridNioSession ses)
Called when session is idle for longer time that is
allowed by NIO server.
|
void |
GridNioCodecFilter.onSessionIdleTimeout(GridNioSession ses)
Called when session is idle for longer time that is
allowed by NIO server.
|
void |
GridNioFilterChain.onSessionOpened(GridNioSession ses)
Starts chain notification from head to tail.
|
void |
GridNioAsyncNotifyFilter.onSessionOpened(GridNioSession ses)
Invoked when a new session was created.
|
void |
GridConnectionBytesVerifyFilter.onSessionOpened(GridNioSession ses)
Invoked when a new session was created.
|
void |
GridNioFilter.onSessionOpened(GridNioSession ses)
Invoked when a new session was created.
|
void |
GridNioCodecFilter.onSessionOpened(GridNioSession ses)
Invoked when a new session was created.
|
GridNioFuture<?> |
GridNioFilterChain.onSessionWrite(GridNioSession ses,
Object msg)
Starts chain notification from tail to head.
|
GridNioFuture<?> |
GridNioAsyncNotifyFilter.onSessionWrite(GridNioSession ses,
Object msg)
Invoked when a write request is performed on a session.
|
GridNioFuture<?> |
GridConnectionBytesVerifyFilter.onSessionWrite(GridNioSession ses,
Object msg)
Invoked when a write request is performed on a session.
|
GridNioFuture<?> |
GridNioFilter.onSessionWrite(GridNioSession ses,
Object msg)
Invoked when a write request is performed on a session.
|
GridNioFuture<?> |
GridNioCodecFilter.onSessionWrite(GridNioSession ses,
Object msg)
Invoked when a write request is performed on a session.
|
void |
GridNioFilterChain.onSessionWriteTimeout(GridNioSession ses)
Called when session has not empty write buffer that has not been fully
flushed during max timeout allowed by NIO server.
|
void |
GridNioAsyncNotifyFilter.onSessionWriteTimeout(GridNioSession ses)
Called when session has not empty write buffer that has not been fully
flushed during max timeout allowed by NIO server.
|
void |
GridConnectionBytesVerifyFilter.onSessionWriteTimeout(GridNioSession ses)
Called when session has not empty write buffer that has not been fully
flushed during max timeout allowed by NIO server.
|
void |
GridNioFilter.onSessionWriteTimeout(GridNioSession ses)
Called when session has not empty write buffer that has not been fully
flushed during max timeout allowed by NIO server.
|
void |
GridNioCodecFilter.onSessionWriteTimeout(GridNioSession ses)
Called when session has not empty write buffer that has not been fully
flushed during max timeout allowed by NIO server.
|
void |
GridNioFilterAdapter.proceedExceptionCaught(GridNioSession ses,
GridException e)
Forwards GridNioException event to the next logical filter in filter chain.
|
void |
GridNioFilter.proceedExceptionCaught(GridNioSession ses,
GridException e)
Forwards GridNioException event to the next logical filter in filter chain.
|
void |
GridNioFilterAdapter.proceedMessageReceived(GridNioSession ses,
Object msg)
Forwards received message to the next logical filter in filter chain.
|
void |
GridNioFilter.proceedMessageReceived(GridNioSession ses,
Object msg)
Forwards received message to the next logical filter in filter chain.
|
GridNioFuture<?> |
GridNioFilterAdapter.proceedPauseReads(GridNioSession ses)
Pauses reads for session.
|
GridNioFuture<?> |
GridNioFilter.proceedPauseReads(GridNioSession ses)
Pauses reads for session.
|
GridNioFuture<?> |
GridNioFilterAdapter.proceedResumeReads(GridNioSession ses)
Resumes reads for session.
|
GridNioFuture<?> |
GridNioFilter.proceedResumeReads(GridNioSession ses)
Resumes reads for session.
|
GridNioFuture<Boolean> |
GridNioFilterAdapter.proceedSessionClose(GridNioSession ses)
Forwards session close request to the next logical filter in filter chain.
|
GridNioFuture<Boolean> |
GridNioFilter.proceedSessionClose(GridNioSession ses)
Forwards session close request to the next logical filter in filter chain.
|
void |
GridNioFilterAdapter.proceedSessionClosed(GridNioSession ses)
Forwards session closed event to the next logical filter in filter chain.
|
void |
GridNioFilter.proceedSessionClosed(GridNioSession ses)
Forwards session closed event to the next logical filter in filter chain.
|
void |
GridNioFilterAdapter.proceedSessionIdleTimeout(GridNioSession ses)
Forwards session idle notification to the next logical filter in filter chain.
|
void |
GridNioFilter.proceedSessionIdleTimeout(GridNioSession ses)
Forwards session idle notification to the next logical filter in filter chain.
|
void |
GridNioFilterAdapter.proceedSessionOpened(GridNioSession ses)
Forwards session opened event to the next logical filter in filter chain.
|
void |
GridNioFilter.proceedSessionOpened(GridNioSession ses)
Forwards session opened event to the next logical filter in filter chain.
|
GridNioFuture<?> |
GridNioFilterAdapter.proceedSessionWrite(GridNioSession ses,
Object msg)
Forwards write request to the next logical filter in filter chain.
|
GridNioFuture<?> |
GridNioFilter.proceedSessionWrite(GridNioSession ses,
Object msg)
Forwards write request to the next logical filter in filter chain.
|
void |
GridNioFilterAdapter.proceedSessionWriteTimeout(GridNioSession ses)
Forwards session write timeout notification to the next logical filter in filter chain.
|
void |
GridNioFilter.proceedSessionWriteTimeout(GridNioSession ses)
Forwards session write timeout notification to the next logical filter in filter chain.
|
byte[] |
GridNioServerBuffer.read(ByteBuffer buf) |
void |
GridCommunicationClient.sendMessage(byte[] data,
int len) |
void |
GridTcpNioCommunicationClient.sendMessage(byte[] data,
int len) |
void |
GridShmemCommunicationClient.sendMessage(byte[] data,
int len) |
void |
GridTcpCommunicationClient.sendMessage(byte[] data,
int len) |
void |
GridCommunicationClient.sendMessage(ByteBuffer data) |
void |
GridTcpNioCommunicationClient.sendMessage(ByteBuffer data) |
void |
GridShmemCommunicationClient.sendMessage(ByteBuffer data) |
void |
GridTcpCommunicationClient.sendMessage(ByteBuffer data) |
void |
GridCommunicationClient.sendMessage(UUID nodeId,
GridTcpCommunicationMessageAdapter msg) |
void |
GridTcpNioCommunicationClient.sendMessage(UUID nodeId,
GridTcpCommunicationMessageAdapter msg) |
void |
GridShmemCommunicationClient.sendMessage(UUID nodeId,
GridTcpCommunicationMessageAdapter msg) |
void |
GridTcpCommunicationClient.sendMessage(UUID nodeId,
GridTcpCommunicationMessageAdapter msg) |
| Constructor and Description |
|---|
GridShmemCommunicationClient(GridNioMetricsListener metricsLsnr,
int port,
long connTimeout,
GridLogger log,
GridNioMessageWriter msgWriter) |
GridTcpCommunicationClient(GridNioMetricsListener metricsLsnr,
GridNioMessageWriter msgWriter,
InetSocketAddress addr,
InetAddress locHost,
long connTimeout,
boolean tcpNoDelay,
int sockRcvBuf,
int sockSndBuf,
int bufSize,
int minBufferedMsgCnt,
double bufSizeRatio) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNioSslFilter.onExceptionCaught(GridNioSession ses,
GridException ex)
Invoked when exception is caught in filter processing.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridNioSslFilter.onExceptionCaught(GridNioSession ses,
GridException ex)
Invoked when exception is caught in filter processing.
|
void |
GridNioSslFilter.onMessageReceived(GridNioSession ses,
Object msg)
Invoked when a new messages received.
|
GridNioFuture<Boolean> |
GridNioSslFilter.onSessionClose(GridNioSession ses)
Invoked when a session close request is performed on session.
|
void |
GridNioSslFilter.onSessionClosed(GridNioSession ses)
Invoked after session get closed.
|
void |
GridNioSslFilter.onSessionIdleTimeout(GridNioSession ses)
Called when session is idle for longer time that is
allowed by NIO server.
|
void |
GridNioSslFilter.onSessionOpened(GridNioSession ses)
Invoked when a new session was created.
|
GridNioFuture<?> |
GridNioSslFilter.onSessionWrite(GridNioSession ses,
Object msg)
Invoked when a write request is performed on a session.
|
void |
GridNioSslFilter.onSessionWriteTimeout(GridNioSession ses)
Called when session has not empty write buffer that has not been fully
flushed during max timeout allowed by NIO server.
|
| Modifier and Type | Method and Description |
|---|---|
static Set<String> |
GridNodeStartUtils.expandHost(String addr)
Parses and expands range of IPs, if needed.
|
static GridBiTuple<Collection<Map<String,Object>>,Map<String,Object>> |
GridNodeStartUtils.parseFile(File file)
Parses INI file.
|
static Map<String,Collection<GridRemoteStartSpecification>> |
GridNodeStartUtils.specifications(Collection<Map<String,Object>> hosts,
Map<String,Object> dflts)
Makes specifications.
|
| Modifier and Type | Method and Description |
|---|---|
static String |
X.resolveGridGainHome()
Tries to resolve GridGain installation home folder.
|
static void |
X.waitAll(Iterable<GridFuture<?>> futs)
Synchronously waits for all futures in the collection.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridWorkerFuture.cancel()
Default no-op implementation that always returns
false. |
void |
GridWorkerPool.execute(GridWorker w)
Schedules runnable task for execution.
|
Copyright © 2014. All rights reserved.