| Modifier and Type | Class and Description |
|---|---|
class |
IgniteAuthenticationException
Exception that represents authentication failure.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
IgfsPerBlockLruEvictionPolicy.exclude(IgfsPath path)
Check whether provided path must be excluded from evictions.
|
| Modifier and Type | Method and Description |
|---|---|
protected <X> X |
CacheJdbcBlobStore.fromBytes(byte[] bytes)
Deserialize object from byte array using marshaller.
|
protected byte[] |
CacheJdbcBlobStore.toBytes(Object obj)
Serialize object to byte array using marshaller.
|
| 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(IgniteCompute compute,
Class<?> cls,
GridifyRangeArgument arg,
GridifyNodeFilter nodeFilter,
int threshold,
int splitSize,
long timeout)
Execute method on grid.
|
protected Object |
GridifySetToValueAbstractAspect.execute(Method mtd,
IgniteCompute compute,
Class<?> cls,
GridifyRangeArgument arg,
GridifyNodeFilter nodeFilter,
int threshold,
int splitSize,
long timeout)
Execute method on grid.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<InetSocketAddress> |
AddressResolver.getExternalAddresses(InetSocketAddress addr)
Maps internal address to a collection of external addresses.
|
| 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.
|
class |
IgniteDeploymentCheckedException
Deployment or re-deployment failed.
|
class |
IgniteFutureCancelledCheckedException
Future computation cannot be retrieved because it was cancelled.
|
class |
IgniteFutureTimeoutCheckedException
Future computation completion is timed out.
|
class |
IgniteInterruptedCheckedException
This exception is used to wrap standard
InterruptedException into IgniteCheckedException. |
| Modifier and Type | Method and Description |
|---|---|
static <R> ComputeTaskInternalFuture<R> |
ComputeTaskInternalFuture.finishedFuture(GridKernalContext ctx,
Class<?> taskCls,
IgniteCheckedException e) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
IgniteInternalFuture.cancel()
Cancels this future.
|
boolean |
ComputeTaskInternalFuture.cancel()
Default no-op implementation that always returns
false. |
<T> T |
IgniteComponentType.create(boolean noOp)
Creates component.
|
<T extends GridComponent> |
IgniteComponentType.create(GridKernalContext ctx,
boolean noOp)
Creates component.
|
<T extends GridComponent> |
IgniteComponentType.createIfInClassPath(GridKernalContext ctx,
boolean mandatory)
Creates component.
|
<T> T |
IgniteComponentType.createOptional()
First tries to find main component class, if it is not found creates no-op implementation.
|
<T> T |
IgniteComponentType.createOptional(GridKernalContext ctx)
First tries to find main component class, if it is not found creates no-op implementation.
|
R |
IgniteInternalFuture.get()
Synchronously waits for completion of the computation and
returns computation result.
|
R |
IgniteInternalFuture.get(long timeout)
Synchronously waits for completion of the computation for
up to the timeout specified and returns computation result.
|
R |
IgniteInternalFuture.get(long timeout,
TimeUnit unit)
Synchronously waits for completion of the computation for
up to the timeout specified and returns computation result.
|
static IgniteBiTuple<IgniteConfiguration,GridSpringResourceContext> |
IgnitionEx.loadConfiguration(String springCfgPath)
Loads first found grid configuration specified within given Spring XML configuration file.
|
static IgniteBiTuple<IgniteConfiguration,GridSpringResourceContext> |
IgnitionEx.loadConfiguration(URL springCfgUrl)
Loads first found grid configuration specified within given Spring XML configuration file.
|
static IgniteBiTuple<Collection<IgniteConfiguration>,? extends GridSpringResourceContext> |
IgnitionEx.loadConfigurations(String springCfgPath)
Loads all grid configurations specified within given Spring XML configuration file.
|
static IgniteBiTuple<Collection<IgniteConfiguration>,? extends GridSpringResourceContext> |
IgnitionEx.loadConfigurations(URL springCfgUrl)
Loads all grid configurations specified within given Spring XML configuration file.
|
static <T> T |
IgnitionEx.loadSpringBean(String springXmlPath,
String beanName)
Loads spring bean by name.
|
static <T> T |
IgnitionEx.loadSpringBean(URL springXmlUrl,
String beanName)
Loads spring bean by name.
|
void |
GridPluginComponent.onKernalStart()
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
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).
|
GridContinuousHandler.RegisterStatus |
GridMessageListenHandler.register(UUID nodeId,
UUID routineId,
GridKernalContext ctx)
Registers listener.
|
boolean |
MarshallerContextAdapter.registerClass(int id,
Class cls)
Registers class with provided type ID.
|
protected boolean |
MarshallerContextImpl.registerClassName(int id,
String clsName)
Registers class name.
|
protected abstract boolean |
MarshallerContextAdapter.registerClassName(int id,
String clsName)
Registers class name.
|
<R> R |
AsyncSupportAdapter.saveOrGet(IgniteInternalFuture<R> fut) |
static Ignite |
IgnitionEx.start()
Starts grid with default configuration.
|
void |
GridPluginComponent.start()
Starts grid component.
|
void |
GridComponent.start()
Starts grid component.
|
static Ignite |
IgnitionEx.start(GridSpringResourceContext springCtx)
Starts grid with default configuration.
|
static Ignite |
IgnitionEx.start(IgniteConfiguration cfg)
Starts grid with given configuration.
|
void |
IgniteKernal.start(IgniteConfiguration cfg,
ExecutorService utilityCachePool,
ExecutorService marshCachePool,
ExecutorService execSvc,
ExecutorService sysExecSvc,
ExecutorService p2pExecSvc,
ExecutorService mgmtExecSvc,
ExecutorService igfsExecSvc,
ExecutorService restExecSvc,
GridAbsClosure errHnd) |
static Ignite |
IgnitionEx.start(IgniteConfiguration cfg,
GridSpringResourceContext springCtx)
Starts grid with given configuration.
|
static Ignite |
IgnitionEx.start(String springCfgPath)
Starts all grids specified within given Spring XML configuration file.
|
static Ignite |
IgnitionEx.start(String springCfgPath,
String gridName)
Starts all grids specified within given Spring XML configuration file.
|
static Ignite |
IgnitionEx.start(String springCfgPath,
String gridName,
GridSpringResourceContext springCtx)
Starts all grids specified within given Spring XML configuration file.
|
static Ignite |
IgnitionEx.start(URL springCfgUrl)
Starts all grids specified within given Spring XML configuration file URL.
|
static Ignite |
IgnitionEx.start(URL springCfgUrl,
String gridName,
GridSpringResourceContext springCtx)
Starts all grids specified within given Spring XML configuration file URL.
|
static Ignite |
IgnitionEx.startWithClosure(String springCfgPath,
String gridName,
IgniteClosure<IgniteConfiguration,IgniteConfiguration> cfgClo)
Start Grid passing a closure which will modify configuration before it is passed to start routine.
|
void |
GridPluginComponent.stop(boolean cancel)
Stops grid component.
|
void |
GridComponent.stop(boolean cancel)
Stops grid component.
|
void |
GridJobSiblingsResponse.unmarshalSiblings(Marshaller marsh) |
| 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.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ClusterGroupEmptyCheckedException
This exception defines illegal call on empty projection.
|
class |
ClusterTopologyCheckedException
This exception is used to indicate error with grid topology (e.g., crashed node, etc.).
|
class |
ClusterTopologyServerNotFoundException
Internal exception that is used to indicate that all server nodes have left the grid.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ComputeTaskCancelledCheckedException
This exception indicates that grid task was cancelled.
|
class |
ComputeTaskTimeoutCheckedException
This exception indicates that task execution timed out.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgfsControlResponse.error(IgniteCheckedException e) |
| Modifier and Type | Method and Description |
|---|---|
void |
IgfsMarshaller.marshall(IgfsMessage msg,
byte[] hdr,
ObjectOutput out) |
void |
IgfsControlResponse.throwError() |
static void |
IgfsControlResponse.throwError(Integer errCode,
String err) |
IgfsMessage |
IgfsMarshaller.unmarshall(IgfsIpcCommand cmd,
byte[] hdr,
ObjectInput in) |
| Modifier and Type | Method and Description |
|---|---|
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.
|
protected void |
GridManagerAdapter.onKernalStart0() |
protected void |
GridManagerAdapter.startSpi()
Starts wrapped SPI.
|
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,
ComputeTaskSessionScope 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(ClusterNode node,
GridTopic topic,
Message msg,
GridIoPolicy plc) |
void |
GridIoManager.send(ClusterNode node,
Object topic,
Message msg,
GridIoPolicy plc) |
void |
GridIoManager.send(Collection<? extends ClusterNode> nodes,
GridTopic topic,
Message msg,
GridIoPolicy plc) |
void |
GridIoManager.send(Collection<? extends ClusterNode> nodes,
Object topic,
Message msg,
GridIoPolicy plc) |
void |
GridIoManager.send(UUID nodeId,
GridTopic topic,
Message msg,
GridIoPolicy plc) |
void |
GridIoManager.send(UUID nodeId,
Object topic,
Message msg,
GridIoPolicy plc) |
void |
GridIoManager.sendOrderedMessage(ClusterNode node,
Object topic,
Message msg,
GridIoPolicy plc,
long timeout,
boolean skipOnTimeout) |
void |
GridIoManager.sendOrderedMessage(Collection<? extends ClusterNode> nodes,
Object topic,
Message msg,
GridIoPolicy plc,
long timeout,
boolean skipOnTimeout) |
void |
GridIoManager.sendOrderedMessage(UUID nodeId,
Object topic,
Message msg,
GridIoPolicy plc,
long timeout,
boolean skipOnTimeout) |
void |
GridIoManager.sendUserMessage(Collection<? extends ClusterNode> nodes,
Object msg)
Sends a peer deployable user message.
|
void |
GridIoManager.sendUserMessage(Collection<? extends ClusterNode> 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 |
GridDeploymentStore.onKernalStart()
Kernal started callback.
|
void |
GridDeploymentPerLoaderStore.onKernalStart()
Kernal started callback.
|
void |
GridDeploymentManager.onKernalStart0() |
void |
GridDeploymentManager.start()
Starts grid component.
|
void |
GridDeploymentPerVersionStore.start()
Starts store.
|
void |
GridDeploymentStore.start()
Starts store.
|
void |
GridDeploymentPerLoaderStore.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.
|
Event |
GridEventStorageManager.waitForEvent(long timeout,
Runnable c,
IgnitePredicate<? super Event> p,
int... types) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridFailoverManager.start()
Starts grid component.
|
void |
GridFailoverManager.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteSpiCloseableIterator<?> |
GridIndexingManager.query(String space,
Collection<Object> params,
IndexingQueryFilter filters) |
void |
GridIndexingManager.remove(String space,
Object key) |
void |
GridIndexingManager.start() |
void |
GridIndexingManager.stop(boolean cancel) |
<K,V> void |
GridIndexingManager.store(String space,
K key,
V val,
long expirationTime)
Writes key-value pair to index.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridLoadBalancerManager.start()
Starts grid component.
|
void |
GridLoadBalancerManager.stop(boolean cancel)
Stops grid component.
|
| 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)
Gets raw iterator over space entries.
|
byte[] |
GridSwapSpaceManager.read(String spaceName,
SwapKey key,
ClassLoader ldr)
Reads value from swap.
|
<T> T |
GridSwapSpaceManager.readValue(String spaceName,
SwapKey key,
ClassLoader ldr)
Reads value from swap.
|
void |
GridSwapSpaceManager.remove(String spaceName,
Object key,
IgniteInClosure<byte[]> c,
ClassLoader ldr)
Removes value from swap.
|
void |
GridSwapSpaceManager.remove(String spaceName,
SwapKey key,
IgniteInClosure<byte[]> c,
ClassLoader ldr)
Removes value from swap.
|
void |
GridSwapSpaceManager.removeAll(String spaceName,
Collection<SwapKey> keys,
IgniteBiInClosure<SwapKey,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.swapKeys(String spaceName,
Set<Integer> parts)
Gets number of swap entries for given partitions.
|
long |
GridSwapSpaceManager.swapSize(String spaceName)
Gets size in bytes for swap space.
|
void |
GridSwapSpaceManager.write(String spaceName,
Object key,
Object val,
ClassLoader ldr)
Writes value to swap.
|
void |
GridSwapSpaceManager.write(String spaceName,
SwapKey key,
byte[] val,
ClassLoader ldr)
Writes value to swap.
|
<K,V> void |
GridSwapSpaceManager.writeAll(String spaceName,
Map<SwapKey,byte[]> batch,
ClassLoader ldr)
Writes batch to swap.
|
| Modifier and Type | Method and Description |
|---|---|
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<ClusterNode,Collection<K>> |
GridAffinityProcessor.mapKeysToNodes(String cacheName,
Collection<? extends K> keys)
Maps keys to nodes for given cache.
|
<K> ClusterNode |
GridAffinityProcessor.mapKeyToNode(String cacheName,
K key)
Maps single key to a node.
|
<K> ClusterNode |
GridAffinityProcessor.mapKeyToNode(String cacheName,
K key,
AffinityTopologyVersion topVer)
Maps single key to a node.
|
<K> List<ClusterNode> |
GridAffinityProcessor.mapKeyToPrimaryAndBackups(String cacheName,
K key)
Map single key to primary and backup nodes.
|
void |
GridAffinityProcessor.start()
Starts grid component.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CacheAtomicUpdateTimeoutCheckedException
Exception thrown when atomic operation timeout occurs.
|
class |
CachePartialUpdateCheckedException
Exception thrown from non-transactional cache in case when update succeeded only partially.
|
class |
CacheStorePartialUpdateException |
class |
GridCacheIndexUpdateException
Exception indicating that index update failed during cache entry update.
|
class |
GridCacheTryPutFailedException
Try put failed exception.
|
| Modifier and Type | Method and Description |
|---|---|
static RuntimeException |
GridCacheUtils.convertToCacheException(IgniteCheckedException e) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheSharedContext.addCacheContext(GridCacheContext cacheCtx)
Adds cache context to shared cache context.
|
void |
GridCacheContext.awaitStarted() |
void |
GridCacheEvictionManager.batchEvict(Collection<?> keys,
GridCacheVersion obsoleteVer) |
static void |
GridCacheUtils.checkAttributeMismatch(IgniteLogger log,
CacheConfiguration locCfg,
CacheConfiguration rmtCfg,
UUID rmtNodeId,
T2<String,String> attr,
boolean fail)
Checks that local and remove configurations have the same value of given attribute.
|
static void |
GridCacheUtils.checkAttributeMismatch(IgniteLogger log,
String cfgName,
UUID rmtNodeId,
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.
|
void |
GridCacheProxyImpl.clear()
Clears cache on all nodes that store it's data.
|
void |
CacheProjection.clear()
Deprecated.
Deprecated in favor of
CacheProjection.clear(long) method. |
void |
GridCacheProjectionImpl.clear()
Clears cache on all nodes that store it's data.
|
void |
GridCacheAdapter.clear()
Clears cache on all nodes that store it's data.
|
boolean |
GridCacheEntryEx.clear(GridCacheVersion ver,
boolean readers,
CacheEntryPredicate[] filter)
Marks entry as obsolete and, if possible or required, removes it
from swap storage.
|
boolean |
GridCacheMapEntry.clear(GridCacheVersion ver,
boolean readers,
CacheEntryPredicate[] filter)
Marks entry as obsolete and, if possible or required, removes it
from swap storage.
|
void |
GridCacheProxyImpl.clear(K key)
Clears key on all nodes that store it's data.
|
void |
CacheProjection.clear(K key)
Clears key on all nodes that store it's data.
|
void |
GridCacheProjectionImpl.clear(K key)
Clears key on all nodes that store it's data.
|
void |
GridCacheAdapter.clear(K key)
Clears key on all nodes that store it's data.
|
void |
GridCacheProxyImpl.clear(long timeout)
Clears cache on all nodes that store it's data.
|
void |
CacheProjection.clear(long timeout)
Clears cache on all nodes that store it's data.
|
void |
GridCacheProjectionImpl.clear(long timeout)
Clears cache on all nodes that store it's data.
|
void |
GridCacheAdapter.clear(long timeout)
Clears cache on all nodes that store it's data.
|
void |
GridCacheProxyImpl.clearAll(Set<K> keys)
Clears keys on all nodes that store it's data.
|
void |
CacheProjection.clearAll(Set<K> keys)
Clears keys on all nodes that store it's data.
|
void |
GridCacheProjectionImpl.clearAll(Set<K> keys)
Clears keys on all nodes that store it's data.
|
void |
GridCacheAdapter.clearAll(Set<K> keys)
Clears keys on all nodes that store it's data.
|
protected void |
GridCacheMapEntry.clearIndex(CacheObject prevVal)
Clears index.
|
void |
GridCacheSwapManager.clearSwap()
Clears swap.
|
<T> T |
GridCacheContext.cloneOnFlag(T obj)
Clones cached object depending on whether or not
CacheFlag.CLONE flag
is set thread locally. |
<T> T |
GridCacheContext.cloneValue(T obj)
Clone cached object.
|
GridCacheVersionConflictContext<K,V> |
GridCacheContext.conflictResolve(GridCacheVersionedEntryEx<K,V> oldEntry,
GridCacheVersionedEntryEx<K,V> newEntry,
boolean atomicVerComp)
Resolve DR conflict.
|
boolean |
GridCacheSwapManager.containsKey(KeyCacheObject key) |
void |
GridCacheSharedContext.endTx(IgniteInternalTx tx) |
boolean |
GridCacheEvictionManager.evict(GridCacheEntryEx entry,
GridCacheVersion obsoleteVer,
boolean explicit,
CacheEntryPredicate[] filter) |
GridCacheBatchSwapEntry |
GridCacheEntryEx.evictInBatchInternal(GridCacheVersion obsoleteVer)
Evicts entry when batch evict is performed.
|
GridCacheBatchSwapEntry |
GridCacheMapEntry.evictInBatchInternal(GridCacheVersion obsoleteVer)
Evicts entry when batch evict is performed.
|
boolean |
GridCacheEntryEx.evictInternal(boolean swap,
GridCacheVersion obsoleteVer,
CacheEntryPredicate[] filter) |
boolean |
GridCacheMapEntry.evictInternal(boolean swap,
GridCacheVersion obsoleteVer,
CacheEntryPredicate[] filter) |
void |
CacheObjectByteArrayImpl.finishUnmarshal(CacheObjectContext ctx,
ClassLoader ldr) |
void |
CacheObjectImpl.finishUnmarshal(CacheObjectContext ctx,
ClassLoader ldr) |
void |
KeyCacheObjectImpl.finishUnmarshal(CacheObjectContext ctx,
ClassLoader ldr) |
void |
CacheObject.finishUnmarshal(CacheObjectContext ctx,
ClassLoader ldr) |
void |
CacheInvokeDirectResult.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEntryPredicate.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEntryPredicateContainsValue.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
GridCacheReturn.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEvictionEntry.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEntrySerializablePredicate.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEntryPredicateAdapter.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
GridCacheEvictionRequest.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridCacheEvictionResponse.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridCacheMessage.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
protected void |
GridCacheMessage.finishUnmarshalCacheObjects(Collection<? extends CacheObject> col,
GridCacheContext ctx,
ClassLoader ldr) |
protected void |
GridCacheMessage.finishUnmarshalCacheObjects(List<? extends CacheObject> col,
GridCacheContext ctx,
ClassLoader ldr) |
void |
GridCacheWriteBehindStore.forceFlush()
Forces all entries collected to be flushed to the underlying store.
|
void |
GridCacheStoreManager.forceFlush() |
CacheObject |
GridCacheContext.fromOffheap(long valPtr,
boolean tmp) |
V |
GridCacheProxyImpl.get(K key)
Retrieves value mapped to the specified key from cache.
|
V |
CacheProjection.get(K key)
Retrieves value mapped to the specified key from cache.
|
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 |
GridCacheAdapter.get(K key,
boolean deserializePortable) |
V |
GridCacheProxyImpl.get(K key,
GridCacheEntryEx entry,
boolean deserializePortable,
CacheEntryPredicate... filter) |
V |
GridCacheProjectionEx.get(K key,
GridCacheEntryEx entry,
boolean deserializePortable,
CacheEntryPredicate... filter) |
V |
GridCacheProjectionImpl.get(K key,
GridCacheEntryEx entry,
boolean deserializePortable,
CacheEntryPredicate... filter) |
V |
GridCacheAdapter.get(K key,
GridCacheEntryEx entry,
boolean deserializePortable,
CacheEntryPredicate... filter) |
Map<K,V> |
GridCacheProxyImpl.getAll(Collection<? extends K> keys)
Retrieves values mapped to the specified keys from cache.
|
Map<K,V> |
CacheProjection.getAll(Collection<? extends K> keys)
Retrieves values mapped to the specified keys from cache.
|
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> |
GridCacheAdapter.getAll(Collection<? extends K> keys,
boolean deserializePortable) |
void |
QueryCursorImpl.getAll(QueryCursorEx.Consumer<T> clo)
Get all values passing them through passed consumer.
|
Map<K,V> |
GridCacheProxyImpl.getAllOutTx(List<K> keys)
Gets values from cache.
|
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.
|
V |
GridCacheProxyImpl.getForcePrimary(K key)
Gets value 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.
|
int |
GridCacheProxyImpl.globalPrimarySize()
Gets the number of all primary entries cached across all nodes (excluding backups).
|
int |
CacheProjection.globalPrimarySize()
Gets the number of all primary entries cached across all nodes (excluding backups).
|
int |
GridCacheProjectionImpl.globalPrimarySize()
Gets the number of all primary entries cached across all nodes (excluding backups).
|
int |
GridCacheAdapter.globalPrimarySize()
Gets the number of all primary entries cached across all nodes (excluding backups).
|
int |
GridCacheProxyImpl.globalSize()
Gets the number of all entries cached across all nodes.
|
int |
CacheProjection.globalSize()
Gets the number of all entries cached across all nodes.
|
int |
GridCacheProjectionImpl.globalSize()
Gets the number of all entries cached across all nodes.
|
int |
GridCacheAdapter.globalSize()
Gets the number of all entries cached across all nodes.
|
boolean |
GridCacheEntryEx.initialValue(CacheObject val,
GridCacheVersion ver,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType)
Sets new value if current version is 0
|
boolean |
GridCacheMapEntry.initialValue(CacheObject val,
GridCacheVersion ver,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType)
Sets new value if current version is 0
|
boolean |
GridCacheEntryEx.initialValue(KeyCacheObject key,
GridCacheSwapEntry unswapped)
Sets new value if current version is 0 using swap entry data.
|
boolean |
GridCacheMapEntry.initialValue(KeyCacheObject key,
GridCacheSwapEntry unswapped)
Sets new value if current version is 0 using swap entry data.
|
CacheObject |
GridCacheEntryEx.innerGet(IgniteInternalTx tx,
boolean readSwap,
boolean readThrough,
boolean failFast,
boolean unmarshal,
boolean updateMetrics,
boolean evt,
boolean tmp,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expiryPlc) |
CacheObject |
GridCacheMapEntry.innerGet(IgniteInternalTx tx,
boolean readSwap,
boolean readThrough,
boolean failFast,
boolean unmarshal,
boolean updateMetrics,
boolean evt,
boolean tmp,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expirePlc) |
CacheObject |
GridCacheEntryEx.innerReload()
Reloads entry from underlying storage.
|
CacheObject |
GridCacheMapEntry.innerReload()
Reloads entry from underlying storage.
|
GridCacheUpdateTxResult |
GridCacheEntryEx.innerRemove(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
boolean writeThrough,
boolean retval,
boolean evt,
boolean metrics,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId,
String taskName) |
GridCacheUpdateTxResult |
GridCacheMapEntry.innerRemove(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
boolean writeThrough,
boolean retval,
boolean evt,
boolean metrics,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId,
String taskName) |
GridCacheUpdateTxResult |
GridCacheEntryEx.innerSet(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId,
String taskName) |
GridCacheUpdateTxResult |
GridCacheMapEntry.innerSet(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId,
String taskName) |
GridCacheUpdateAtomicResult |
GridCacheEntryEx.innerUpdate(GridCacheVersion ver,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object val,
Object[] invokeArgs,
boolean writeThrough,
boolean retval,
IgniteCacheExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
boolean primary,
boolean checkVer,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long conflictTtl,
long conflictExpireTime,
GridCacheVersion conflictVer,
boolean conflictResolve,
boolean intercept,
UUID subjId,
String taskName) |
GridCacheUpdateAtomicResult |
GridCacheMapEntry.innerUpdate(GridCacheVersion newVer,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object writeObj,
Object[] invokeArgs,
boolean writeThrough,
boolean retval,
IgniteCacheExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
boolean primary,
boolean verCheck,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long explicitTtl,
long explicitExpireTime,
GridCacheVersion conflictVer,
boolean conflictResolve,
boolean intercept,
UUID subjId,
String taskName) |
GridTuple3<Boolean,Object,javax.cache.processor.EntryProcessorResult<Object>> |
GridCacheEntryEx.innerUpdateLocal(GridCacheVersion ver,
GridCacheOperation op,
Object writeObj,
Object[] invokeArgs,
boolean writeThrough,
boolean retval,
javax.cache.expiry.ExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
CacheEntryPredicate[] filter,
boolean intercept,
UUID subjId,
String taskName)
Update method for local cache in atomic mode.
|
GridTuple3<Boolean,Object,javax.cache.processor.EntryProcessorResult<Object>> |
GridCacheMapEntry.innerUpdateLocal(GridCacheVersion ver,
GridCacheOperation op,
Object writeObj,
Object[] invokeArgs,
boolean writeThrough,
boolean retval,
javax.cache.expiry.ExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
CacheEntryPredicate[] filter,
boolean intercept,
UUID subjId,
String taskName)
Update method for local cache in atomic mode.
|
static <K,V> void |
GridCacheUtils.inTx(CacheProjection<K,V> cache,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
IgniteInClosureX<CacheProjection<K,V>> clo)
Execute closure inside cache transaction.
|
static <K,V> void |
GridCacheUtils.inTx(Ignite ignite,
IgniteCache<K,V> cache,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
IgniteInClosureX<IgniteCache<K,V>> clo)
Execute closure inside cache transaction.
|
boolean |
GridCacheEntryEx.invalidate(CacheEntryPredicate[] filter)
Invalidates this entry if it passes given filter.
|
boolean |
GridCacheMapEntry.invalidate(CacheEntryPredicate[] filter)
Invalidates this entry if it passes given filter.
|
boolean |
GridCacheEntryEx.invalidate(GridCacheVersion curVer,
GridCacheVersion newVer)
Invalidates this entry.
|
boolean |
GridCacheMapEntry.invalidate(GridCacheVersion curVer,
GridCacheVersion newVer)
Invalidates this entry.
|
<T> javax.cache.processor.EntryProcessorResult<T> |
GridCacheProxyImpl.invoke(K key,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> javax.cache.processor.EntryProcessorResult<T> |
GridCacheProjectionEx.invoke(K key,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> javax.cache.processor.EntryProcessorResult<T> |
GridCacheProjectionImpl.invoke(K key,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> javax.cache.processor.EntryProcessorResult<T> |
GridCacheAdapter.invoke(K key,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>> |
GridCacheProxyImpl.invokeAll(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map,
Object... args) |
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>> |
GridCacheProjectionEx.invokeAll(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map,
Object... args) |
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>> |
GridCacheProjectionImpl.invokeAll(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map,
Object... args) |
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>> |
GridCacheAdapter.invokeAll(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map,
Object... args) |
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>> |
GridCacheProxyImpl.invokeAll(Set<? extends K> keys,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>> |
GridCacheProjectionEx.invokeAll(Set<? extends K> keys,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>> |
GridCacheProjectionImpl.invokeAll(Set<? extends K> keys,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>> |
GridCacheAdapter.invokeAll(Set<? extends K> keys,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<E> boolean |
GridCacheContext.isAll(E e,
IgnitePredicate<? super E>[] p)
Same as
GridFunc.isAll(Object, IgnitePredicate[]), but safely unwraps exceptions. |
boolean |
GridCacheContext.isAll(GridCacheEntryEx e,
CacheEntryPredicate[] p) |
<K1,V1> boolean |
GridCacheContext.isAll(GridCacheEntryEx e,
IgnitePredicate<javax.cache.Cache.Entry<K1,V1>>[] p)
Same as
GridFunc.isAll(Object, IgnitePredicate[]), but safely unwraps exceptions. |
boolean |
GridCacheContext.isAllLocked(GridCacheEntryEx e,
CacheEntryPredicate[] p) |
GridCloseableIterator<Map.Entry<byte[],GridCacheSwapEntry>> |
GridCacheSwapManager.iterator(int part)
Gets offheap and swap iterator over partition.
|
<K,V> Iterator<Map.Entry<K,V>> |
GridCacheSwapManager.lazySwapIterator() |
boolean |
GridCacheStoreManager.loadAllFromStore(IgniteInternalTx tx,
Collection<? extends KeyCacheObject> keys,
IgniteBiInClosure<KeyCacheObject,Object> vis)
Loads data from persistent store.
|
boolean |
GridCacheStoreManager.loadCache(GridInClosure3<KeyCacheObject,Object,GridCacheVersion> vis,
Object[] args)
Loads data from persistent store.
|
Object |
GridCacheStoreManager.loadFromStore(IgniteInternalTx tx,
KeyCacheObject key)
Loads data from persistent store.
|
Iterable<javax.cache.Cache.Entry<K,V>> |
GridCacheProxyImpl.localEntries(CachePeekMode[] peekModes) |
Iterable<javax.cache.Cache.Entry<K,V>> |
CacheProjection.localEntries(CachePeekMode[] peekModes) |
Iterable<javax.cache.Cache.Entry<K,V>> |
GridCacheProjectionImpl.localEntries(CachePeekMode[] peekModes) |
Iterable<javax.cache.Cache.Entry<K,V>> |
GridCacheAdapter.localEntries(CachePeekMode[] peekModes) |
void |
GridCacheAdapter.localLoad(Collection<? extends K> keys,
javax.cache.expiry.ExpiryPolicy plc) |
void |
GridCacheProjectionEx.localLoadCache(IgniteBiPredicate<K,V> p,
Object... args)
Delegates to
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure,Object...) method
to load state from the underlying persistent storage. |
void |
GridCacheProjectionImpl.localLoadCache(IgniteBiPredicate<K,V> p,
Object... args)
Delegates to
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure,Object...) method
to load state from the underlying persistent storage. |
void |
GridCacheProxyImpl.localLoadCache(IgniteBiPredicate<K,V> p,
Object[] args)
Delegates to
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure,Object...) method
to load state from the underlying persistent storage. |
void |
GridCacheAdapter.localLoadCache(IgniteBiPredicate<K,V> p,
Object[] args)
Delegates to
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure,Object...) method
to load state from the underlying persistent storage. |
V |
GridCacheProxyImpl.localPeek(K key,
CachePeekMode[] peekModes,
IgniteCacheExpiryPolicy plc) |
V |
CacheProjection.localPeek(K key,
CachePeekMode[] peekModes,
IgniteCacheExpiryPolicy plc) |
V |
GridCacheProjectionImpl.localPeek(K key,
CachePeekMode[] peekModes,
IgniteCacheExpiryPolicy plc) |
V |
GridCacheAdapter.localPeek(K key,
CachePeekMode[] peekModes,
IgniteCacheExpiryPolicy plc) |
void |
GridCacheProxyImpl.localRemoveAll() |
void |
CacheProjection.localRemoveAll() |
void |
GridCacheProjectionImpl.localRemoveAll() |
void |
GridCacheAdapter.localRemoveAll() |
int |
GridCacheProxyImpl.localSize(CachePeekMode[] peekModes) |
int |
CacheProjection.localSize(CachePeekMode[] peekModes) |
int |
GridCacheProjectionImpl.localSize(CachePeekMode[] peekModes) |
int |
GridCacheAdapter.localSize(CachePeekMode[] peekModes) |
void |
GridCacheStoreManager.localStoreLoadAll(IgniteInternalTx tx,
Collection<? extends KeyCacheObject> keys,
GridInClosure3<KeyCacheObject,Object,GridCacheVersion> vis) |
boolean |
CacheProjection.lock(K key,
long timeout,
CacheEntryPredicate... filter)
Synchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
boolean |
GridCacheProjectionImpl.lock(K key,
long timeout,
CacheEntryPredicate... 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,
CacheEntryPredicate... 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,
CacheEntryPredicate[] filter)
Synchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
boolean |
CacheProjection.lockAll(Collection<? extends K> keys,
long timeout,
CacheEntryPredicate... filter)
All or nothing synchronous lock for passed in keys.
|
boolean |
GridCacheAdapter.lockAll(Collection<? extends K> keys,
long timeout,
CacheEntryPredicate... filter)
All or nothing synchronous lock for passed in keys.
|
boolean |
GridCacheProxyImpl.lockAll(Collection<? extends K> keys,
long timeout,
CacheEntryPredicate[] filter)
All or nothing synchronous lock for passed in keys.
|
boolean |
GridCacheProjectionImpl.lockAll(Collection<? extends K> keys,
long timeout,
CacheEntryPredicate[] filter)
All or nothing synchronous lock for passed in keys.
|
boolean |
GridCacheEntryEx.markObsoleteIfEmpty(GridCacheVersion ver)
Sets obsolete flag if entry value is
null or entry is expired and no
locks are held. |
boolean |
GridCacheMapEntry.markObsoleteIfEmpty(GridCacheVersion ver)
Sets obsolete flag if entry value is
null or entry is expired and no
locks are held. |
void |
GridCacheEntryInfo.marshal(GridCacheContext ctx) |
static byte[] |
GridCacheUtils.marshal(GridCacheSharedContext ctx,
Object obj) |
protected LinkedHashMap<byte[],Boolean> |
GridCacheMessage.marshalBooleanLinkedMap(LinkedHashMap<?,Boolean> map,
GridCacheSharedContext ctx) |
protected List<byte[]> |
GridCacheMessage.marshalCollection(Collection<?> col,
GridCacheSharedContext ctx) |
protected void |
GridCacheMessage.marshalInfo(GridCacheEntryInfo info,
GridCacheContext ctx) |
protected void |
GridCacheMessage.marshalInfos(Iterable<? extends GridCacheEntryInfo> infos,
GridCacheContext ctx) |
protected byte[][] |
GridCacheMessage.marshalInvokeArguments(Object[] args,
GridCacheSharedContext ctx) |
int |
GridCacheEntryInfo.marshalledSize(GridCacheContext ctx) |
protected void |
GridCacheMessage.marshalTx(Iterable<IgniteTxEntry> txEntries,
GridCacheSharedContext ctx) |
int |
GridCacheEntryEx.memorySize() |
int |
GridCacheMapEntry.memorySize() |
int |
GridCacheSwapManager.offheapEntriesCount(boolean primary,
boolean backup,
AffinityTopologyVersion topVer) |
Iterator<Map.Entry<K,V>> |
GridCacheProxyImpl.offHeapIterator()
Gets iterator over keys and values belonging to this cache off-heap memory on local node.
|
Iterator<Map.Entry<K,V>> |
GridCache.offHeapIterator()
Gets iterator over keys and values belonging to this cache off-heap memory on local node.
|
Iterator<Map.Entry<K,V>> |
GridCacheAdapter.offHeapIterator()
Gets iterator over keys and values belonging to this cache off-heap memory on local node.
|
<K,V> Iterator<javax.cache.Cache.Entry<K,V>> |
GridCacheSwapManager.offheapIterator(boolean primary,
boolean backup,
AffinityTopologyVersion topVer) |
GridCloseableIterator<Map.Entry<byte[],GridCacheSwapEntry>> |
GridCacheSwapManager.offHeapIterator(int part)
Gets offheap iterator over partition.
|
protected void |
CacheWeakQueryIteratorsHolder.WeakQueryFutureIterator.onClose()
Invoked on iterator close.
|
void |
GridCacheSwapListener.onEntryUnswapped(int part,
KeyCacheObject key,
GridCacheSwapEntry e) |
boolean |
CacheWeakQueryIteratorsHolder.WeakQueryFutureIterator.onHasNext() |
void |
GridCacheManager.onKernalStart() |
void |
GridCacheProcessor.onKernalStart()
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
void |
GridCachePreloaderAdapter.onKernalStart()
Kernal start callback.
|
void |
GridCacheSharedManagerAdapter.onKernalStart() |
void |
GridCachePreloader.onKernalStart()
Kernal start callback.
|
void |
GridCacheManagerAdapter.onKernalStart() |
void |
GridCacheSharedManager.onKernalStart() |
protected void |
GridCacheAdapter.onKernalStart()
Kernal start callback.
|
protected void |
GridCacheSharedManagerAdapter.onKernalStart0() |
protected void |
GridCachePartitionExchangeManager.onKernalStart0() |
void |
GridCacheMvccManager.onKernalStart0() |
protected void |
GridCacheManagerAdapter.onKernalStart0() |
protected void |
GridCacheTtlManager.onKernalStart0() |
protected void |
GridCacheAffinityManager.onKernalStart0() |
protected void |
GridCacheEvictionManager.onKernalStart0() |
T |
CacheWeakQueryIteratorsHolder.WeakQueryFutureIterator.onNext() |
protected void |
CacheWeakQueryIteratorsHolder.WeakQueryFutureIterator.onRemove()
Called on remove from iterator.
|
static <T> T |
GridCacheUtils.outTx(Callable<T> cmd,
GridCacheContext ctx)
Method executes any Callable out of scope of transaction.
|
long |
GridCacheProxyImpl.overflowSize()
Gets size (in bytes) of all entries swapped to disk.
|
long |
GridCache.overflowSize()
Gets size (in bytes) of all entries swapped to disk.
|
long |
GridCacheAdapter.overflowSize()
Gets size (in bytes) of all entries swapped to disk.
|
CacheObject |
GridCacheEntryEx.peek(boolean heap,
boolean offheap,
boolean swap,
AffinityTopologyVersion topVer,
IgniteCacheExpiryPolicy plc)
Peeks into entry without loading value or updating statistics.
|
CacheObject |
GridCacheMapEntry.peek(boolean heap,
boolean offheap,
boolean swap,
AffinityTopologyVersion topVer,
IgniteCacheExpiryPolicy expiryPlc)
Peeks into entry without loading value or updating statistics.
|
V |
GridCacheProxyImpl.peek(K key,
Collection<GridCachePeekMode> modes)
Peeks at cached value using optional set of peek modes.
|
V |
CacheProjection.peek(K key,
Collection<GridCachePeekMode> modes)
Peeks at cached value using optional set of peek modes.
|
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.
|
GridTuple<CacheObject> |
GridCacheEntryEx.peek0(boolean failFast,
GridCachePeekMode mode,
CacheEntryPredicate[] filter,
IgniteInternalTx tx) |
GridTuple<CacheObject> |
GridCacheMapEntry.peek0(boolean failFast,
GridCachePeekMode mode,
CacheEntryPredicate[] filter,
IgniteInternalTx tx) |
protected GridTuple<V> |
GridCacheAdapter.peek0(boolean failFast,
K key,
Collection<GridCachePeekMode> modes,
IgniteInternalTx tx) |
protected V |
GridCacheAdapter.peek0(K key,
Collection<GridCachePeekMode> modes,
IgniteInternalTx tx) |
protected Map<K,V> |
GridCacheAdapter.peekAll0(Collection<? extends K> keys,
Collection<GridCachePeekMode> modes,
IgniteInternalTx tx,
Collection<K> skipped) |
CacheObject |
GridCacheEntryEx.poke(CacheObject val)
This method overwrites current in-memory value with new value.
|
CacheObject |
GridCacheMapEntry.poke(CacheObject val)
This method overwrites current in-memory value with new value.
|
void |
GridCacheProcessor.prepareCachesStart(Collection<DynamicCacheChangeRequest> reqs,
AffinityTopologyVersion topVer) |
void |
CacheObjectByteArrayImpl.prepareMarshal(CacheObjectContext ctx) |
void |
CacheObjectImpl.prepareMarshal(CacheObjectContext ctx) |
void |
KeyCacheObjectImpl.prepareMarshal(CacheObjectContext ctx) |
void |
CacheObject.prepareMarshal(CacheObjectContext ctx) |
void |
CacheInvokeDirectResult.prepareMarshal(GridCacheContext ctx) |
void |
CacheEntryPredicate.prepareMarshal(GridCacheContext ctx) |
void |
CacheEntryPredicateContainsValue.prepareMarshal(GridCacheContext ctx) |
void |
GridCacheReturn.prepareMarshal(GridCacheContext ctx) |
void |
CacheEvictionEntry.prepareMarshal(GridCacheContext ctx) |
void |
CacheEntrySerializablePredicate.prepareMarshal(GridCacheContext ctx) |
void |
CacheEntryPredicateAdapter.prepareMarshal(GridCacheContext ctx) |
void |
GridCacheEvictionRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridCacheEvictionResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridCacheMessage.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
protected void |
GridCacheMessage.prepareMarshalCacheObjects(Collection<? extends CacheObject> col,
GridCacheContext ctx) |
protected void |
GridCacheMessage.prepareMarshalCacheObjects(List<? extends CacheObject> col,
GridCacheContext ctx) |
protected void |
GridCacheMessage.prepareObject(Object o,
GridCacheSharedContext ctx) |
V |
GridCacheProxyImpl.promote(K key)
This method promotes cache entry by given key, if any, from offheap or swap storage
into memory.
|
V |
CacheProjection.promote(K key)
This method promotes cache entry by given key, if any, from offheap or swap storage
into memory.
|
V |
GridCacheProjectionImpl.promote(K key)
This method promotes cache entry by given key, if any, from offheap or swap storage
into memory.
|
V |
GridCacheAdapter.promote(K key)
This method promotes cache entry by given key, if any, from offheap or swap storage
into memory.
|
V |
GridCacheAdapter.promote(K key,
boolean deserializePortable) |
void |
GridCacheProxyImpl.promoteAll(Collection<? extends K> keys)
This method unswaps cache entries by given keys, if any, from swap storage
into memory.
|
void |
CacheProjection.promoteAll(Collection<? extends K> keys)
This method unswaps cache entries by given keys, if any, from 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.
|
V |
CacheProjection.put(K key,
V val,
CacheEntryPredicate... filter)
Stores given key-value pair in cache.
|
V |
GridCacheAdapter.put(K key,
V val,
CacheEntryPredicate... filter)
Stores given key-value pair in cache.
|
V |
GridCacheProxyImpl.put(K key,
V val,
CacheEntryPredicate[] filter)
Stores given key-value pair in cache.
|
V |
GridCacheProjectionImpl.put(K key,
V val,
CacheEntryPredicate[] filter)
Stores given key-value pair in cache.
|
V |
GridCacheProxyImpl.put(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
CacheEntryImpl. |
V |
GridCacheProjectionEx.put(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
CacheEntryImpl. |
V |
GridCacheProjectionImpl.put(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
CacheEntryImpl. |
V |
GridCacheAdapter.put(K key,
V val,
GridCacheEntryEx cached,
long ttl,
CacheEntryPredicate[] filter)
Internal method that is called from
CacheEntryImpl. |
void |
CacheProjection.putAll(Map<? extends K,? extends V> m,
CacheEntryPredicate... filter)
Stores given key-value pairs in cache.
|
void |
GridCacheProxyImpl.putAll(Map<? extends K,? extends V> m,
CacheEntryPredicate[] filter)
Stores given key-value pairs in cache.
|
void |
GridCacheProjectionImpl.putAll(Map<? extends K,? extends V> m,
CacheEntryPredicate[] filter)
Stores given key-value pairs in cache.
|
void |
GridCacheAdapter.putAll(Map<? extends K,? extends V> m,
CacheEntryPredicate[] filter)
Stores given key-value pairs in cache.
|
void |
GridCacheProxyImpl.putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data.
|
void |
GridCacheProjectionEx.putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data.
|
void |
GridCacheProjectionImpl.putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data.
|
void |
GridCacheAdapter.putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data.
|
IgniteInternalFuture<?> |
GridCacheProxyImpl.putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data asynchronously.
|
IgniteInternalFuture<?> |
GridCacheProjectionEx.putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data asynchronously.
|
IgniteInternalFuture<?> |
GridCacheProjectionImpl.putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data asynchronously.
|
IgniteInternalFuture<?> |
GridCacheAdapter.putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data asynchronously.
|
boolean |
GridCacheStoreManager.putAllToStore(IgniteInternalTx tx,
Map<Object,IgniteBiTuple<Object,GridCacheVersion>> map)
Puts key-value pair into storage.
|
V |
GridCacheProxyImpl.putIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
V |
CacheProjection.putIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
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.
|
boolean |
GridCacheStoreManager.putToStore(IgniteInternalTx tx,
Object key,
Object val,
GridCacheVersion ver)
Puts key-value pair into storage.
|
boolean |
CacheProjection.putx(K key,
V val,
CacheEntryPredicate... filter)
Stores given key-value pair in cache.
|
boolean |
GridCacheProxyImpl.putx(K key,
V val,
CacheEntryPredicate[] filter)
Stores given key-value pair in cache.
|
boolean |
GridCacheProjectionImpl.putx(K key,
V val,
CacheEntryPredicate[] filter)
Stores given key-value pair in cache.
|
boolean |
GridCacheAdapter.putx(K key,
V val,
CacheEntryPredicate[] filter)
Stores given key-value pair in cache.
|
boolean |
GridCacheProxyImpl.putx(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
CacheEntryImpl. |
boolean |
GridCacheProjectionEx.putx(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
CacheEntryImpl. |
boolean |
GridCacheProjectionImpl.putx(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
CacheEntryImpl. |
boolean |
GridCacheAdapter.putx(K key,
V val,
GridCacheEntryEx cached,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
CacheEntryImpl. |
boolean |
GridCacheProxyImpl.putxIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
boolean |
CacheProjection.putxIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
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.
|
CacheObject |
GridCacheEntryEx.rawGetOrUnmarshal(boolean tmp) |
CacheObject |
GridCacheMapEntry.rawGetOrUnmarshal(boolean tmp) |
CacheObject |
GridCacheMapEntry.rawGetOrUnmarshalUnlocked(boolean tmp) |
GridCloseableIterator<Map.Entry<byte[],byte[]>> |
GridCacheSwapManager.rawIterator()
Gets offheap and swap iterator over partition.
|
GridCloseableIterator<Map.Entry<byte[],byte[]>> |
GridCacheSwapManager.rawSwapIterator() |
GridCacheSwapEntry |
GridCacheSwapManager.read(KeyCacheObject key,
boolean readOffheap,
boolean readSwap) |
Collection<GridCacheBatchSwapEntry> |
GridCacheSwapManager.readAndRemove(Collection<? extends KeyCacheObject> keys) |
protected Object |
GridCacheMapEntry.readThrough(IgniteInternalTx tx,
KeyCacheObject key,
boolean reload,
UUID subjId,
String taskName) |
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 |
GridCacheProxyImpl.reload(K key)
Reloads a single key from persistent storage.
|
V |
CacheProjection.reload(K key)
Reloads a single key from persistent storage.
|
V |
GridCacheProjectionImpl.reload(K key)
Reloads a single key from persistent storage.
|
V |
GridCacheAdapter.reload(K key) |
V |
CacheProjection.remove(K key,
CacheEntryPredicate... filter)
Removes given key mapping from cache.
|
V |
GridCacheProxyImpl.remove(K key,
CacheEntryPredicate[] filter)
Removes given key mapping from cache.
|
V |
GridCacheProjectionImpl.remove(K key,
CacheEntryPredicate[] filter)
Removes given key mapping from cache.
|
V |
GridCacheAdapter.remove(K key,
CacheEntryPredicate[] filter)
Removes given key mapping from cache.
|
void |
GridCacheSwapManager.remove(KeyCacheObject key) |
V |
GridCacheProxyImpl.remove(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
CacheEntryImpl. |
V |
GridCacheProjectionEx.remove(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
CacheEntryImpl. |
V |
GridCacheProjectionImpl.remove(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
CacheEntryImpl. |
V |
GridCacheAdapter.remove(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
CacheEntryImpl. |
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 |
CacheProjection.remove(K key,
V val)
Removes given key mapping from cache if one exists and value is equal to the passed in value.
|
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.
|
void |
GridCacheProxyImpl.removeAll()
Removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
CacheProjection.removeAll()
Removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
GridCacheProjectionImpl.removeAll()
Removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
CacheProjection.removeAll(Collection<? extends K> keys,
CacheEntryPredicate... filter)
Removes given key mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
GridCacheProjectionImpl.removeAll(Collection<? extends K> keys,
CacheEntryPredicate... 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,
CacheEntryPredicate... 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,
CacheEntryPredicate[] filter)
Removes given key mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
GridCacheProxyImpl.removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data.
|
void |
GridCacheProjectionEx.removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data.
|
void |
GridCacheProjectionImpl.removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data.
|
void |
GridCacheAdapter.removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data.
|
IgniteInternalFuture<?> |
GridCacheProxyImpl.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
IgniteInternalFuture<?> |
GridCacheProjectionEx.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
IgniteInternalFuture<?> |
GridCacheProjectionImpl.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
IgniteInternalFuture<?> |
GridCacheAdapter.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
boolean |
GridCacheStoreManager.removeAllFromStore(IgniteInternalTx tx,
Collection<Object> keys) |
boolean |
GridCacheStoreManager.removeFromStore(IgniteInternalTx tx,
Object key) |
void |
CacheWeakQueryIteratorsHolder.removeIterator(CacheWeakQueryIteratorsHolder.WeakQueryFutureIterator it) |
boolean |
CacheProjection.removex(K key,
CacheEntryPredicate... filter)
Removes given key mapping from cache.
|
boolean |
GridCacheAdapter.removex(K key,
CacheEntryPredicate... filter)
Removes given key mapping from cache.
|
boolean |
GridCacheProxyImpl.removex(K key,
CacheEntryPredicate[] filter)
Removes given key mapping from cache.
|
boolean |
GridCacheProjectionImpl.removex(K key,
CacheEntryPredicate[] filter)
Removes given key mapping from cache.
|
boolean |
GridCacheProxyImpl.removex(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
CacheEntryImpl. |
boolean |
GridCacheProjectionEx.removex(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
CacheEntryImpl. |
boolean |
GridCacheProjectionImpl.removex(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
CacheEntryImpl. |
boolean |
GridCacheAdapter.removex(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
CacheEntryImpl. |
GridCacheReturn |
GridCacheProxyImpl.removex(K key,
V val)
Removes given key mapping from cache if one exists and value is equal to the passed in value.
|
GridCacheReturn |
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 |
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 |
GridCacheAdapter.removex(K key,
V val)
Removes given key mapping from cache if one exists and value is equal to the passed in value.
|
V |
GridCacheProxyImpl.replace(K key,
V val)
Stores given key-value pair in cache only if there is a previous mapping for it.
|
V |
CacheProjection.replace(K key,
V val)
Stores given key-value pair in cache only if there is a previous mapping for it.
|
V |
GridCacheProjectionImpl.replace(K key,
V val)
Stores given key-value pair in cache only if there is a previous mapping for it.
|
V |
GridCacheAdapter.replace(K key,
V val)
Stores given key-value pair in cache only if there is a previous mapping for it.
|
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. |
boolean |
CacheProjection.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 |
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.replacex(K key,
V val)
Stores given key-value pair in cache only if only if there is a previous mapping for it.
|
boolean |
CacheProjection.replacex(K key,
V val)
Stores given key-value pair in cache only if only if there is a previous mapping for it.
|
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.
|
GridCacheReturn |
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. |
GridCacheReturn |
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 |
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 |
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. |
IgniteInternalFuture |
GridCacheSharedContext.rollbackTxAsync(IgniteInternalTx tx) |
boolean |
GridCacheIoManager.safeSend(Collection<? extends ClusterNode> nodes,
GridCacheMessage msg,
GridIoPolicy plc,
IgnitePredicate<ClusterNode> fallback)
Sends message and automatically accounts for lefts nodes.
|
protected CacheObject |
GridCacheMapEntry.saveValueForIndexUnlocked()
This method will return current value only if clearIndex(V) will require previous value.
|
void |
GridCacheIoManager.send(ClusterNode node,
GridCacheMessage msg,
GridIoPolicy plc)
Sends communication message.
|
void |
GridCacheIoManager.send(UUID nodeId,
GridCacheMessage msg,
GridIoPolicy plc)
Sends communication message.
|
void |
GridCacheIoManager.sendOrderedMessage(ClusterNode node,
Object topic,
GridCacheMessage msg,
GridIoPolicy plc,
long timeout) |
int |
GridCacheProxyImpl.size(CachePeekMode[] peekModes) |
int |
CacheProjection.size(CachePeekMode[] peekModes) |
int |
GridCacheProjectionImpl.size(CachePeekMode[] peekModes) |
int |
GridCacheAdapter.size(CachePeekMode[] peekModes) |
void |
GridCacheProcessor.start()
Starts grid component.
|
void |
GridCachePreloaderAdapter.start()
Starts preloading.
|
void |
GridCachePreloader.start()
Starts preloading.
|
void |
GridCacheAdapter.start()
Starts this cache.
|
void |
GridCacheManager.start(GridCacheContext<K,V> cctx)
Starts manager.
|
void |
GridCacheManagerAdapter.start(GridCacheContext<K,V> cctx)
Starts manager.
|
void |
GridCacheSharedManagerAdapter.start(GridCacheSharedContext<K,V> cctx)
Starts manager.
|
void |
GridCacheSharedManager.start(GridCacheSharedContext<K,V> cctx)
Starts manager.
|
protected void |
GridCacheSharedManagerAdapter.start0() |
protected void |
GridCachePartitionExchangeManager.start0() |
protected void |
GridCacheMvccManager.start0() |
protected void |
GridCacheManagerAdapter.start0() |
void |
GridCacheIoManager.start0() |
protected void |
GridCacheTtlManager.start0() |
void |
GridCacheAffinityManager.start0() |
void |
GridCacheEvictionManager.start0() |
void |
GridCacheSwapManager.start0() |
void |
GridCacheDeploymentManager.start0() |
protected void |
GridCacheStoreManager.start0() |
void |
GridCacheProcessor.stop(boolean cancel)
Stops grid component.
|
int |
GridCacheSwapManager.swapEntriesCount(boolean primary,
boolean backup,
AffinityTopologyVersion topVer) |
Iterator<Map.Entry<K,V>> |
GridCacheProxyImpl.swapIterator()
Gets iterator over keys and values belonging to this cache swap space on local node.
|
Iterator<Map.Entry<K,V>> |
GridCache.swapIterator()
Gets iterator over keys and values belonging to this cache swap space on local node.
|
Iterator<Map.Entry<K,V>> |
GridCacheAdapter.swapIterator()
Gets iterator over keys and values belonging to this cache swap space on local node.
|
<K,V> Iterator<javax.cache.Cache.Entry<K,V>> |
GridCacheSwapManager.swapIterator(boolean primary,
boolean backup,
AffinityTopologyVersion topVer) |
GridCloseableIterator<Map.Entry<byte[],GridCacheSwapEntry>> |
GridCacheSwapManager.swapIterator(int part)
Gets swap space iterator over partition.
|
Iterator<KeyCacheObject> |
GridCacheSwapManager.swapKeyIterator(boolean primary,
boolean backup,
AffinityTopologyVersion topVer) |
long |
GridCacheProxyImpl.swapKeys()
Gets number of swap entries (keys).
|
long |
GridCache.swapKeys()
Gets number of swap entries (keys).
|
long |
GridCacheSwapManager.swapKeys()
Gets number of swap entries (keys).
|
long |
GridCacheAdapter.swapKeys()
Gets number of swap entries (keys).
|
long |
GridCacheProxyImpl.swapSize()
Gets size in bytes for swap space.
|
long |
GridCache.swapSize()
Gets size in bytes for swap space.
|
long |
GridCacheSwapManager.swapSize() |
long |
GridCacheAdapter.swapSize()
Gets size in bytes for swap space.
|
KeyCacheObject |
GridCacheContext.toCacheKeyObject(byte[] bytes) |
V |
GridCacheAdapter.tryPutIfAbsent(K key,
V val)
Tries to put value in cache.
|
void |
GridCacheStoreManager.txEnd(IgniteInternalTx tx,
boolean commit) |
void |
CacheProjection.unlock(K key,
CacheEntryPredicate... filter)
Unlocks given key only if current thread owns the lock.
|
void |
GridCacheAdapter.unlock(K key,
CacheEntryPredicate... filter)
Unlocks given key only if current thread owns the lock.
|
void |
GridCacheProxyImpl.unlock(K key,
CacheEntryPredicate[] filter)
Unlocks given key only if current thread owns the lock.
|
void |
GridCacheProjectionImpl.unlock(K key,
CacheEntryPredicate[] filter)
Unlocks given key only if current thread owns the lock.
|
void |
CacheProjection.unlockAll(Collection<? extends K> keys,
CacheEntryPredicate... filter)
Unlocks given keys only if current thread owns the locks.
|
void |
GridCacheProxyImpl.unlockAll(Collection<? extends K> keys,
CacheEntryPredicate[] filter)
Unlocks given keys only if current thread owns the locks.
|
void |
GridCacheProjectionImpl.unlockAll(Collection<? extends K> keys,
CacheEntryPredicate[] filter)
Unlocks given keys only if current thread owns the locks.
|
void |
GridCacheEntryInfo.unmarshal(GridCacheContext ctx,
ClassLoader clsLdr)
Unmarshalls entry.
|
protected <K1> LinkedHashMap<K1,Boolean> |
GridCacheMessage.unmarshalBooleanLinkedMap(Map<byte[],Boolean> byteMap,
GridCacheSharedContext ctx,
ClassLoader ldr) |
protected <T> List<T> |
GridCacheMessage.unmarshalCollection(Collection<byte[]> byteCol,
GridCacheSharedContext ctx,
ClassLoader ldr) |
protected void |
GridCacheMessage.unmarshalInfo(GridCacheEntryInfo info,
GridCacheContext ctx,
ClassLoader ldr) |
protected void |
GridCacheMessage.unmarshalInfos(Iterable<? extends GridCacheEntryInfo> infos,
GridCacheContext ctx,
ClassLoader ldr) |
protected Object[] |
GridCacheMessage.unmarshalInvokeArguments(byte[][] byteCol,
GridCacheSharedContext ctx,
ClassLoader ldr) |
protected void |
GridCacheMessage.unmarshalTx(Iterable<IgniteTxEntry> txEntries,
boolean near,
GridCacheSharedContext ctx,
ClassLoader ldr) |
void |
GridCacheEntryInfo.unmarshalValue(GridCacheContext<?,?> ctx,
ClassLoader ldr) |
CacheObject |
GridCacheEntryEx.unswap() |
CacheObject |
GridCacheMapEntry.unswap() |
CacheObject |
GridCacheEntryEx.unswap(boolean ignoreFlags,
boolean needVal)
Unswap ignoring flags.
|
CacheObject |
GridCacheMapEntry.unswap(boolean ignoreFlags,
boolean needVal)
Unswaps an entry.
|
CacheObject |
GridCacheContext.unswapCacheObject(byte type,
byte[] bytes,
IgniteUuid clsLdrId) |
protected void |
GridCacheMapEntry.updateIndex(CacheObject val,
long expireTime,
GridCacheVersion ver,
CacheObject prevVal)
Updates cache index.
|
byte[] |
CacheObjectByteArrayImpl.valueBytes(CacheObjectContext ctx) |
byte[] |
CacheObjectImpl.valueBytes(CacheObjectContext ctx) |
byte[] |
KeyCacheObjectImpl.valueBytes(CacheObjectContext ctx) |
byte[] |
CacheObject.valueBytes(CacheObjectContext ctx) |
CacheObject |
GridCacheEntryEx.valueBytes(GridCacheVersion ver)
Gets cached serialized value bytes.
|
CacheObject |
GridCacheMapEntry.valueBytes(GridCacheVersion ver)
Gets cached serialized value bytes.
|
GridCacheVersionedEntryEx |
GridCacheMapEntry.versionedEntry()
Create versioned entry for this cache entry.
|
<K,V> GridCacheVersionedEntryEx<K,V> |
GridCacheEntryEx.versionedEntry()
Create versioned entry for this cache entry.
|
boolean |
GridCacheEntryEx.versionedValue(CacheObject val,
GridCacheVersion curVer,
GridCacheVersion newVer)
Sets new value if passed in version matches the current version
(used for read-through only).
|
boolean |
GridCacheMapEntry.versionedValue(CacheObject val,
GridCacheVersion curVer,
GridCacheVersion newVer)
Sets new value if passed in version matches the current version
(used for read-through only).
|
| Constructor and Description |
|---|
GridCacheStoreManager(GridKernalContext ctx,
Map<CacheStore,ThreadLocal> sesHolders,
CacheStore<Object,Object> cfgStore,
CacheConfiguration cfg) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
CacheDataStructuresManager.onKernalStart0() |
<T> GridCacheQueueProxy<T> |
CacheDataStructuresManager.queue(String name,
int cap,
boolean colloc,
boolean create) |
<T> GridCacheQueueProxy<T> |
CacheDataStructuresManager.queue0(String name,
int cap,
boolean colloc,
boolean create) |
void |
CacheDataStructuresManager.removeSetData(IgniteUuid id) |
<T> IgniteSet<T> |
CacheDataStructuresManager.set(String name,
boolean colloc,
boolean create) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDistributedUnlockRequest.addKey(KeyCacheObject key,
GridCacheContext ctx) |
void |
GridDistributedLockRequest.addKeyBytes(KeyCacheObject key,
boolean retVal,
Collection<GridCacheMvccCandidate> cands,
GridCacheContext ctx)
Adds a key.
|
void |
GridDistributedTxRemoteAdapter.commit()
Commits this transaction by initiating
two-phase-commit process. |
void |
GridDistributedBaseMessage.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDistributedTxPrepareRequest.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridCacheTtlUpdateRequest.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDistributedTxPrepareResponse.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDistributedLockResponse.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDistributedTxFinishRequest.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDistributedUnlockRequest.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDistributedLockRequest.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDistributedTxRemoteAdapter.forceCommit()
Forces commit for this tx.
|
void |
GridDistributedTxRemoteAdapter.prepare()
Prepare phase.
|
void |
GridDistributedBaseMessage.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedTxPrepareRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridCacheTtlUpdateRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedTxPrepareResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedLockResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedTxFinishRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedUnlockRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedLockRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedCacheAdapter.removeAll()
Removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
| Constructor and Description |
|---|
GridFutureRemapTimeoutObject(GridFutureAdapter<?> fut,
long timeout,
AffinityTopologyVersion topVer,
IgniteCheckedException e) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtLockRequest.addDhtKey(KeyCacheObject key,
boolean invalidateEntry,
GridCacheContext ctx)
Adds a DHT key.
|
IgniteInternalFuture<Boolean> |
GridDhtTxLocalAdapter.addEntry(long msgId,
IgniteTxEntry e) |
void |
GridDhtLockRequest.addNearKey(KeyCacheObject key,
GridCacheSharedContext ctx)
Adds a Near key.
|
void |
GridDhtUnlockRequest.addNearKey(KeyCacheObject key,
GridCacheSharedContext ctx)
Adds a Near key.
|
void |
GridDhtTxRemote.addWrite(IgniteTxEntry entry,
ClassLoader ldr) |
boolean |
GridClientPartitionTopology.afterExchange(GridDhtPartitionsExchangeFuture exchFut)
Post-initializes this topology.
|
boolean |
GridDhtPartitionTopology.afterExchange(GridDhtPartitionsExchangeFuture exchFut)
Post-initializes this topology.
|
void |
GridDhtPartitionTopology.beforeExchange(GridDhtPartitionsExchangeFuture exchFut)
Pre-initializes this topology.
|
AffinityTopologyVersion |
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 |
GridDhtLockRequest.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtTxPrepareResponse.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtTxPrepareRequest.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtUnlockRequest.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtAffinityAssignmentResponse.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtLockResponse.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtCacheAdapter.localLoad(Collection<? extends K> keys,
javax.cache.expiry.ExpiryPolicy plc) |
void |
GridDhtCacheAdapter.localLoadCache(IgniteBiPredicate<K,V> p,
Object[] args)
Delegates to
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure,Object...) method
to load state from the underlying persistent storage. |
int |
GridDhtCacheEntry.memorySize() |
void |
GridDhtLocalPartition.onDeferredDelete(KeyCacheObject key,
GridCacheVersion ver) |
void |
GridDhtCacheAdapter.onKernalStart()
Kernal start callback.
|
void |
GridDhtLockRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtTxPrepareResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtTxPrepareRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtUnlockRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtAffinityAssignmentResponse.prepareMarshal(GridCacheSharedContext ctx) |
void |
GridDhtLockResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
V |
GridDhtCacheAdapter.reload(K key)
Reloads a single key from persistent storage.
|
void |
GridDhtTxLocalAdapter.rollback()
Rolls back this transaction.
|
void |
GridDhtCacheAdapter.start()
Starts this cache.
|
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 |
|---|---|
IgniteCheckedException |
GridDhtAtomicUpdateResponse.error() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtAtomicUpdateRequest.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridNearAtomicUpdateResponse.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtAtomicUpdateResponse.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridNearAtomicUpdateRequest.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
<T> javax.cache.processor.EntryProcessorResult<T> |
GridDhtAtomicCache.invoke(K key,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>> |
GridDhtAtomicCache.invokeAll(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map,
Object... args) |
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>> |
GridDhtAtomicCache.invokeAll(Set<? extends K> keys,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
void |
GridDhtAtomicCache.localRemoveAll() |
V |
GridDhtAtomicCache.peek(K key,
Collection<GridCachePeekMode> modes)
Peeks at cached value using optional set of peek modes.
|
void |
GridDhtAtomicUpdateRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearAtomicUpdateResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtAtomicUpdateResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearAtomicUpdateRequest.prepareMarshal(GridCacheSharedContext 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 cached,
long ttl,
CacheEntryPredicate[] filter)
Internal method that is called from
CacheEntryImpl. |
void |
GridDhtAtomicCache.putAll(Map<? extends K,? extends V> m,
CacheEntryPredicate[] filter)
Stores given key-value pairs in cache.
|
void |
GridDhtAtomicCache.putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> conflictMap)
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,
CacheEntryPredicate[] filter)
Stores given key-value pair in cache.
|
boolean |
GridDhtAtomicCache.putx(K key,
V val,
GridCacheEntryEx cached,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
CacheEntryImpl. |
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 entry,
CacheEntryPredicate... filter)
Internal method that is called from
CacheEntryImpl. |
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,
CacheEntryPredicate... filter)
Removes given key mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
GridDhtAtomicCache.removeAllConflict(Map<KeyCacheObject,GridCacheVersion> conflictMap)
Removes DR data.
|
boolean |
GridDhtAtomicCache.removex(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
CacheEntryImpl. |
GridCacheReturn |
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 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 |
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.
|
V |
GridDhtAtomicCache.tryPutIfAbsent(K key,
V val)
Tries to put value in cache.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridDhtDetachedCacheEntry.clearIndex(CacheObject val)
Clears index.
|
V |
GridDhtColocatedCache.peek(K key,
Collection<GridCachePeekMode> modes)
Peeks at cached value using optional set of peek modes.
|
void |
GridDhtDetachedCacheEntry.resetFromPrimary(CacheObject val,
GridCacheVersion ver)
Sets value to detached entry so it can be retrieved in transactional gets.
|
void |
GridDhtColocatedCache.start()
Starts this cache.
|
CacheObject |
GridDhtDetachedCacheEntry.unswap(boolean ignoreFlags,
boolean needVal)
Unswaps an entry.
|
protected void |
GridDhtDetachedCacheEntry.updateIndex(CacheObject val,
long expireTime,
GridCacheVersion ver,
CacheObject old)
Updates cache index.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtPartitionDemandMessage.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtForceKeysResponse.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtPartitionsFullMessage.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtPartitionsSingleMessage.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtPartitionSupplyMessage.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtForceKeysRequest.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtPreloader.onKernalStart()
Kernal start callback.
|
void |
GridDhtPartitionDemandMessage.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtForceKeysResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtPartitionsFullMessage.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtPartitionsSingleMessage.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtForceKeysRequest.prepareMarshal(GridCacheSharedContext 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<IgniteTxEntry> entries)
Adds entries to started near remote tx.
|
boolean |
GridNearTxRemote.addEntry(GridCacheContext cacheCtx,
IgniteTxKey key,
GridCacheOperation op,
CacheObject val,
GridCacheVersion drVer) |
void |
GridNearLockRequest.addKeyBytes(KeyCacheObject key,
boolean retVal,
GridCacheVersion dhtVer,
GridCacheContext ctx)
Adds a key.
|
void |
GridNearLockResponse.addValueBytes(CacheObject val,
boolean filterPassed,
GridCacheVersion dhtVer,
GridCacheVersion mappedVer) |
void |
GridNearTxLocal.close()
Ends the transaction.
|
void |
GridNearLockRequest.filter(CacheEntryPredicate[] filter,
GridCacheContext ctx) |
boolean |
GridNearTxLocal.finish(boolean commit)
Finishes transaction (either commit or rollback).
|
void |
CacheVersionedValue.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr)
This method is called after the whole message is received
and is responsible for unmarshalling state.
|
void |
GridNearGetResponse.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridNearLockRequest.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridNearTxPrepareResponse.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridNearGetRequest.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr) |
void |
GridNearTxFinishResponse.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
<T> javax.cache.processor.EntryProcessorResult<T> |
GridNearAtomicCache.invoke(K key,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>> |
GridNearAtomicCache.invokeAll(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map,
Object... args) |
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>> |
GridNearAtomicCache.invokeAll(Set<? extends K> keys,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
boolean |
GridNearCacheEntry.loadedValue(IgniteInternalTx tx,
UUID primaryNodeId,
CacheObject val,
GridCacheVersion ver,
GridCacheVersion dhtVer,
GridCacheVersion expVer,
long ttl,
long expireTime,
boolean evt,
AffinityTopologyVersion topVer,
UUID subjId) |
void |
GridNearCacheAdapter.localLoad(Collection<? extends K> keys,
javax.cache.expiry.ExpiryPolicy plc) |
void |
GridNearCacheAdapter.localLoadCache(IgniteBiPredicate<K,V> p,
Object[] args)
Delegates to
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure,Object...) method
to load state from the underlying persistent storage. |
void |
GridNearAtomicCache.localRemoveAll() |
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 |
CacheVersionedValue.prepareMarshal(CacheObjectContext ctx)
This method is called before the whole message is sent
and is responsible for pre-marshalling state.
|
void |
GridNearGetResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearLockRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearTxPrepareResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearGetRequest.prepareMarshal(GridCacheSharedContext ctx) |
void |
GridNearTxFinishResponse.prepareMarshal(GridCacheSharedContext 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 by given key, if any, from offheap or swap storage
into memory.
|
V |
GridNearCacheAdapter.promote(K key,
boolean deserializePortable) |
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 cached,
long ttl,
CacheEntryPredicate[] filter)
Internal method that is called from
CacheEntryImpl. |
void |
GridNearAtomicCache.putAll(Map<? extends K,? extends V> m,
CacheEntryPredicate[] filter)
Stores given key-value pairs in cache.
|
void |
GridNearAtomicCache.putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data.
|
IgniteInternalFuture<?> |
GridNearAtomicCache.putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> 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,
CacheEntryPredicate[] filter)
Stores given key-value pair in cache.
|
boolean |
GridNearAtomicCache.putx(K key,
V val,
GridCacheEntryEx cached,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
CacheEntryImpl. |
boolean |
GridNearAtomicCache.putxIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
protected Object |
GridNearCacheEntry.readThrough(IgniteInternalTx tx,
KeyCacheObject key,
boolean reload,
UUID subjId,
String taskName) |
V |
GridNearCacheAdapter.reload(K key)
Reloads a single key from persistent storage.
|
V |
GridNearAtomicCache.remove(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
CacheEntryImpl. |
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()
Removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
GridNearAtomicCache.removeAll(Collection<? extends K> keys,
CacheEntryPredicate... filter)
Removes given key mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
GridNearAtomicCache.removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data.
|
IgniteInternalFuture<?> |
GridNearAtomicCache.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
boolean |
GridNearAtomicCache.removex(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
CacheEntryImpl. |
GridCacheReturn |
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 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 |
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(CacheObject val,
GridCacheVersion ver,
GridCacheVersion dhtVer,
UUID primaryNodeId,
AffinityTopologyVersion topVer)
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 |
GridNearTransactionalCache.startRemoteTx(UUID nodeId,
GridDhtLockRequest 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.unlockAll(Collection<? extends K> keys,
CacheEntryPredicate... filter)
Unlocks given keys only if current thread owns the locks.
|
protected void |
GridNearCacheEntry.updateIndex(CacheObject val,
long expireTime,
GridCacheVersion ver,
CacheObject old)
Updates cache index.
|
| Constructor and Description |
|---|
GridNearTxRemote(GridCacheSharedContext ctx,
ClassLoader ldr,
UUID nodeId,
UUID nearNodeId,
long rmtThreadId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
GridIoPolicy plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
Collection<IgniteTxEntry> writeEntries,
int txSize,
IgniteTxKey grpLockKey,
UUID subjId,
int taskNameHash)
This constructor is meant for optimistic transactions.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheDrManager.beforeExchange(AffinityTopologyVersion topVer,
boolean left)
Process partitions "before exchange" event.
|
void |
GridCacheDrManager.replicate(KeyCacheObject key,
CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
GridDrType drType)
Performs replication.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridOsCacheDrManager.beforeExchange(AffinityTopologyVersion topVer,
boolean left)
Process partitions "before exchange" event.
|
void |
GridOsCacheDrManager.onKernalStart() |
void |
GridOsCacheDrManager.start(GridCacheContext cctx)
Starts manager.
|
| Modifier and Type | Method and Description |
|---|---|
abstract void |
CacheJtaManagerAdapter.checkJta()
Checks if cache is working in JTA transaction and enlist cache as XAResource if necessary.
|
void |
CacheNoopJtaManager.checkJta()
Checks if cache is working in JTA transaction and enlist cache as XAResource if necessary.
|
abstract void |
CacheJtaManagerAdapter.createTmLookup(CacheConfiguration ccfg)
Creates transaction manager finder.
|
void |
CacheNoopJtaManager.createTmLookup(CacheConfiguration ccfg)
Creates transaction manager finder.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridLocalCache.removeAll()
Removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
GridLocalCache.unlockAll(Collection<? extends K> keys,
CacheEntryPredicate[] filter)
Unlocks given keys only if current thread owns the locks.
|
| Modifier and Type | Method and Description |
|---|---|
V |
GridLocalAtomicCache.get(K key,
boolean deserializePortable) |
Map<K,V> |
GridLocalAtomicCache.getAll(Collection<? extends K> keys,
boolean deserializePortable) |
<T> javax.cache.processor.EntryProcessorResult<T> |
GridLocalAtomicCache.invoke(K key,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>> |
GridLocalAtomicCache.invokeAll(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map,
Object... args) |
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>> |
GridLocalAtomicCache.invokeAll(Set<? extends K> keys,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
V |
GridLocalAtomicCache.put(K key,
V val,
GridCacheEntryEx cached,
long ttl,
CacheEntryPredicate[] filter)
Internal method that is called from
CacheEntryImpl. |
void |
GridLocalAtomicCache.putAll(Map<? extends K,? extends V> m,
CacheEntryPredicate[] 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,
CacheEntryPredicate[] filter)
Stores given key-value pair in cache.
|
boolean |
GridLocalAtomicCache.putx(K key,
V val,
GridCacheEntryEx cached,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
CacheEntryImpl. |
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 entry,
CacheEntryPredicate... filter)
Internal method that is called from
CacheEntryImpl. |
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()
Removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
GridLocalAtomicCache.removeAll(Collection<? extends K> keys,
CacheEntryPredicate... filter)
Removes given key mappings from cache for entries for which the optionally passed in filters do
pass.
|
boolean |
GridLocalAtomicCache.removex(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
CacheEntryImpl. |
GridCacheReturn |
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 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 |
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.unlockAll(Collection<? extends K> keys,
CacheEntryPredicate... 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
CacheQueryFuture.next() method without blocking. |
int |
CacheQueryFuture.available()
Returns number of elements that are already fetched and can
be returned from
CacheQueryFuture.next() method without blocking. |
boolean |
CacheQueryFuture.cancel()
Cancels this query future and stop receiving any further results for the query
associated with this future.
|
boolean |
GridCacheQueryFutureAdapter.cancel()
Default no-op implementation that always returns
false. |
protected void |
GridCacheLocalQueryFuture.cancelQuery() |
protected abstract void |
GridCacheQueryFutureAdapter.cancelQuery() |
protected void |
GridCacheDistributedQueryFuture.cancelQuery() |
void |
QueryCursorEx.Consumer.consume(T val)
Consume value.
|
void |
GridCacheQueryResponse.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridCacheQueryRequest.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) 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.
|
void |
QueryCursorEx.getAll(QueryCursorEx.Consumer<T> c)
Get all values passing them through passed consumer.
|
T |
GridCacheQueryErrorFuture.next()
Returns next element from result set.
|
T |
CacheQueryFuture.next()
Returns next element from result set.
|
Collection<R> |
GridCacheQueryFutureAdapter.nextPage()
Returns next page for the query.
|
Collection<R> |
GridCacheQueryFutureAdapter.nextPage(long timeout)
Returns next page for the query.
|
void |
GridCacheQueryManager.onSwap(String swapSpaceName,
K key)
Entry for given key unswapped.
|
void |
GridCacheQueryManager.onUnswap(K key,
V val,
byte[] valBytes)
Entry for given key unswapped.
|
void |
GridCacheQueryResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridCacheQueryRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridCacheQueryManager.remove(Object key,
Object val) |
long |
GridCacheQueryManager.size(Class<?> valType)
Gets number of objects of given type in index.
|
Collection<GridCacheSqlMetadata> |
GridCacheQueriesImpl.sqlMetadata()
Gets SQL metadata.
|
Collection<GridCacheSqlMetadata> |
GridCacheQueriesProxy.sqlMetadata()
Gets SQL metadata.
|
Collection<GridCacheSqlMetadata> |
GridCacheQueriesEx.sqlMetadata()
Gets SQL metadata.
|
Collection<GridCacheSqlMetadata> |
GridCacheQueryManager.sqlMetadata()
Gets SQL metadata.
|
void |
GridCacheDistributedQueryManager.start0() |
void |
GridCacheQueryManager.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 |
CacheContinuousQueryManager.cancelJCacheQuery(javax.cache.configuration.CacheEntryListenerConfiguration cfg) |
UUID |
CacheContinuousQueryManager.executeInternalQuery(javax.cache.event.CacheEntryUpdatedListener<?,?> locLsnr,
CacheEntryEventSerializableFilter rmtFilter,
boolean loc,
boolean notifyExisting) |
void |
CacheContinuousQueryManager.executeJCacheQuery(javax.cache.configuration.CacheEntryListenerConfiguration cfg,
boolean onStart) |
UUID |
CacheContinuousQueryManager.executeQuery(javax.cache.event.CacheEntryUpdatedListener locLsnr,
CacheEntryEventSerializableFilter rmtFilter,
int bufSize,
long timeInterval,
boolean autoUnsubscribe,
ClusterGroup grp) |
void |
CacheContinuousQueryManager.onEntryExpired(GridCacheEntryEx e,
KeyCacheObject key,
CacheObject oldVal) |
void |
CacheContinuousQueryManager.onEntryUpdated(GridCacheEntryEx e,
KeyCacheObject key,
CacheObject newVal,
CacheObject oldVal,
boolean preload) |
protected void |
CacheContinuousQueryManager.onKernalStart0() |
protected void |
CacheContinuousQueryManager.start0() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
IgniteTxLocalAdapter.addActiveCache(GridCacheContext cacheCtx)
Adds cache to the list of active caches in transaction.
|
protected IgniteBiTuple<GridCacheOperation,CacheObject> |
IgniteTxAdapter.applyTransformClosures(IgniteTxEntry txEntry,
boolean metrics) |
protected void |
IgniteTxAdapter.awaitCompletion()
Awaits transaction completion.
|
protected void |
IgniteTxLocalAdapter.batchStoreCommit(Iterable<IgniteTxEntry> writeEntries)
Performs batch database operations.
|
protected void |
IgniteTxLocalAdapter.checkValid()
Checks transaction expiration.
|
void |
IgniteInternalTx.close()
Ends the transaction.
|
void |
IgniteTxAdapter.close() |
void |
IgniteTxLocalAdapter.commit()
Commits this transaction by initiating
two-phase-commit process. |
void |
IgniteInternalTx.commit()
Commits this transaction by initiating
two-phase-commit process. |
protected IgniteBiTuple<GridCacheOperation,GridCacheVersionConflictContext> |
IgniteTxAdapter.conflictResolve(GridCacheOperation op,
IgniteTxEntry txEntry,
CacheObject newVal,
GridCacheVersion newVer,
GridCacheEntryEx old)
Resolve DR conflict.
|
protected boolean |
IgniteTxAdapter.evictNearEntry(IgniteTxEntry e,
boolean primaryOnly) |
boolean |
IgniteTxLocalEx.finish(boolean commit)
Finishes transaction (either commit or rollback).
|
void |
IgniteTxKey.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
IgniteTxEntry.marshal(GridCacheSharedContext<?,?> ctx,
boolean transferExpiry) |
void |
TxEntryValueHolder.marshal(GridCacheSharedContext<?,?> sharedCtx,
GridCacheContext<?,?> ctx) |
protected abstract IgniteInternalFuture<T> |
IgniteTxLocalAdapter.PostLockClosure2.postLock()
Post lock callback.
|
protected abstract T |
IgniteTxLocalAdapter.PostLockClosure1.postLock(T val)
Post lock callback.
|
protected Set<KeyCacheObject> |
IgniteTxLocalAdapter.postLockWrite(GridCacheContext cacheCtx,
Iterable<KeyCacheObject> keys,
Set<KeyCacheObject> failed,
GridCacheReturn ret,
boolean rmv,
boolean retval,
boolean read,
long accessTtl,
CacheEntryPredicate[] filter,
boolean computeInvoke)
Post lock processing for put or remove.
|
protected abstract IgniteInternalFuture<T> |
IgniteTxLocalAdapter.PostMissClosure.postMiss(T t)
Post lock callback.
|
void |
IgniteTxLocalAdapter.prepare()
Prepare state.
|
void |
IgniteInternalTx.prepare()
Prepare state.
|
void |
IgniteTxKey.prepareMarshal(GridCacheContext ctx) |
void |
IgniteTxManager.prepareTx(IgniteInternalTx tx)
Handles prepare stage of 2PC.
|
void |
IgniteInternalTx.rollback()
Rolls back this transaction.
|
protected void |
IgniteTxManager.start0() |
GridNearTxRemote |
IgniteTxHandler.startNearRemoteTx(ClassLoader ldr,
UUID nodeId,
GridDhtTxPrepareRequest req)
Called while processing dht tx prepare request.
|
void |
TxEntryValueHolder.unmarshal(GridCacheContext<?,?> ctx,
ClassLoader ldr) |
void |
IgniteTxEntry.unmarshal(GridCacheSharedContext<?,?> ctx,
boolean near,
ClassLoader clsLdr)
Unmarshalls entry.
|
void |
IgniteTxLocalAdapter.userCommit() |
void |
IgniteTxLocalEx.userCommit() |
void |
IgniteTxLocalAdapter.userPrepare() |
void |
IgniteTxLocalAdapter.userRollback() |
void |
IgniteTxLocalEx.userRollback() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheRawVersionedEntry.marshal(CacheObjectContext ctx,
Marshaller marsh)
Perform internal marshal of this entry before it will be serialized.
|
protected void |
GridCacheVersionManager.onKernalStart0() |
void |
GridCacheRawVersionedEntry.prepareDirectMarshal(CacheObjectContext ctx) |
<K,V> GridCacheVersionConflictContext<K,V> |
GridCacheVersionAbstractConflictResolver.resolve(GridCacheVersionedEntryEx<K,V> oldEntry,
GridCacheVersionedEntryEx<K,V> newEntry,
boolean atomicVerComparator)
Resolve the conflict.
|
protected <K,V> void |
GridCacheVersionConflictResolver.resolve0(GridCacheVersionConflictContext<K,V> ctx,
GridCacheVersionedEntryEx<K,V> oldEntry,
GridCacheVersionedEntryEx<K,V> newEntry,
boolean atomicVerComparator)
Internal conflict resolution routine.
|
protected abstract <K,V> void |
GridCacheVersionAbstractConflictResolver.resolve0(GridCacheVersionConflictContext<K,V> ctx,
GridCacheVersionedEntryEx<K,V> oldEntry,
GridCacheVersionedEntryEx<K,V> newEntry,
boolean atomicVerComparator)
Internal conflict resolution routine.
|
void |
GridCacheVersionManager.start0() |
void |
GridCacheRawVersionedEntry.unmarshal(CacheObjectContext ctx) |
void |
GridCacheRawVersionedEntry.unmarshal(CacheObjectContext ctx,
Marshaller marsh)
Perform internal unmarshal of this entry.
|
void |
GridCacheRawVersionedEntry.unmarshalKey(CacheObjectContext ctx,
Marshaller marsh)
Perform internal key unmarshal of this entry.
|
| Modifier and Type | Method and Description |
|---|---|
byte[] |
IgniteCacheObjectProcessorImpl.marshal(CacheObjectContext ctx,
Object val) |
byte[] |
IgniteCacheObjectProcessor.marshal(CacheObjectContext ctx,
Object val) |
CacheObject |
IgniteCacheObjectProcessorImpl.toCacheObject(GridCacheContext ctx,
long valPtr,
boolean tmp) |
CacheObject |
IgniteCacheObjectProcessor.toCacheObject(GridCacheContext ctx,
long valPtr,
boolean tmp) |
Object |
IgniteCacheObjectProcessorImpl.unmarshal(CacheObjectContext ctx,
byte[] bytes,
ClassLoader clsLdr) |
Object |
IgniteCacheObjectProcessor.unmarshal(CacheObjectContext ctx,
byte[] bytes,
ClassLoader clsLdr) |
| Modifier and Type | Method and Description |
|---|---|
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,
boolean sync,
boolean msg) |
void |
GridContinuousProcessor.onCacheStart(GridCacheContext ctx)
Callback invoked when cache is started.
|
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).
|
GridContinuousHandler.RegisterStatus |
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 |
|---|---|
void |
DataStreamerImpl.closeEx(boolean cancel) |
void |
DataStreamProcessor.start()
Starts grid component.
|
| Modifier and Type | Method and Description |
|---|---|
Object |
GridCacheAnnotationHelper.annotatedValue(Object target)
Returns annotated value.
|
IgniteAtomicLong |
DataStructuresProcessor.atomicLong(String name,
long initVal,
boolean create)
Gets an atomic long from cache or creates one if it's not cached.
|
<T> IgniteAtomicReference<T> |
DataStructuresProcessor.atomicReference(String name,
T initVal,
boolean create)
Gets an atomic reference from cache or creates one if it's not cached.
|
<T,S> IgniteAtomicStamped<T,S> |
DataStructuresProcessor.atomicStamped(String name,
T initVal,
S initStamp,
boolean create)
Gets an atomic stamped from cache or creates one if it's not cached.
|
IgniteCountDownLatch |
DataStructuresProcessor.countDownLatch(String name,
int cnt,
boolean autoDel,
boolean create)
Gets or creates count down latch.
|
<T> IgniteQueue<T> |
DataStructuresProcessor.queue(String name,
int cap,
CollectionConfiguration cfg)
Gets a queue from cache or creates one if it's not cached.
|
void |
DataStructuresProcessor.removeAtomicLong(String name)
Removes atomic long from cache.
|
void |
DataStructuresProcessor.removeAtomicReference(String name)
Removes atomic reference from cache.
|
void |
DataStructuresProcessor.removeAtomicStamped(String name)
Removes atomic stamped from cache.
|
void |
DataStructuresProcessor.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.
|
void |
DataStructuresProcessor.removeQueue(String name,
GridCacheContext cctx) |
void |
DataStructuresProcessor.removeSequence(String name)
Removes sequence from cache.
|
void |
DataStructuresProcessor.removeSet(String name,
GridCacheContext cctx) |
static <R> R |
DataStructuresProcessor.retry(IgniteLogger log,
Callable<R> call) |
IgniteAtomicSequence |
DataStructuresProcessor.sequence(String name,
long initVal,
boolean create)
Gets a sequence from cache or creates one if it's not cached.
|
<T> IgniteSet<T> |
DataStructuresProcessor.set(String name,
CollectionConfiguration cfg)
Gets a set from cache or creates one if it's not cached.
|
| Modifier and Type | Method and Description |
|---|---|
abstract void |
HadoopTaskContext.cleanupTaskEnvironment()
Cleans up local environment of the task.
|
void |
HadoopJob.cleanupTaskEnvironment(HadoopTaskInfo info)
Cleans up local environment of the task.
|
void |
HadoopTaskInput.close()
Closes input.
|
void |
HadoopSerialization.close()
Finalise the internal objects.
|
void |
HadoopTaskOutput.close()
Closes output.
|
abstract HadoopCounters |
HadoopProcessorAdapter.counters(HadoopJobId jobId)
Returns Hadoop job counters.
|
HadoopCounters |
Hadoop.counters(HadoopJobId jobId)
Returns job counters.
|
HadoopJob |
HadoopJobInfo.createJob(HadoopJobId jobId,
IgniteLogger log)
Creates new job instance for the given ID.
|
void |
HadoopJob.dispose(boolean external)
Release all the resources.
|
IgniteInternalFuture<?> |
HadoopNoopProcessor.finishFuture(HadoopJobId jobId)
Gets Hadoop job finish future.
|
abstract IgniteInternalFuture<?> |
HadoopProcessorAdapter.finishFuture(HadoopJobId jobId)
Gets Hadoop job finish future.
|
IgniteInternalFuture<?> |
Hadoop.finishFuture(HadoopJobId jobId)
Gets Hadoop finish future for particular job.
|
HadoopTaskContext |
HadoopJob.getTaskContext(HadoopTaskInfo info)
Returns context for task execution.
|
void |
HadoopJob.initialize(boolean external,
UUID locNodeId)
Does all the needed initialization for the job.
|
Collection<HadoopInputSplit> |
HadoopJob.input()
Gets collection of input splits for this job.
|
abstract HadoopSerialization |
HadoopTaskContext.keySerialization()
Gets serializer for values.
|
boolean |
HadoopNoopProcessor.kill(HadoopJobId jobId)
Kills job.
|
abstract boolean |
HadoopProcessorAdapter.kill(HadoopJobId jobId)
Kills job.
|
boolean |
Hadoop.kill(HadoopJobId jobId)
Kills job.
|
abstract HadoopPartitioner |
HadoopTaskContext.partitioner()
Gets partitioner.
|
HadoopMapReducePlan |
HadoopMapReducePlanner.preparePlan(HadoopJob job,
Collection<ClusterNode> top,
HadoopMapReducePlan oldPlan)
Prepares map-reduce execution plan for the given job and topology.
|
abstract void |
HadoopTaskContext.prepareTaskEnvironment()
Prepare local environment for the task.
|
void |
HadoopJob.prepareTaskEnvironment(HadoopTaskInfo info)
Prepare local environment for the task.
|
Object |
HadoopSerialization.read(DataInput in,
Object obj)
Reads object from the given input optionally reusing given instance.
|
abstract void |
HadoopTaskContext.run()
Execute current task.
|
abstract void |
HadoopTask.run(HadoopTaskContext taskCtx)
Runs task.
|
HadoopJobStatus |
HadoopNoopProcessor.status(HadoopJobId jobId)
Gets Hadoop job execution status.
|
abstract HadoopJobStatus |
HadoopProcessorAdapter.status(HadoopJobId jobId)
Gets Hadoop job execution status.
|
HadoopJobStatus |
Hadoop.status(HadoopJobId jobId)
Gets Hadoop job execution status.
|
abstract HadoopSerialization |
HadoopTaskContext.valueSerialization()
Gets serializer for values.
|
void |
HadoopSerialization.write(DataOutput out,
Object obj)
Writes the given object to output.
|
void |
HadoopTaskOutput.write(Object key,
Object val)
Writes key and value to the output.
|
| Modifier and Type | Method and Description |
|---|---|
void |
HadoopCounterWriter.write(HadoopJobInfo jobInfo,
HadoopJobId jobId,
HadoopCounters cntrs)
Writes counters of given job to some statistics storage.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IgfsInvalidRangeException
Internal exception thrown when attempted to update range that is no longer present
in file affinity map.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteCheckedException |
IgfsAckMessage.error() |
IgniteCheckedException |
IgfsDeleteMessage.error() |
| Modifier and Type | Method and Description |
|---|---|
Collection<IgfsBlockLocation> |
IgfsDataManager.affinity(IgfsFileInfo info,
long start,
long len)
Resolve affinity nodes for specified part of file.
|
Collection<IgfsBlockLocation> |
IgfsDataManager.affinity(IgfsFileInfo info,
long start,
long len,
long maxLen)
Resolve affinity nodes for specified part of file.
|
IgfsSecondaryOutputStreamDescriptor |
IgfsMetaManager.appendDual(IgfsSecondaryFileSystem fs,
IgfsPath path,
int bufSize)
Append to a file in DUAL mode.
|
IgniteInternalFuture<?> |
IgfsAsyncImpl.awaitDeletesAsync()
Asynchronously await for all entries existing in trash to be removed.
|
IgniteInternalFuture<?> |
IgfsEx.awaitDeletesAsync()
Asynchronously await for all entries existing in trash to be removed.
|
IgniteInternalFuture<?> |
IgfsImpl.awaitDeletesAsync()
Asynchronously await for all entries existing in trash to be removed.
|
IgfsSecondaryOutputStreamDescriptor |
IgfsMetaManager.createDual(IgfsSecondaryFileSystem fs,
IgfsPath path,
boolean simpleCreate,
Map<String,String> props,
boolean overwrite,
int bufSize,
short replication,
long blockSize,
IgniteUuid affKey)
Create the file in DUAL mode.
|
IgniteInternalFuture<byte[]> |
IgfsDataManager.dataBlock(IgfsFileInfo fileInfo,
IgfsPath path,
long blockIdx,
IgfsSecondaryFileSystemPositionedReadable secReader)
Get data block for specified file ID and block index.
|
protected IgniteInternalFuture<byte[]> |
IgfsInputStreamImpl.dataBlock(IgfsFileInfo fileInfo,
long blockIdx)
Get data block for specified block index.
|
boolean |
IgfsMetaManager.deleteDual(IgfsSecondaryFileSystem fs,
IgfsPath path,
boolean recursive)
Delete path in DUAL mode.
|
void |
IgfsFileMap.deleteRange(IgfsFileAffinityRange range)
Deletes range from map.
|
Map<String,IgfsListingEntry> |
IgfsMetaManager.directoryListing(IgniteUuid fileId)
List child files for specified file ID.
|
void |
IgfsFileWorkerTask.execute()
Execute task logic.
|
boolean |
IgfsMetaManager.exists(IgniteUuid fileId)
Ensure that entry with the given ID exists in meta cache.
|
IgfsFileInfo |
IgfsMetaManager.fileForFragmentizer(Collection<IgniteUuid> exclude)
Gets first available file info for fragmentizer.
|
IgniteUuid |
IgfsMetaManager.fileId(IgfsPath path)
Gets file ID for specified path.
|
IgniteUuid |
IgfsMetaManager.fileId(IgniteUuid parentId,
String fileName)
Gets file ID by its name from parent directory listing.
|
List<IgniteUuid> |
IgfsMetaManager.fileIds(IgfsPath path)
Gets all file IDs for components of specified path.
|
void |
IgfsAckMessage.finishUnmarshal(Marshaller marsh,
ClassLoader ldr) |
void |
IgfsDeleteMessage.finishUnmarshal(Marshaller marsh,
ClassLoader ldr) |
void |
IgfsCommunicationMessage.finishUnmarshal(Marshaller marsh,
ClassLoader ldr) |
void |
IgfsAsyncImpl.globalSampling(Boolean val)
Enables, disables or clears sampling flag.
|
void |
IgfsEx.globalSampling(Boolean val)
Enables, disables or clears sampling flag.
|
void |
IgfsImpl.globalSampling(Boolean val)
Enables, disables or clears sampling flag.
|
IgfsStatus |
IgfsAsyncImpl.globalSpace()
Gets global space counters.
|
IgfsStatus |
IgfsEx.globalSpace()
Gets global space counters.
|
IgfsFileInfo |
IgfsMetaManager.info(IgniteUuid fileId)
Gets file info by its ID.
|
Map<IgniteUuid,IgfsFileInfo> |
IgfsMetaManager.infos(Collection<IgniteUuid> fileIds)
Gets files details by their IDs.
|
List<Long> |
IgfsDataManager.listLocalDataBlocks(IgfsFileInfo fileInfo)
Get list of local data blocks of the given file.
|
IgfsFileInfo |
IgfsMetaManager.lock(IgniteUuid fileId)
Lock the file explicitly outside of transaction.
|
IgfsFileInfo |
IgfsMetaManager.lockInfo(IgfsFileInfo info)
Set lock on file info.
|
boolean |
IgfsMetaManager.mkdirsDual(IgfsSecondaryFileSystem fs,
IgfsPath path,
Map<String,String> props)
Create directory in DUAL mode.
|
void |
IgfsMetaManager.move(IgniteUuid fileId,
String srcFileName,
IgniteUuid srcParentId,
String destFileName,
IgniteUuid destParentId)
Move or rename file.
|
void |
IgfsProcessor.onKernalStart()
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
void |
IgfsManager.onKernalStart() |
protected void |
IgfsMetaManager.onKernalStart0() |
protected void |
IgfsManager.onKernalStart0() |
protected void |
IgfsDataManager.onKernalStart0() |
protected void |
IgfsFragmentizerManager.onKernalStart0() |
protected void |
IgfsServerManager.onKernalStart0() |
IgfsSecondaryInputStreamDescriptor |
IgfsMetaManager.openDual(IgfsSecondaryFileSystem fs,
IgfsPath path,
int bufSize)
Open file in DUAL mode.
|
Collection<IgniteUuid> |
IgfsMetaManager.pendingDeletes()
Check whether there are any pending deletes and return collection of pending delete entry IDs.
|
void |
IgfsAckMessage.prepareMarshal(Marshaller marsh) |
void |
IgfsDeleteMessage.prepareMarshal(Marshaller marsh) |
void |
IgfsCommunicationMessage.prepareMarshal(Marshaller marsh) |
IgniteUuid |
IgfsMetaManager.putIfAbsent(IgniteUuid parentId,
String fileName,
IgfsFileInfo newFileInfo)
Add file into file system structure.
|
IgfsFileInfo |
IgfsMetaManager.removeIfEmpty(IgniteUuid parentId,
String fileName,
IgniteUuid fileId,
IgfsPath path,
boolean rmvLocked)
Remove file from the file system structure.
|
boolean |
IgfsMetaManager.renameDual(IgfsSecondaryFileSystem fs,
IgfsPath src,
IgfsPath dest)
Rename path in DUAL mode.
|
Boolean |
IgfsMetaManager.sampling()
Get sampling flag state.
|
boolean |
IgfsMetaManager.sampling(Boolean val)
Set sampling flag.
|
void |
IgfsContext.send(ClusterNode node,
Object topic,
IgfsCommunicationMessage msg,
GridIoPolicy plc) |
void |
IgfsContext.send(UUID nodeId,
Object topic,
IgfsCommunicationMessage msg,
GridIoPolicy plc) |
void |
IgfsProcessor.start()
Starts grid component.
|
void |
IgfsServer.start()
Starts this server.
|
void |
IgfsManager.start(IgfsContext igfsCtx)
Called when IGFS processor is started.
|
protected void |
IgfsMetaManager.start0()
Start manager implementation.
|
protected void |
IgfsManager.start0()
Start manager implementation.
|
protected void |
IgfsDataManager.start0()
Start manager implementation.
|
protected void |
IgfsFragmentizerManager.start0()
Start manager implementation.
|
protected void |
IgfsServerManager.start0()
Start manager implementation.
|
void |
IgfsServerHandler.stop()
Stops handling of incoming requests.
|
byte[] |
IgfsDataManager.storeDataBlocks(IgfsFileInfo fileInfo,
long reservedLen,
byte[] remainder,
int remainderLen,
ByteBuffer data,
boolean flush,
IgfsFileAffinityRange affinityRange,
IgfsFileWorkerBatch batch)
Store data blocks in file.
|
byte[] |
IgfsDataManager.storeDataBlocks(IgfsFileInfo fileInfo,
long reservedLen,
byte[] remainder,
int remainderLen,
DataInput in,
int len,
boolean flush,
IgfsFileAffinityRange affinityRange,
IgfsFileWorkerBatch batch)
Store data blocks in file.
|
IgfsFileInfo |
IgfsMetaManager.synchronizeFileDual(IgfsSecondaryFileSystem fs,
IgfsPath path)
Synchronizes with secondary file system.
|
void |
IgfsMetaManager.unlock(IgfsFileInfo info,
long modificationTime)
Remove explicit lock on file held by the current thread.
|
IgfsFileInfo |
IgfsMetaManager.updateDual(IgfsSecondaryFileSystem fs,
IgfsPath path,
Map<String,String> props)
Update path in DUAL mode.
|
IgfsFileInfo |
IgfsMetaManager.updateInfo(IgniteUuid fileId,
IgniteClosure<IgfsFileInfo,IgfsFileInfo> c)
Update file info in cache.
|
IgfsFileInfo |
IgfsMetaManager.updateProperties(IgniteUuid parentId,
IgniteUuid fileId,
String fileName,
Map<String,String> props)
Update file info (file properties) in cache.
|
void |
IgfsFileMap.updateRangeStatus(IgfsFileAffinityRange range,
int status)
Updates range status in file map.
|
void |
IgfsMetaManager.updateTimes(IgniteUuid parentId,
IgniteUuid fileId,
String fileName,
long accessTime,
long modificationTime)
Updates last access and last modification times.
|
void |
IgfsNoopHelper.validateCacheConfiguration(CacheConfiguration cfg)
Validate cache configuration for IGFS.
|
void |
IgfsHelperImpl.validateCacheConfiguration(CacheConfiguration cfg)
Validate cache configuration for IGFS.
|
void |
IgfsHelper.validateCacheConfiguration(CacheConfiguration cfg)
Validate cache configuration for IGFS.
|
| Constructor and Description |
|---|
IgfsAckMessage(IgniteUuid fileId,
long id,
IgniteCheckedException err) |
IgfsDeleteMessage(IgniteUuid id,
IgniteCheckedException err)
Constructor.
|
| Constructor and Description |
|---|
IgfsContext(GridKernalContext ctx,
FileSystemConfiguration cfg,
IgfsMetaManager metaMgr,
IgfsDataManager dataMgr,
IgfsServerManager srvMgr,
IgfsFragmentizerManager fragmentizerMgr) |
| Modifier and Type | Method and Description |
|---|---|
Collection<ComputeJobSibling> |
GridJobProcessor.requestJobSiblings(ComputeTaskSession 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.
|
void |
GridOffHeapProcessor.enableEviction(String spaceName,
int part,
Object key,
byte[] keyBytes)
Enables eviction for entry after
GridOffHeapProcessor.valuePointer(java.lang.String, int, java.lang.Object, byte[]) was called. |
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.
|
IgniteBiTuple<Long,Integer> |
GridOffHeapProcessor.valuePointer(String spaceName,
int part,
Object key,
byte[] keyBytes)
Gets value pointer from offheap space for the given key.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgnitePluginProcessor.start()
Starts 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 |
GridQueryProcessor.initializeCache(CacheConfiguration<?,?> ccfg) |
void |
GridQueryProcessor.onCacheStart(GridCacheContext cctx) |
void |
GridQueryIndexing.onSwap(String spaceName,
Object key)
Will be called when entry with given key is swapped.
|
void |
GridQueryProcessor.onSwap(String spaceName,
Object key)
Will be called when entry for key will be swapped.
|
void |
GridQueryProcessor.onUndeploy(String space,
ClassLoader ldr)
Removes index tables for all classes belonging to given class loader.
|
void |
GridQueryIndexing.onUnswap(String spaceName,
Object key,
Object val,
byte[] valBytes)
Will be called when entry with given key is unswapped.
|
void |
GridQueryProcessor.onUnswap(String spaceName,
Object key,
Object val,
byte[] valBytes)
Will be called when entry for key will be unswapped.
|
<K,V> GridCloseableIterator<IgniteBiTuple<K,V>> |
GridQueryIndexing.query(String spaceName,
String qry,
Collection<Object> params,
GridQueryTypeDescriptor type,
IndexingQueryFilter filters)
Executes regular query.
|
<K,V> GridCloseableIterator<IgniteBiTuple<K,V>> |
GridQueryProcessor.query(String space,
String clause,
Collection<Object> params,
String resType,
IndexingQueryFilter filters) |
GridQueryFieldsResult |
GridQueryIndexing.queryFields(String spaceName,
String qry,
Collection<Object> params,
IndexingQueryFilter filters)
Queries individual fields (generally used by JDBC drivers).
|
<K,V> GridQueryFieldsResult |
GridQueryProcessor.queryFields(String space,
String clause,
Collection<Object> params,
IndexingQueryFilter filters) |
<K,V> GridCloseableIterator<IgniteBiTuple<K,V>> |
GridQueryIndexing.queryText(String spaceName,
String qry,
GridQueryTypeDescriptor type,
IndexingQueryFilter filters)
Executes text query.
|
<K,V> GridCloseableIterator<IgniteBiTuple<K,V>> |
GridQueryProcessor.queryText(String space,
String clause,
String resType,
IndexingQueryFilter filters) |
void |
GridQueryIndexing.registerCache(CacheConfiguration<?,?> ccfg)
Registers cache.
|
boolean |
GridQueryIndexing.registerType(String spaceName,
GridQueryTypeDescriptor desc)
Registers type if it was not known before or updates it otherwise.
|
void |
GridQueryIndexing.remove(String spaceName,
Object key,
Object val)
Removes index entry by key.
|
void |
GridQueryProcessor.remove(String space,
Object key,
Object val) |
long |
GridQueryProcessor.size(String space,
Class<?> valType)
Returns number of objects of given type for given space of spi.
|
long |
GridQueryIndexing.size(String spaceName,
GridQueryTypeDescriptor desc,
IndexingQueryFilter filters)
Gets size of index for given type or -1 if it is a unknown type.
|
void |
GridQueryProcessor.start()
Starts grid component.
|
void |
GridQueryIndexing.start(GridKernalContext ctx)
Starts indexing.
|
void |
GridQueryIndexing.stop()
Stops indexing.
|
void |
GridQueryProcessor.stop(boolean cancel)
Stops grid component.
|
void |
GridQueryIndexing.store(String spaceName,
GridQueryTypeDescriptor type,
Object key,
Object val,
byte[] ver,
long expirationTime)
Updates index.
|
<K,V> void |
GridQueryProcessor.store(String space,
K key,
byte[] keyBytes,
V val,
byte[] valBytes,
byte[] ver,
long expirationTime)
Writes key-value pair to index.
|
GridQueryTypeDescriptor |
GridQueryProcessor.type(String space,
String typeName)
Gets type descriptor for space and type name.
|
void |
GridQueryIndexing.unregisterCache(CacheConfiguration<?,?> ccfg)
Deregisters cache.
|
void |
GridQueryIndexing.unregisterType(String spaceName,
GridQueryTypeDescriptor type)
Unregisters type and removes all corresponding data.
|
<T> T |
GridQueryTypeDescriptor.value(String field,
Object key,
Object val)
Gets field value for given key and value.
|
| Constructor and Description |
|---|
GridQueryProcessor(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
Collection<GridCacheSqlQuery> |
GridQueryRequest.queries(Marshaller m) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridResourceProcessor.cleanup(IgniteSpi spi)
Cleans up resources from given SPI implementation.
|
void |
GridResourceProcessor.cleanup(LifecycleBean lifecycleBean)
Cleans up resources from given lifecycle beans.
|
void |
GridResourceProcessor.cleanup(Service svc)
Cleans up resources from given service.
|
void |
GridResourceProcessor.cleanupGeneric(Object obj) |
void |
GridResourceProcessor.inject(GridDeployment dep,
Class<?> taskCls,
ComputeJob job,
ComputeTaskSession 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,
ComputeTask<?,?> task,
GridTaskSessionImpl ses,
ComputeLoadBalancer balancer,
ComputeTaskContinuousMapper mapper)
Injects held resources into given grid task.
|
void |
GridResourceLoggerInjector.inject(org.apache.ignite.internal.processors.resource.GridResourceField field,
Object target,
Class<?> depCls,
GridDeployment dep)
Injects resource into field.
|
void |
GridResourceJobContextInjector.inject(org.apache.ignite.internal.processors.resource.GridResourceField field,
Object target,
Class<?> depCls,
GridDeployment dep)
Injects resource into field.
|
void |
GridResourceServiceInjector.inject(org.apache.ignite.internal.processors.resource.GridResourceField field,
Object target,
Class<?> depCls,
GridDeployment dep)
Injects resource into field.
|
void |
GridResourceLoggerInjector.inject(org.apache.ignite.internal.processors.resource.GridResourceMethod mtd,
Object target,
Class<?> depCls,
GridDeployment dep)
Injects resource with a setter method.
|
void |
GridResourceJobContextInjector.inject(org.apache.ignite.internal.processors.resource.GridResourceMethod mtd,
Object target,
Class<?> depCls,
GridDeployment dep)
Injects resource with a setter method.
|
void |
GridResourceServiceInjector.inject(org.apache.ignite.internal.processors.resource.GridResourceMethod mtd,
Object target,
Class<?> depCls,
GridDeployment dep)
Injects resource with a setter method.
|
void |
GridResourceProcessor.inject(IgniteSpi spi)
Injects held resources into given SPI implementation.
|
void |
GridResourceProcessor.inject(LifecycleBean lifecycleBean)
Injects held resources into given lifecycle bean.
|
void |
GridResourceProcessor.inject(Service svc)
Injects resources into service.
|
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) |
boolean |
GridResourceProcessor.injectStoreSession(Object obj,
CacheStoreSession ses)
Injects cache store session into given object.
|
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 |
|---|---|
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) |
| 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.
|
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.
|
protected GridClientMessage |
GridTcpRestParser.parseClientMessage(GridNioSession ses,
GridTcpRestParser.ParserState state)
Parses
GridClientMessage from raw bytes. |
void |
GridTcpRestProtocol.start(GridRestProtocolHandler hnd)
Starts protocol.
|
| Modifier and Type | Method and Description |
|---|---|
SecurityContext |
GridSecurityProcessor.authenticate(AuthenticationContext ctx)
Authenticates subject via underlying Authenticator.
|
GridSecuritySubject |
GridSecurityProcessor.authenticatedSubject(UUID subjId)
Gets authenticated node subject.
|
Collection<GridSecuritySubject> |
GridSecurityProcessor.authenticatedSubjects()
Gets collection of authenticated nodes.
|
SecurityContext |
GridSecurityProcessor.authenticateNode(ClusterNode node,
GridSecurityCredentials cred)
Authenticates grid node with it's attributes via underlying Authenticator.
|
| Modifier and Type | Method and Description |
|---|---|
SecurityContext |
GridOsSecurityProcessor.authenticate(AuthenticationContext authCtx)
Authenticates subject via underlying Authenticator.
|
SecurityContext |
GridOsSecurityProcessor.authenticateNode(ClusterNode node,
GridSecurityCredentials cred)
Authenticates grid node with it's attributes via underlying Authenticator.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridServiceNotFoundException
Exception thrown if service is not found.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridServiceProcessor.onKernalStart()
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
void |
GridServiceProcessor.start()
Starts grid component.
|
| 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 |
|---|---|
void |
GridTaskProcessor.onKernalStart()
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
void |
GridTaskProcessor.setAttributes(GridTaskSessionImpl ses,
Map<?,?> attrs) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridTimeoutProcessor.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IgniteTxHeuristicCheckedException
Exception thrown whenever grid transaction enters an unknown state.
|
class |
IgniteTxOptimisticCheckedException
Exception thrown whenever grid transactions fail optimistically.
|
class |
IgniteTxRollbackCheckedException
Exception thrown whenever grid transactions has been automatically rolled back.
|
class |
IgniteTxTimeoutCheckedException
Exception thrown whenever grid transactions time out.
|
| Modifier and Type | Method and Description |
|---|---|
static IgniteCheckedException |
IgniteUtils.cast(Throwable t)
Casts this throwable as
IgniteCheckedException. |
static IgniteCheckedException |
IgniteUtils.exceptionWithSuppressed(String msg,
Collection<Throwable> suppressed)
Creates
IgniteCheckedException with the collection of suppressed exceptions. |
| Modifier and Type | Method and Description |
|---|---|
static C1<IgniteCheckedException,IgniteException> |
IgniteUtils.getExceptionConverter(Class<? extends IgniteCheckedException> clazz)
Gets IgniteClosure for an IgniteCheckedException class.
|
| Modifier and Type | Method and Description |
|---|---|
static IgniteException |
IgniteUtils.convertException(IgniteCheckedException e) |
static Exception |
IgniteUtils.convertExceptionNoWrap(IgniteCheckedException e)
Converts exception, but unlike
IgniteUtils.convertException(IgniteCheckedException)
does not wrap passed in exception if none suitable converter found. |
| Modifier and Type | Method and Description |
|---|---|
static C1<IgniteCheckedException,IgniteException> |
IgniteUtils.getExceptionConverter(Class<? extends IgniteCheckedException> clazz)
Gets IgniteClosure for an IgniteCheckedException class.
|
| Modifier and Type | Method and Description |
|---|---|
T |
GridCircularBuffer.add(T t,
IgniteInClosureX<T> c) |
static IgniteBiTuple<Object,Object> |
IgniteUtils.addLog4jNoOpLogger()
Adds no-op logger to remove no-appender warning.
|
void |
GridWeakIterator.close()
Closes iterator.
|
void |
GridCloseableIteratorAdapterEx.close()
Closes the iterator and frees all the resources held by the iterator.
|
void |
GridCloseableIteratorAdapter.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[] |
IgniteUtils.decodeHex(char[] data)
Converts an array of characters representing hexidecimal values into an
array of bytes of those same values.
|
static <T> T |
IgniteUtils.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<?> |
IgniteUtils.forceEmptyConstructor(Class<?> cls)
Gets empty constructor for class even if the class does not have empty constructor
declared.
|
static <T> T |
IgniteUtils.forceNewInstance(Class<?> cls)
Creates new instance of a class even if it does not have public constructor.
|
static <T> T |
IgniteUtils.get(Future<T> fut)
Gets result from the given future with right exception handling.
|
boolean |
GridCloseableIteratorAdapterEx.hasNextX()
This method is the same as
Iterator.hasNext(), but allows for failure
with exception. |
boolean |
GridCloseableIteratorAdapter.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 |
IgniteUtils.invoke(Class<?> cls,
Object obj,
String mtdName,
Class[] paramTypes,
Object... params)
Invokes method.
|
static <T> T |
IgniteUtils.invoke(Class<?> cls,
Object obj,
String mtdName,
Object... params)
Invokes method.
|
static <T> T |
IgniteUtils.newInstance(Class<T> cls)
Creates new instance of a class only if it has an empty constructor (can be non-public).
|
static <T> T |
IgniteUtils.newInstance(String cls)
Creates new instance of a class only if it has an empty constructor (can be non-public).
|
T |
GridCloseableIteratorAdapterEx.nextX()
This method is the same as
Iterator.next(), but allows for failure
with exception. |
T |
GridCloseableIteratorAdapter.nextX()
This method is the same as
Iterator.next(), but allows for failure
with exception. |
protected void |
GridSpiCloseableIteratorWrapper.onClose()
Invoked on iterator close.
|
protected void |
GridCloseableIteratorAdapterEx.onClose()
Invoked on iterator close.
|
protected void |
GridCloseableIteratorAdapter.onClose()
Invoked on iterator close.
|
protected boolean |
GridSpiCloseableIteratorWrapper.onHasNext() |
protected abstract boolean |
GridCloseableIteratorAdapterEx.onHasNext() |
protected abstract boolean |
GridCloseableIteratorAdapter.onHasNext() |
protected T |
GridSpiCloseableIteratorWrapper.onNext() |
protected abstract T |
GridCloseableIteratorAdapterEx.onNext() |
protected abstract T |
GridCloseableIteratorAdapter.onNext() |
protected void |
GridCloseableIteratorAdapterEx.onRemove()
Called on remove from iterator.
|
protected void |
GridCloseableIteratorAdapter.onRemove()
Called on remove from iterator.
|
static Calendar |
IgniteUtils.parseIsoDate(String str) |
static void |
IgniteUtils.removeLog4jNoOpLogger(IgniteBiTuple<Object,Object> t)
Removes previously added no-op logger via method
IgniteUtils.addLog4jNoOpLogger(). |
void |
GridCloseableIteratorAdapterEx.removeX()
This method is the same as
Iterator.remove(), but allows for failure
with exception. |
void |
GridCloseableIteratorAdapter.removeX()
This method is the same as
Iterator.remove(), but allows for failure
with exception. |
static IgniteBiTuple<Collection<String>,Collection<String>> |
IgniteUtils.resolveLocalAddresses(InetAddress locAddr)
Returns host names consistent with
IgniteUtils.resolveLocalHost(String). |
static URL |
IgniteUtils.resolveSpringUrl(String springCfgPath)
Resolve Spring configuration URL.
|
static File |
IgniteUtils.resolveWorkDirectory(String path,
boolean delIfExist)
Resolves work directory.
|
static void |
IgniteUtils.setWorkDirectory(String userWorkDir,
String userIgniteHome) |
static void |
IgniteUtils.startLifecycleAware(Iterable<?> objs)
For each object provided by the given
Iterable checks if it implements
LifecycleAware interface and executes LifecycleAware.start() method. |
static <T> T |
IgniteUtils.staticField(Class<?> cls,
String fieldName)
Gets static field value.
|
static int |
IgniteUtils.toDigit(char ch,
int idx)
Converts a hexadecimal character to an integer.
|
static Collection<InetAddress> |
IgniteUtils.toInetAddresses(ClusterNode node)
Returns tha list of resolved inet addresses.
|
static Collection<InetAddress> |
IgniteUtils.toInetAddresses(Collection<String> addrs,
Collection<String> hostNames)
Returns tha list of resolved inet addresses.
|
static <R> R |
IgniteUtils.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 |
GridEmbeddedFuture.cancel()
Default no-op implementation that always returns
false. |
boolean |
GridFutureAdapter.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.
|
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.
|
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.
|
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) |
| Modifier and Type | Method and Description |
|---|---|
GridifyRangeArgument |
GridifyArgumentBuilder.createTaskArgument(GridifyRangeArgument arg,
Collection<?> input)
Create
GridifyRangeArgument for task. |
| Modifier and Type | Class and Description |
|---|---|
class |
IpcEndpointBindException
Represents exception occurred during IPC endpoint binding.
|
| Modifier and Type | Method and Description |
|---|---|
IpcEndpoint |
IpcServerEndpoint.accept()
Accepts client IPC connection.
|
static IpcEndpoint |
IpcEndpointFactory.connectEndpoint(String endpointAddr,
IgniteLogger log)
Connects to open server IPC endpoint.
|
InputStream |
IpcEndpoint.inputStream()
Gets input stream associated with this IPC endpoint.
|
OutputStream |
IpcEndpoint.outputStream()
Gets output stream associated with this IPC endpoint.
|
void |
IpcServerEndpoint.start()
Starts configured endpoint implementation.
|
| Modifier and Type | Method and Description |
|---|---|
IpcEndpoint |
IpcServerTcpEndpoint.accept()
Accepts client IPC connection.
|
InputStream |
IpcClientTcpEndpoint.inputStream()
Gets input stream associated with this IPC endpoint.
|
OutputStream |
IpcClientTcpEndpoint.outputStream()
Gets output stream associated with this IPC endpoint.
|
void |
IpcServerTcpEndpoint.setupConfiguration(Map<String,String> endpointCfg)
Sets configuration properties from the map.
|
void |
IpcServerTcpEndpoint.start()
Starts configured endpoint implementation.
|
| Constructor and Description |
|---|
IpcClientTcpEndpoint(String host,
int port)
Creates and connects client IPC endpoint.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IpcOutOfSystemResourcesException
Thrown when IPC runs out of system resources (for example, no more free shared memory is
available in operating system).
|
class |
IpcSharedMemoryOperationTimedoutException
Thrown when IPC operation (such as
Object.wait(long))
has timed out. |
| Modifier and Type | Method and Description |
|---|---|
IpcEndpoint |
IpcSharedMemoryServerEndpoint.accept()
Accepts client IPC connection.
|
static void |
IpcSharedMemoryNativeLoader.load() |
int |
IpcSharedMemorySpace.read(byte[] buf,
int off,
int len,
long timeout)
Blocks until at least 1 byte is read.
|
int |
IpcSharedMemorySpace.read(ByteBuffer buf,
int off,
int len,
long timeout)
Blocks until at least 1 byte is read.
|
void |
IpcSharedMemoryServerEndpoint.setupConfiguration(Map<String,String> endpointCfg)
Sets configuration properties from the map.
|
void |
IpcSharedMemoryServerEndpoint.start()
Starts configured endpoint implementation.
|
int |
IpcSharedMemorySpace.unreadCount() |
void |
IpcSharedMemorySpace.write(byte[] buf,
int off,
int len,
long timeout) |
void |
IpcSharedMemorySpace.write(ByteBuffer buf,
int off,
int len,
long timeout) |
| Constructor and Description |
|---|
IpcSharedMemoryClientEndpoint(int port,
IgniteLogger parent)
Creates and connects client IPC endpoint and starts background checker thread to avoid deadlocks on other party
crash.
|
IpcSharedMemoryClientEndpoint(int port,
int timeout,
IgniteLogger parent)
Creates and connects client IPC endpoint and starts background checker thread to avoid deadlocks on other party
crash.
|
IpcSharedMemorySpace(String tokFileName,
int writerPid,
int readerPid,
int size,
boolean reader,
IgniteLogger parent)
This will allocate system resources for the space.
|
IpcSharedMemorySpace(String tokFileName,
int writerPid,
int readerPid,
int size,
boolean reader,
int shmemId,
IgniteLogger 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() |
void |
GridPlainInClosure.apply(T arg) |
R |
GridPlainClosure.apply(T arg) |
R |
GridPlainClosure2.apply(T1 arg1,
T2 arg2) |
abstract boolean |
GridAbsPredicateX.applyx()
Predicate body that can throw
IgniteCheckedException. |
abstract R |
IgniteReducer2X.applyx()
Reducer body that can throw
IgniteCheckedException. |
abstract T |
IgniteOutClosureX.applyx()
Out-closure body that can throw
IgniteCheckedException. |
abstract R |
IgniteReducerX.applyx()
Reducer body that can throw
IgniteCheckedException. |
abstract R |
IgniteReducer3X.applyx()
Reducer body that can throw
IgniteCheckedException. |
abstract void |
GridAbsClosureX.applyx()
Closure body that can throw
IgniteCheckedException. |
abstract R |
IgniteClosureX.applyx(E e)
Closure body that can throw
IgniteCheckedException. |
abstract boolean |
IgnitePredicateX.applyx(E1 e)
Predicate body that can throw
IgniteCheckedException. |
abstract boolean |
IgnitePredicate2X.applyx(E1 e1,
E2 e2)
Predicate body that can throw
IgniteCheckedException. |
abstract void |
IgniteInClosure2X.applyx(E1 e1,
E2 e2)
In-closure body that can throw
IgniteCheckedException. |
abstract R |
IgniteClosure2X.applyx(E1 e1,
E2 e2)
Closure body that can throw
IgniteCheckedException. |
abstract boolean |
GridPredicate3X.applyx(E1 e1,
E2 e2,
E3 e3)
Predicate body that can throw
IgniteCheckedException. |
abstract void |
GridInClosure3X.applyx(E1 e1,
E2 e2,
E3 e3)
In-closure body that can throw
IgniteCheckedException. |
abstract R |
GridClosure3X.applyx(E1 e1,
E2 e2,
E3 e3)
Closure body that can throw
IgniteCheckedException. |
abstract void |
IgniteInClosureX.applyx(T t)
In-closure body that can throw
IgniteCheckedException. |
static <T> void |
GridFunc.awaitAll(Collection<IgniteInternalFuture<T>> futs)
Waits until all passed futures will be executed.
|
static <T> void |
GridFunc.awaitAll(IgniteInternalFuture<T>... futs)
Waits until all passed futures will be executed.
|
static <T> void |
GridFunc.awaitAll(long timeout,
Collection<IgniteInternalFuture<T>> futs)
Waits until all passed futures will be executed.
|
static <T,R> R |
GridFunc.awaitAll(long timeout,
IgniteReducer<T,R> rdc,
Collection<IgniteInternalFuture<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.
|
boolean |
GridIterableAdapter.hasNextX()
This method is the same as
Iterator.hasNext(), but allows for failure
with exception. |
boolean |
GridIterator.hasNextX()
This method is the same as
Iterator.hasNext(), but allows for failure
with exception. |
T |
GridIterableAdapter.nextX()
This method is the same as
Iterator.next(), but allows for failure
with exception. |
T |
GridIterator.nextX()
This method is the same as
Iterator.next(), but allows for failure
with exception. |
void |
GridIterableAdapter.removeX()
This method is the same as
Iterator.remove(), but allows for failure
with exception. |
void |
GridIterator.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 |
GridConnectionBytesVerifyFilter.onExceptionCaught(GridNioSession ses,
IgniteCheckedException ex)
Invoked when exception is caught in filter processing.
|
void |
GridNioCodecFilter.onExceptionCaught(GridNioSession ses,
IgniteCheckedException ex)
Invoked when exception is caught in filter processing.
|
void |
GridNioAsyncNotifyFilter.onExceptionCaught(GridNioSession ses,
IgniteCheckedException ex)
Invoked when exception is caught in filter processing.
|
void |
GridNioFilter.onExceptionCaught(GridNioSession ses,
IgniteCheckedException ex)
Invoked when exception is caught in filter processing.
|
void |
GridNioFilterChain.onExceptionCaught(GridNioSession ses,
IgniteCheckedException e)
Starts chain notification from head to tail.
|
void |
GridNioFilterAdapter.proceedExceptionCaught(GridNioSession ses,
IgniteCheckedException e)
Forwards GridNioException event to the next logical filter in filter chain.
|
void |
GridNioFilter.proceedExceptionCaught(GridNioSession ses,
IgniteCheckedException 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.
|
Object |
GridNioParser.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.
|
byte[] |
GridBufferedParser.decode(GridNioSession ses,
ByteBuffer buf)
This method is called when input bytes are available on the underlying network connection.
|
void |
GridCommunicationClient.doHandshake(IgniteInClosure2X<InputStream,OutputStream> handshakeC)
Executes the given handshake closure on opened client passing underlying IO streams.
|
void |
GridTcpNioCommunicationClient.doHandshake(IgniteInClosure2X<InputStream,OutputStream> handshakeC)
Executes the given handshake closure on opened client passing underlying IO streams.
|
void |
GridTcpCommunicationClient.doHandshake(IgniteInClosure2X<InputStream,OutputStream> handshakeC)
Executes the given handshake closure on opened client passing underlying IO streams.
|
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.
|
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 |
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.
|
void |
GridConnectionBytesVerifyFilter.onExceptionCaught(GridNioSession ses,
IgniteCheckedException ex)
Invoked when exception is caught in filter processing.
|
void |
GridNioCodecFilter.onExceptionCaught(GridNioSession ses,
IgniteCheckedException ex)
Invoked when exception is caught in filter processing.
|
void |
GridNioAsyncNotifyFilter.onExceptionCaught(GridNioSession ses,
IgniteCheckedException ex)
Invoked when exception is caught in filter processing.
|
void |
GridNioFilter.onExceptionCaught(GridNioSession ses,
IgniteCheckedException ex)
Invoked when exception is caught in filter processing.
|
void |
GridConnectionBytesVerifyFilter.onMessageReceived(GridNioSession ses,
Object msg)
Invoked when a new messages received.
|
void |
GridNioCodecFilter.onMessageReceived(GridNioSession ses,
Object msg)
Invoked when a new messages received.
|
void |
GridNioAsyncNotifyFilter.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 |
GridNioFilterChain.onMessageReceived(GridNioSession ses,
Object msg)
Starts chain notification from head to tail.
|
GridNioFuture<?> |
GridNioFilterAdapter.onPauseReads(GridNioSession ses)
Pauses reads for session.
|
GridNioFuture<?> |
GridNioFilter.onPauseReads(GridNioSession ses)
Pauses reads for session.
|
GridNioFuture<?> |
GridNioFilterChain.onPauseReads(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<?> |
GridNioFilterChain.onResumeReads(GridNioSession ses)
Starts chain notification from tail to head.
|
GridNioFuture<Boolean> |
GridConnectionBytesVerifyFilter.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.
|
GridNioFuture<Boolean> |
GridNioAsyncNotifyFilter.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> |
GridNioFilterChain.onSessionClose(GridNioSession ses)
Starts chain notification from tail to head.
|
void |
GridConnectionBytesVerifyFilter.onSessionClosed(GridNioSession ses)
Invoked after session get closed.
|
void |
GridNioCodecFilter.onSessionClosed(GridNioSession ses)
Invoked after session get closed.
|
void |
GridNioAsyncNotifyFilter.onSessionClosed(GridNioSession ses)
Invoked after session get closed.
|
void |
GridNioFilter.onSessionClosed(GridNioSession ses)
Invoked after session get closed.
|
void |
GridNioFilterChain.onSessionClosed(GridNioSession ses)
Starts chain notification from head to tail.
|
void |
GridConnectionBytesVerifyFilter.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 |
GridNioAsyncNotifyFilter.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 |
GridNioFilterChain.onSessionIdleTimeout(GridNioSession ses)
Called when session is idle for longer time that is
allowed by NIO server.
|
void |
GridConnectionBytesVerifyFilter.onSessionOpened(GridNioSession ses)
Invoked when a new session was created.
|
void |
GridNioCodecFilter.onSessionOpened(GridNioSession ses)
Invoked when a new session was created.
|
void |
GridNioAsyncNotifyFilter.onSessionOpened(GridNioSession ses)
Invoked when a new session was created.
|
void |
GridNioFilter.onSessionOpened(GridNioSession ses)
Invoked when a new session was created.
|
void |
GridNioFilterChain.onSessionOpened(GridNioSession ses)
Starts chain notification from head to tail.
|
GridNioFuture<?> |
GridConnectionBytesVerifyFilter.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.
|
GridNioFuture<?> |
GridNioAsyncNotifyFilter.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<?> |
GridNioFilterChain.onSessionWrite(GridNioSession ses,
Object msg)
Starts chain notification from tail to head.
|
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 |
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 |
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 |
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 |
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 |
GridNioFilterAdapter.proceedExceptionCaught(GridNioSession ses,
IgniteCheckedException e)
Forwards GridNioException event to the next logical filter in filter chain.
|
void |
GridNioFilter.proceedExceptionCaught(GridNioSession ses,
IgniteCheckedException 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 |
GridTcpCommunicationClient.sendMessage(byte[] data,
int len) |
void |
GridCommunicationClient.sendMessage(ByteBuffer data) |
void |
GridTcpNioCommunicationClient.sendMessage(ByteBuffer data) |
void |
GridTcpCommunicationClient.sendMessage(ByteBuffer data) |
boolean |
GridCommunicationClient.sendMessage(UUID nodeId,
Message msg) |
boolean |
GridTcpNioCommunicationClient.sendMessage(UUID nodeId,
Message msg) |
boolean |
GridTcpCommunicationClient.sendMessage(UUID nodeId,
Message msg) |
| Constructor and Description |
|---|
GridTcpCommunicationClient(GridNioMetricsListener metricsLsnr,
InetSocketAddress addr,
InetAddress locHost,
long connTimeout,
boolean tcpNoDelay,
int sockRcvBuf,
int sockSndBuf,
int bufSize,
int minBufferedMsgCnt,
double bufSizeRatio,
MessageFormatter formatter) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNioSslFilter.onExceptionCaught(GridNioSession ses,
IgniteCheckedException ex)
Invoked when exception is caught in filter processing.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridNioSslFilter.onExceptionCaught(GridNioSession ses,
IgniteCheckedException 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> |
IgniteNodeStartUtils.expandHost(String addr)
Parses and expands range of IPs, if needed.
|
static IgniteBiTuple<Collection<Map<String,Object>>,Map<String,Object>> |
IgniteNodeStartUtils.parseFile(File file)
Parses INI file.
|
static Map<String,Collection<IgniteRemoteStartSpecification>> |
IgniteNodeStartUtils.specifications(Collection<Map<String,Object>> hosts,
Map<String,Object> dflts)
Makes specifications.
|
| Modifier and Type | Method and Description |
|---|---|
<T> T |
IgniteSpringHelper.loadBean(URL url,
String beanName)
Loads bean instance by name.
|
Map<Class<?>,Object> |
IgniteSpringHelper.loadBeans(URL cfgUrl,
Class<?>... beanClasses)
Loads bean instances that match the given types from given configuration file.
|
<T> IgniteBiTuple<Collection<T>,? extends GridSpringResourceContext> |
IgniteSpringHelper.loadConfigurations(URL cfgUrl,
Class<T> cl,
String... excludedProps)
Loads all configurations with given type specified within given configuration file.
|
IgniteBiTuple<Collection<IgniteConfiguration>,? extends GridSpringResourceContext> |
IgniteSpringHelper.loadConfigurations(URL cfgUrl,
String... excludedProps)
Loads all grid configurations specified within given configuration file.
|
| Modifier and Type | Method and Description |
|---|---|
static String |
X.resolveIgniteHome()
Tries to resolve Ignite installation home folder.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
static VisorCache |
VisorCache.from(Ignite ignite,
String cacheName,
int sample) |
| Modifier and Type | Method and Description |
|---|---|
static IgniteBiTuple<List<Object[]>,Map.Entry<Object,Object>> |
VisorQueryUtils.fetchScanQueryRows(CacheQueryFuture<Map.Entry<Object,Object>> fut,
Map.Entry<Object,Object> savedNext,
int pageSize)
Fetch rows from SCAN query future.
|
static IgniteBiTuple<List<Object[]>,List<?>> |
VisorQueryUtils.fetchSqlQueryRows(CacheQueryFuture<List<?>> fut,
List<?> savedNext,
int pageSize)
Collects rows from sql query future, first time creates meta and column names arrays.
|
| Modifier and Type | Method and Description |
|---|---|
static Path |
VisorTaskUtils.resolveIgfsProfilerLogsDir(IgniteFileSystem igfs)
Resolve IGFS profiler logs directory.
|
| Modifier and Type | Method and Description |
|---|---|
void |
JavaLoggerFileHandler.nodeId(UUID nodeId)
Sets Node id and instantiates
FileHandler delegate. |
| Modifier and Type | Method and Description |
|---|---|
byte[] |
AbstractMarshaller.marshal(Object obj)
Marshals object to byte array.
|
byte[] |
Marshaller.marshal(Object obj)
Marshals object to byte array.
|
void |
Marshaller.marshal(Object obj,
OutputStream out)
Marshals object to the output stream.
|
boolean |
MarshallerContext.registerClass(int id,
Class cls)
Registers class with provided type ID.
|
<T> T |
AbstractMarshaller.unmarshal(byte[] arr,
ClassLoader clsLdr)
Unmarshals object from byte array using given class loader.
|
<T> T |
Marshaller.unmarshal(byte[] arr,
ClassLoader clsLdr)
Unmarshals object from byte array using given class loader.
|
<T> T |
Marshaller.unmarshal(InputStream in,
ClassLoader clsLdr)
Unmarshals object from the output stream using given class loader.
|
| Modifier and Type | Method and Description |
|---|---|
void |
JdkMarshaller.marshal(Object obj,
OutputStream out)
Marshals object to the output stream.
|
<T> T |
JdkMarshaller.unmarshal(InputStream in,
ClassLoader clsLdr)
Unmarshals object from the output stream using given class loader.
|
| Modifier and Type | Method and Description |
|---|---|
byte[] |
OptimizedMarshaller.marshal(Object obj)
Marshals object to byte array.
|
void |
OptimizedMarshaller.marshal(Object obj,
OutputStream out)
Marshals object to the output stream.
|
<T> T |
OptimizedMarshaller.unmarshal(byte[] arr,
ClassLoader clsLdr)
Unmarshals object from byte array using given class loader.
|
<T> T |
OptimizedMarshaller.unmarshal(InputStream in,
ClassLoader clsLdr)
Unmarshals object from the output stream using given class loader.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PluginProvider.onIgniteStart()
Callback that notifies that Ignite has successfully started,
including all internal components.
|
void |
PluginProvider.start(PluginContext ctx)
Starts grid component.
|
void |
PluginProvider.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
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 | Method and Description |
|---|---|
void |
IgniteSpiCloseableIterator.close()
Closes the iterator and frees all the resources held by the iterator.
|
| Modifier and Type | Method and Description |
|---|---|
protected GridCommunicationClient |
TcpCommunicationSpi.createNioClient(ClusterNode node) |
protected GridCommunicationClient |
TcpCommunicationSpi.createTcpClient(ClusterNode node)
Establish TCP connection to remote node and returns client.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.0.0 Release Date : March 31 2015