| 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 | Class and Description |
|---|---|
class |
QueryCancelledException
The exception is thrown if a query was cancelled or timed out while executing.
|
| 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 |
GridifySetToSetAbstractAspect.checkMethodSignature(Method mtd)
Check method signature.
|
protected void |
GridifySetToValueAbstractAspect.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.
|
Collection<InetSocketAddress> |
BasicAddressResolver.getExternalAddresses(InetSocketAddress addr)
Maps internal address to a collection of external addresses.
|
| Modifier and Type | Method and Description |
|---|---|
HadoopMapReducePlan |
HadoopMapReducePlanner.preparePlan(HadoopJob job,
Collection<ClusterNode> top,
HadoopMapReducePlan oldPlan)
Prepares map-reduce execution plan for the given job and topology.
|
| 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 |
IgniteClientDisconnectedCheckedException |
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. |
class |
IgniteNeedReconnectException
Indicates that node should try reconnect to cluster.
|
class |
NodeStoppingException |
| 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 |
ComputeTaskInternalFuture.cancel()
Default no-op implementation that always returns
false. |
boolean |
IgniteInternalFuture.cancel()
Cancels this future.
|
<T> T |
IgniteComponentType.create(boolean noOp)
Creates component.
|
<T> T |
IgniteComponentType.create(GridKernalContext ctx,
boolean noOp)
Creates component.
|
<T> T |
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.
|
Class |
MarshallerContextImpl.getClass(int typeId,
ClassLoader ldr)
Gets class for provided type ID.
|
String |
MarshallerContextImpl.getClassName(byte platformId,
int typeId)
Gets class name for provided (platformId, typeId) pair.
|
R |
IgniteInternalFuture.getUninterruptibly()
Synchronously waits for completion of the computation and returns computation result ignoring interrupts.
|
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(InputStream springCfgStream)
Loads all grid configurations specified within given input stream.
|
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(InputStream springXmlStream,
String beanName)
Loads spring bean by name.
|
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.
|
MessageFactory |
IgniteComponentType.messageFactory()
Creates message factory for the component.
|
void |
GridComponent.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
void |
GridComponent.onKernalStart(boolean activeOnStart)
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
void |
GridPluginComponent.onKernalStart(boolean activeOnStart)
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
void |
MarshallerContextImpl.onMarshallerProcessorStarted(GridKernalContext ctx,
MarshallerMappingTransport transport) |
IgniteInternalFuture<?> |
GridComponent.onReconnected(boolean clusterRestarted)
Client reconnected callback.
|
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 |
MarshallerContextImpl.registerClassName(byte platformId,
int typeId,
String clsName)
Registers class with provided type ID.
|
<R> R |
AsyncSupportAdapter.saveOrGet(IgniteInternalFuture<R> fut) |
static Ignite |
IgnitionEx.start()
Starts grid with default configuration.
|
void |
GridComponent.start(boolean activeOnStart)
Starts grid component.
|
void |
GridPluginComponent.start(boolean activeOnStart)
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.
|
static Ignite |
IgnitionEx.start(IgniteConfiguration cfg,
boolean failIfStarted)
Starts a grid with given configuration.
|
void |
IgniteKernal.start(IgniteConfiguration cfg,
ExecutorService utilityCachePool,
ExecutorService execSvc,
ExecutorService svcExecSvc,
ExecutorService sysExecSvc,
StripedExecutor stripedExecSvc,
ExecutorService p2pExecSvc,
ExecutorService mgmtExecSvc,
ExecutorService igfsExecSvc,
ExecutorService dataStreamExecSvc,
ExecutorService restExecSvc,
ExecutorService affExecSvc,
ExecutorService idxExecSvc,
IgniteStripedThreadPoolExecutor callbackExecSvc,
ExecutorService qryExecSvc,
ExecutorService schemaExecSvc,
Map<String,? extends ExecutorService> customExecSvcs,
GridAbsClosure errHnd) |
static Ignite |
IgnitionEx.start(IgniteConfiguration cfg,
GridSpringResourceContext springCtx)
Starts grid with given configuration.
|
static T2<Ignite,Boolean> |
IgnitionEx.start(IgniteConfiguration cfg,
GridSpringResourceContext springCtx,
boolean failIfStarted)
Starts grid with given configuration.
|
static Ignite |
IgnitionEx.start(InputStream springCfgStream)
Starts all grids specified within given Spring XML configuration input stream.
|
static Ignite |
IgnitionEx.start(InputStream springCfgStream,
String igniteInstanceName,
GridSpringResourceContext springCtx,
ClassLoader ldr)
Starts all grids specified within given Spring XML configuration input stream.
|
static Ignite |
IgnitionEx.start(String springCfgPath)
Starts all grids specified within given Spring XML configuration file.
|
static Ignite |
IgnitionEx.start(String springCfgPath,
String igniteInstanceName)
Starts all grids specified within given Spring XML configuration file.
|
static Ignite |
IgnitionEx.start(String springCfgPath,
String igniteInstanceName,
GridSpringResourceContext springCtx,
ClassLoader ldr)
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,
ClassLoader ldr)
Starts all grids specified within given Spring XML configuration file URL.
|
static Ignite |
IgnitionEx.start(URL springCfgUrl,
String igniteInstanceName,
GridSpringResourceContext springCtx,
ClassLoader ldr)
Starts all grids specified within given Spring XML configuration file URL.
|
void |
GridComponent.stop(boolean cancel)
Stops grid component.
|
void |
GridPluginComponent.stop(boolean cancel)
Stops grid component.
|
void |
GridJobSiblingsResponse.unmarshalSiblings(Marshaller marsh) |
| Modifier and Type | Method and Description |
|---|---|
void |
BinaryObjectOffheapImpl.finishUnmarshal(CacheObjectContext ctx,
ClassLoader ldr) |
void |
BinaryObjectImpl.finishUnmarshal(CacheObjectContext ctx,
ClassLoader ldr) |
void |
BinaryEnumObjectImpl.finishUnmarshal(CacheObjectContext ctx,
ClassLoader ldr) |
protected byte[] |
BinaryMarshaller.marshal0(Object obj)
Marshals object to byte array.
|
protected void |
BinaryMarshaller.marshal0(Object obj,
OutputStream out)
Marshals object to the output stream.
|
void |
BinaryObjectOffheapImpl.prepareMarshal(CacheObjectContext ctx) |
void |
BinaryObjectImpl.prepareMarshal(CacheObjectContext ctx) |
void |
BinaryEnumObjectImpl.prepareMarshal(CacheObjectContext ctx) |
boolean |
BinaryObjectOffheapImpl.putValue(ByteBuffer buf) |
boolean |
BinaryObjectImpl.putValue(ByteBuffer buf) |
boolean |
BinaryEnumObjectImpl.putValue(ByteBuffer buf) |
boolean |
BinaryObjectOffheapImpl.putValue(ByteBuffer buf,
int off,
int len) |
boolean |
BinaryObjectImpl.putValue(ByteBuffer buf,
int off,
int len) |
boolean |
BinaryEnumObjectImpl.putValue(ByteBuffer buf,
int off,
int len) |
int |
BinaryObjectOffheapImpl.putValue(long addr) |
int |
BinaryObjectImpl.putValue(long addr) |
int |
BinaryEnumObjectImpl.putValue(long addr) |
protected <T> T |
BinaryMarshaller.unmarshal0(byte[] bytes,
ClassLoader clsLdr)
Unmarshals object from byte array using given class loader.
|
protected <T> T |
BinaryMarshaller.unmarshal0(InputStream in,
ClassLoader clsLdr)
Unmarshals object from the input stream using given class loader.
|
byte[] |
BinaryObjectOffheapImpl.valueBytes(CacheObjectContext ctx) |
byte[] |
BinaryObjectImpl.valueBytes(CacheObjectContext ctx) |
byte[] |
BinaryEnumObjectImpl.valueBytes(CacheObjectContext cacheCtx) |
int |
BinaryObjectOffheapImpl.valueBytesLength(CacheObjectContext ctx) |
int |
BinaryObjectImpl.valueBytesLength(CacheObjectContext ctx) |
int |
BinaryEnumObjectImpl.valueBytesLength(CacheObjectContext ctx) |
| 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)
Serializes the message and sends it into the given output stream.
|
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. |
protected void |
GridManagerAdapter.inject()
Injects resources to SPI.
|
void |
GridManagerAdapter.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
void |
GridManagerAdapter.onKernalStart(boolean activeOnStart)
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
protected void |
GridManagerAdapter.onKernalStart0() |
IgniteInternalFuture<?> |
GridManagerAdapter.onReconnected(boolean clusterRestarted)
Client reconnected callback.
|
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(boolean activeOnStart)
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(boolean activeOnStart)
Starts grid component.
|
void |
GridCollisionManager.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridIoManager.onKernalStart0() |
void |
GridIoManager.sendGeneric(ClusterNode node,
Object topic,
int topicOrd,
Message msg,
byte plc) |
void |
GridIoManager.sendOrderedMessage(ClusterNode node,
Object topic,
Message msg,
byte plc,
long timeout,
boolean skipOnTimeout) |
void |
GridIoManager.sendOrderedMessage(ClusterNode node,
Object topic,
Message msg,
byte plc,
long timeout,
boolean skipOnTimeout,
IgniteInClosure<IgniteException> ackC) |
void |
GridIoManager.sendToCustomTopic(ClusterNode node,
Object topic,
Message msg,
byte plc) |
void |
GridIoManager.sendToCustomTopic(UUID nodeId,
Object topic,
Message msg,
byte plc) |
void |
GridIoManager.sendToGridTopic(ClusterNode node,
GridTopic topic,
Message msg,
byte plc) |
void |
GridIoManager.sendToGridTopic(ClusterNode node,
GridTopic topic,
Message msg,
byte plc,
IgniteInClosure<IgniteException> ackC) |
void |
GridIoManager.sendToGridTopic(Collection<? extends ClusterNode> nodes,
GridTopic topic,
Message msg,
byte plc) |
void |
GridIoManager.sendToGridTopic(UUID nodeId,
GridTopic topic,
Message msg,
byte plc) |
void |
GridIoManager.sendUserMessage(Collection<? extends ClusterNode> nodes,
Object msg,
Object topic,
boolean ordered,
long timeout,
boolean async)
Sends a peer deployable user message.
|
void |
GridIoManager.start(boolean activeOnStart)
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 |
GridDeploymentManager.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
void |
GridDeploymentStore.onKernalStart()
Kernal started callback.
|
void |
GridDeploymentPerVersionStore.onKernalStart()
Kernal started callback.
|
void |
GridDeploymentPerLoaderStore.onKernalStart()
Kernal started callback.
|
void |
GridDeploymentManager.onKernalStart0() |
IgniteInternalFuture<?> |
GridDeploymentManager.onReconnected(boolean clusterRestarted)
Client reconnected callback.
|
void |
GridDeploymentStore.start()
Starts store.
|
void |
GridDeploymentPerVersionStore.start()
Starts store.
|
void |
GridDeploymentPerLoaderStore.start()
Starts store.
|
void |
GridDeploymentManager.start(boolean activeOnStart)
Starts grid component.
|
void |
GridDeploymentManager.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridDiscoveryManager.onKernalStart0() |
void |
GridDiscoveryManager.sendCustomEvent(DiscoveryCustomMessage msg) |
void |
GridDiscoveryManager.start(boolean activeOnStart)
Starts grid component.
|
void |
GridDiscoveryManager.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
<T extends Event> |
GridEventStorageManager.localEvents(IgnitePredicate<T> p) |
void |
GridEventStorageManager.start(boolean activeOnStart)
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(boolean activeOnStart)
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(boolean activeOnStart) |
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(boolean activeOnStart)
Starts grid component.
|
void |
GridLoadBalancerManager.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
protected byte[] |
OptimizedMarshaller.marshal0(Object obj)
Marshals object to byte array.
|
protected void |
OptimizedMarshaller.marshal0(Object obj,
OutputStream out)
Marshals object to the output stream.
|
protected <T> T |
OptimizedMarshaller.unmarshal0(byte[] arr,
ClassLoader clsLdr)
Unmarshals object from byte array using given class loader.
|
protected <T> T |
OptimizedMarshaller.unmarshal0(InputStream in,
ClassLoader clsLdr)
Unmarshals object from the input stream using given class loader.
|
| Modifier and Type | Method and Description |
|---|---|
long |
PageSupport.acquirePage(int cacheId,
long pageId)
Gets the page absolute pointer associated with the given page ID.
|
long |
PageIdAllocator.allocatePage(int cacheId,
int partId,
byte flags)
Allocates a page from the space for the given partition ID and the given flags.
|
boolean |
PageIdAllocator.freePage(int cacheId,
long pageId)
The given page is free now.
|
| Modifier and Type | Method and Description |
|---|---|
long |
PageStore.allocatePage()
Allocates next page index.
|
long |
IgnitePageStoreManager.allocatePage(int cacheId,
int partId,
byte flags)
Allocates a page for the given page space.
|
void |
PageStore.ensure() |
void |
IgnitePageStoreManager.ensure(int cacheId,
int partId) |
boolean |
IgnitePageStoreManager.exists(int cacheId,
int partId)
Checks if page exists.
|
void |
IgnitePageStoreManager.initializeForCache(CacheConfiguration ccfg)
Callback called when a cache is starting.
|
void |
IgnitePageStoreManager.onPartitionCreated(int cacheId,
int partId)
Callback called when a partition is created on the local node.
|
void |
IgnitePageStoreManager.onPartitionDestroyed(int cacheId,
int partId,
int tag)
Callback called when a partition for the given cache is evicted from the local node.
|
long |
IgnitePageStoreManager.pageOffset(int cacheId,
long pageId)
Gets page offset within the page store file.
|
int |
IgnitePageStoreManager.pages(int cacheId,
int partId)
Gets total number of allocated pages for the given space.
|
void |
IgnitePageStoreManager.read(int cacheId,
long pageId,
ByteBuffer pageBuf)
Reads a page for the given cache ID.
|
void |
PageStore.read(long pageId,
ByteBuffer pageBuf,
boolean keepCrc)
Reads a page.
|
void |
PageStore.readHeader(ByteBuffer buf)
Reads a header.
|
void |
IgnitePageStoreManager.readHeader(int cacheId,
int partId,
ByteBuffer buf)
Reads a header of apage store.
|
void |
IgnitePageStoreManager.shutdownForCache(GridCacheContext cacheCtx,
boolean destroy)
Callback called when a cache is stopping.
|
void |
PageStore.sync()
Sync method used to ensure that the given pages are guaranteed to be written to the store.
|
void |
IgnitePageStoreManager.sync(int cacheId,
int partId)
Makes sure that all previous writes to the store has been written to disk.
|
void |
IgnitePageStoreManager.write(int cacheId,
long pageId,
ByteBuffer pageBuf,
int tag)
Writes the page for the given cache ID.
|
void |
PageStore.write(long pageId,
ByteBuffer pageBuf,
int tag)
Writes a page.
|
| Modifier and Type | Class and Description |
|---|---|
class |
StorageException |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteWriteAheadLogManager.fsync(WALPointer ptr)
Makes sure that all log entries written to the log up until the specified pointer are actually persisted to
the underlying storage.
|
WALPointer |
IgniteWriteAheadLogManager.log(WALRecord entry)
Appends the given log entry to the write-ahead log.
|
WALIterator |
IgniteWriteAheadLogManager.replay(WALPointer start)
Invoke this method to iterate over the written log entries.
|
void |
IgniteWriteAheadLogManager.resumeLogging(WALPointer lastWrittenPtr)
Resumes logging after start.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DeltaApplicationException
Thrown in case when delta application to the page failed.
|
| Modifier and Type | Method and Description |
|---|---|
void |
MetaPageUpdateLastSuccessfulFullSnapshotId.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
MetaPageInitRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
InnerReplaceRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
FixLeftmostChildRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
DataPageInsertFragmentRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
PagesListAddPageRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
MetaPageUpdatePartitionDataRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
RemoveRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
PagesListRemovePageRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
RecycleRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
MetaPageInitRootRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
TrackingPageDeltaRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
MetaPageUpdateLastSuccessfulSnapshotId.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
InsertRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
PagesListSetNextRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
ReplaceRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
MetaPageUpdateNextSnapshotId.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
PagesListSetPreviousRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
DataPageSetFreeListPageRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
FixRemoveId.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
DataPageInsertRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
MetaPageCutRootRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
SplitExistingPageRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
abstract void |
PageDeltaRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
DataPageRemoveRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
InitNewPageRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
DataPageUpdateRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
SplitForwardPageRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
NewRootInitRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
MergeRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
PagesListInitNewPageRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
MetaPageAddRootRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
MetaPageInitRootInlineRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
PageListMetaResetCountRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
MetaPageUpdateLastAllocatedIndex.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
void |
FixCountRecord.applyDelta(PageMemory pageMem,
long pageAddr)
Apply changes from this delta to the given page.
|
| 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.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
void |
GridProcessorAdapter.onKernalStart(boolean activeOnStart)
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
IgniteInternalFuture<?> |
GridProcessorAdapter.onReconnected(boolean clusterRestarted)
Client reconnected callback.
|
void |
GridProcessorAdapter.start(boolean activeOnStart)
Starts grid component.
|
void |
GridProcessorAdapter.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridAffinityAssignmentCache.cancelFutures(IgniteCheckedException err)
Kernal stop callback.
|
| 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,
AffinityTopologyVersion topVer)
Map single key to primary and backup nodes.
|
ClusterNode |
GridAffinityProcessor.mapPartitionToNode(String cacheName,
int partId,
AffinityTopologyVersion topVer)
Maps partition to a node.
|
int |
GridAffinityProcessor.partition(String cacheName,
Object key) |
int |
GridAffinityProcessor.partition(String cacheName,
Object key,
org.apache.ignite.internal.processors.affinity.GridAffinityProcessor.AffinityInfo aff) |
int |
GridAffinityProcessor.partition0(String cacheName,
Object key,
org.apache.ignite.internal.processors.affinity.GridAffinityProcessor.AffinityInfo aff) |
void |
GridAffinityProcessor.start(boolean activeOnStart)
Starts grid component.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CacheAtomicUpdateTimeoutCheckedException
Exception thrown when atomic operation timeout occurs.
|
class |
CacheInvalidStateException
This exception is used to indicate that requested operation is unavailable in current cache state.
|
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.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteCheckedException |
GridCacheMessage.classError() |
| Modifier and Type | Method and Description |
|---|---|
protected RuntimeException |
IgniteCacheFutureImpl.convertException(IgniteCheckedException e)
Convert internal exception to public exception.
|
static RuntimeException |
GridCacheUtils.convertToCacheException(IgniteCheckedException e) |
void |
GridCacheMessage.onClassError(IgniteCheckedException err)
If class loading error occurred during unmarshalling and
GridCacheMessage.ignoreClassErrors() is
set to true, then the error will be passed into this method. |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheProcessor.addCacheConfiguration(CacheConfiguration cacheCfg) |
void |
GridCacheSharedContext.addCacheContext(GridCacheContext cacheCtx)
Adds cache context to shared cache context.
|
void |
GridCacheProcessor.awaitStarted() |
void |
GridCacheContext.awaitStarted() |
void |
CacheEvictionManager.batchEvict(Collection<?> keys,
GridCacheVersion obsoleteVer) |
void |
GridCacheEvictionManager.batchEvict(Collection<?> keys,
GridCacheVersion obsoleteVer) |
CacheObjectContext |
DynamicCacheDescriptor.cacheObjectContext(IgniteCacheObjectProcessor proc)
Creates and caches cache object context if needed.
|
CacheObjectContext |
GridCacheSharedContext.cacheObjectContext(int cacheId)
Returns cache object context if created or creates new and caches it until cache started.
|
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 |
IgniteInternalCache.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)
Marks entry as obsolete and, if possible or required, removes it
from swap storage.
|
boolean |
GridCacheMapEntry.clear(GridCacheVersion ver,
boolean readers)
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 |
IgniteInternalCache.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.clearAll(Set<? extends K> keys)
Clears keys on all nodes that store it's data.
|
void |
IgniteInternalCache.clearAll(Set<? extends K> keys)
Clears keys on all nodes that store it's data.
|
void |
GridCacheAdapter.clearAll(Set<? extends K> keys)
Clears keys on all nodes that store it's data.
|
void |
GridCacheEntryEx.clearReserveForLoad(GridCacheVersion ver) |
void |
GridCacheMapEntry.clearReserveForLoad(GridCacheVersion ver) |
<T> T |
GridCacheProcessor.clone(T obj) |
protected int |
IgniteCacheOffheapManagerImpl.CacheDataTree.compare(BPlusIO<CacheSearchRow> io,
long pageAddr,
int idx,
CacheSearchRow row) |
protected int |
IgniteCacheOffheapManagerImpl.PendingEntriesTree.compare(BPlusIO<org.apache.ignite.internal.processors.cache.IgniteCacheOffheapManagerImpl.PendingRow> io,
long pageAddr,
int idx,
org.apache.ignite.internal.processors.cache.IgniteCacheOffheapManagerImpl.PendingRow row) |
GridCacheVersionConflictContext<K,V> |
GridCacheContext.conflictResolve(GridCacheVersionedEntryEx<K,V> oldEntry,
GridCacheVersionedEntryEx<K,V> newEntry,
boolean atomicVerComp)
Resolve DR conflict.
|
IgniteCacheOffheapManager.CacheDataStore |
IgniteCacheOffheapManager.createCacheDataStore(int p) |
IgniteCacheOffheapManager.CacheDataStore |
IgniteCacheOffheapManagerImpl.createCacheDataStore(int p) |
protected IgniteCacheOffheapManager.CacheDataStore |
IgniteCacheOffheapManagerImpl.createCacheDataStore0(int p) |
void |
GridCacheProcessor.createMissingQueryCaches()
Starts client caches that do not exist yet.
|
CacheDataRow |
IgniteCacheOffheapManager.CacheDataStore.createRow(KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
CacheDataRow oldRow) |
CacheDataRow |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.createRow(KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
CacheDataRow oldRow) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManager.CacheDataStore.cursor() |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.cursor() |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManager.CacheDataStore.cursor(KeyCacheObject lower,
KeyCacheObject upper) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.cursor(KeyCacheObject lower,
KeyCacheObject upper) |
void |
IgniteCacheOffheapManager.CacheDataStore.destroy()
Destroys the tree associated with the store.
|
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.destroy()
Destroys the tree associated with the store.
|
void |
IgniteCacheOffheapManager.destroyCacheDataStore(int p,
IgniteCacheOffheapManager.CacheDataStore store) |
void |
IgniteCacheOffheapManagerImpl.destroyCacheDataStore(int p,
IgniteCacheOffheapManager.CacheDataStore store) |
void |
IgniteCacheOffheapManager.dropRootPageForIndex(String idxName) |
void |
IgniteCacheOffheapManagerImpl.dropRootPageForIndex(String idxName) |
void |
GridCacheSharedContext.endTx(GridNearTxLocal tx) |
long |
IgniteCacheOffheapManager.entriesCount(boolean primary,
boolean backup,
AffinityTopologyVersion topVer) |
long |
IgniteCacheOffheapManagerImpl.entriesCount(boolean primary,
boolean backup,
AffinityTopologyVersion topVer) |
<K,V> GridCloseableIterator<javax.cache.Cache.Entry<K,V>> |
IgniteCacheOffheapManager.entriesIterator(boolean primary,
boolean backup,
AffinityTopologyVersion topVer,
boolean keepBinary) |
<K,V> GridCloseableIterator<javax.cache.Cache.Entry<K,V>> |
IgniteCacheOffheapManagerImpl.entriesIterator(boolean primary,
boolean backup,
AffinityTopologyVersion topVer,
boolean keepBinary) |
boolean |
CacheOffheapEvictionManager.evict(GridCacheEntryEx entry,
GridCacheVersion obsoleteVer,
boolean explicit,
CacheEntryPredicate[] filter) |
boolean |
CacheEvictionManager.evict(GridCacheEntryEx entry,
GridCacheVersion obsoleteVer,
boolean explicit,
CacheEntryPredicate[] filter) |
boolean |
GridCacheEvictionManager.evict(GridCacheEntryEx entry,
GridCacheVersion obsoleteVer,
boolean explicit,
CacheEntryPredicate[] filter) |
boolean |
GridCacheEntryEx.evictInternal(GridCacheVersion obsoleteVer,
CacheEntryPredicate[] filter,
boolean evictOffheap) |
boolean |
GridCacheMapEntry.evictInternal(GridCacheVersion obsoleteVer,
CacheEntryPredicate[] filter,
boolean evictOffheap) |
boolean |
IgniteCacheOffheapManager.expire(IgniteInClosure2X<GridCacheEntryEx,GridCacheVersion> c,
int amount) |
boolean |
IgniteCacheOffheapManagerImpl.expire(IgniteInClosure2X<GridCacheEntryEx,GridCacheVersion> c,
int amount) |
long |
IgniteCacheOffheapManager.expiredSize()
Gets the number of entries pending expire.
|
long |
IgniteCacheOffheapManagerImpl.expiredSize()
Gets the number of entries pending expire.
|
CacheDataRow |
IgniteCacheOffheapManager.CacheDataStore.find(KeyCacheObject key) |
CacheDataRow |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.find(KeyCacheObject key) |
void |
KeyCacheObjectImpl.finishUnmarshal(CacheObjectContext ctx,
ClassLoader ldr) |
void |
CacheObjectByteArrayImpl.finishUnmarshal(CacheObjectContext ctx,
ClassLoader ldr) |
void |
CacheObject.finishUnmarshal(CacheObjectContext ctx,
ClassLoader ldr) |
void |
CacheObjectImpl.finishUnmarshal(CacheObjectContext ctx,
ClassLoader ldr) |
void |
CacheEntryPredicate.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
GridCacheReturn.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEntryPredicateContainsValue.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEntryPredicateAdapter.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEvictionEntry.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheEntrySerializablePredicate.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
CacheInvokeDirectResult.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
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. |
void |
GridChangeGlobalStateMessageResponse.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) |
void |
GridCacheMessage.finishUnmarshalCacheObjects(List<? extends CacheObject> col,
GridCacheContext ctx,
ClassLoader ldr) |
V |
GridCacheProxyImpl.get(K key)
Retrieves value mapped to the specified key from cache.
|
V |
IgniteInternalCache.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 deserializeBinary,
boolean needVer) |
protected V |
GridCacheAdapter.get0(K key,
String taskName,
boolean deserializeBinary,
boolean needVer) |
Map<K,V> |
GridCacheProxyImpl.getAll(Collection<? extends K> keys)
Retrieves values mapped to the specified keys from cache.
|
Map<K,V> |
IgniteInternalCache.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.
|
void |
QueryCursorImpl.getAll(QueryCursorEx.Consumer<T> clo)
Get all values passing them through passed consumer.
|
protected Map<K,V> |
GridCacheAdapter.getAll0(Collection<? extends K> keys,
boolean deserializeBinary,
boolean needVer) |
Map<K,V> |
GridCacheProxyImpl.getAllOutTx(Set<? extends K> keys)
Gets values from cache.
|
Map<K,V> |
IgniteInternalCache.getAllOutTx(Set<? extends K> keys)
Gets values from cache.
|
Map<K,V> |
GridCacheAdapter.getAllOutTx(Set<? extends K> keys)
Gets values from cache.
|
V |
GridCacheProxyImpl.getAndPut(K key,
V val)
Stores given key-value pair in cache.
|
V |
IgniteInternalCache.getAndPut(K key,
V val)
Stores given key-value pair in cache.
|
V |
GridCacheAdapter.getAndPut(K key,
V val)
Stores given key-value pair in cache.
|
V |
GridCacheAdapter.getAndPut(K key,
V val,
CacheEntryPredicate filter) |
protected V |
GridCacheAdapter.getAndPut0(K key,
V val,
CacheEntryPredicate filter) |
V |
GridCacheProxyImpl.getAndPutIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
V |
IgniteInternalCache.getAndPutIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
V |
GridCacheAdapter.getAndPutIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
V |
GridCacheProxyImpl.getAndRemove(K key)
Removes given key mapping from cache.
|
V |
IgniteInternalCache.getAndRemove(K key)
Removes given key mapping from cache.
|
V |
GridCacheAdapter.getAndRemove(K key)
Removes given key mapping from cache.
|
protected V |
GridCacheAdapter.getAndRemove0(K key) |
V |
GridCacheProxyImpl.getAndReplace(K key,
V val)
Stores given key-value pair in cache only if there is a previous mapping for it.
|
V |
IgniteInternalCache.getAndReplace(K key,
V val)
Stores given key-value pair in cache only if there is a previous mapping for it.
|
V |
GridCacheAdapter.getAndReplace(K key,
V val)
Stores given key-value pair in cache only if there is a previous mapping for it.
|
Collection<CacheEntry<K,V>> |
GridCacheProxyImpl.getEntries(Collection<? extends K> keys)
Retrieves values mapped to the specified keys from cache.
|
Collection<CacheEntry<K,V>> |
IgniteInternalCache.getEntries(Collection<? extends K> keys)
Retrieves values mapped to the specified keys from cache.
|
Collection<CacheEntry<K,V>> |
GridCacheAdapter.getEntries(Collection<? extends K> keys)
Retrieves values mapped to the specified keys from cache.
|
CacheEntry<K,V> |
GridCacheProxyImpl.getEntry(K key)
Retrieves value mapped to the specified key from cache.
|
CacheEntry<K,V> |
IgniteInternalCache.getEntry(K key)
Retrieves value mapped to the specified key from cache.
|
CacheEntry<K,V> |
GridCacheAdapter.getEntry(K key)
Retrieves value mapped to the specified key from cache.
|
V |
GridCacheProxyImpl.getForcePrimary(K key)
Gets value from cache.
|
V |
IgniteInternalCache.getForcePrimary(K key)
Gets value from cache.
|
V |
GridCacheAdapter.getForcePrimary(K key)
Gets value from cache.
|
org.apache.ignite.internal.processors.cache.IgniteCacheOffheapManagerImpl.PendingRow |
IgniteCacheOffheapManagerImpl.PendingEntryInnerIO.getLookupRow(BPlusTree<org.apache.ignite.internal.processors.cache.IgniteCacheOffheapManagerImpl.PendingRow,?> tree,
long pageAddr,
int idx)
Get lookup row.
|
org.apache.ignite.internal.processors.cache.IgniteCacheOffheapManagerImpl.PendingRow |
IgniteCacheOffheapManagerImpl.PendingEntryLeafIO.getLookupRow(BPlusTree<org.apache.ignite.internal.processors.cache.IgniteCacheOffheapManagerImpl.PendingRow,?> tree,
long pageAddr,
int idx)
Get lookup row.
|
<K,V> IgniteInternalCache<K,V> |
GridCacheProcessor.getOrStartCache(String name) |
IgniteCacheProxy<?,?> |
GridCacheProcessor.getOrStartPublicCache(boolean start,
boolean inclLoc)
Gets public cache that can be used for query execution.
|
protected CacheDataRow |
IgniteCacheOffheapManagerImpl.CacheDataTree.getRow(BPlusIO<CacheSearchRow> io,
long pageAddr,
int idx,
Object flags)
Get data row.
|
protected org.apache.ignite.internal.processors.cache.IgniteCacheOffheapManagerImpl.PendingRow |
IgniteCacheOffheapManagerImpl.PendingEntriesTree.getRow(BPlusIO<org.apache.ignite.internal.processors.cache.IgniteCacheOffheapManagerImpl.PendingRow> io,
long pageAddr,
int idx,
Object ignore)
Get data row.
|
V |
GridCacheProxyImpl.getTopologySafe(K key)
Gets value without waiting for toplogy changes.
|
V |
IgniteInternalCache.getTopologySafe(K key)
Gets value without waiting for toplogy changes.
|
V |
GridCacheAdapter.getTopologySafe(K key)
Gets value without waiting for toplogy changes.
|
Iterator<javax.cache.Cache.Entry<K,V>> |
GridCacheAdapter.igniteIterator() |
Iterator<javax.cache.Cache.Entry<K,V>> |
GridCacheAdapter.igniteIterator(boolean keepBinary) |
IgniteInternalFuture<Map<Integer,Map<Integer,List<UUID>>>> |
CacheAffinitySharedManager.initAffinityOnNodeLeft(GridDhtPartitionsExchangeFuture fut) |
protected void |
IgniteCacheOffheapManagerImpl.initDataStructures() |
boolean |
GridCacheEntryEx.initialValue(CacheObject val,
GridCacheVersion ver,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore)
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,
boolean fromStore)
Sets new value if current version is 0
|
void |
CacheAffinitySharedManager.initStartedCaches(boolean crd,
GridDhtPartitionsExchangeFuture fut,
Collection<DynamicCacheDescriptor> descs)
Initialized affinity started on this exchange.
|
CacheObject |
GridCacheEntryEx.innerGet(GridCacheVersion ver,
IgniteInternalTx tx,
boolean readThrough,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary) |
CacheObject |
GridCacheMapEntry.innerGet(GridCacheVersion ver,
IgniteInternalTx tx,
boolean readThrough,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expirePlc,
boolean keepBinary) |
EntryGetResult |
GridCacheEntryEx.innerGetAndReserveForLoad(boolean updateMetrics,
boolean evt,
UUID subjId,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
ReaderArguments readerArgs) |
EntryGetResult |
GridCacheMapEntry.innerGetAndReserveForLoad(boolean updateMetrics,
boolean evt,
UUID subjId,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
ReaderArguments readerArgs) |
EntryGetResult |
GridCacheEntryEx.innerGetVersioned(GridCacheVersion ver,
IgniteInternalTx tx,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
ReaderArguments readerArgs) |
EntryGetResult |
GridCacheMapEntry.innerGetVersioned(GridCacheVersion ver,
IgniteInternalTx tx,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
ReaderArguments readerArgs) |
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 retval,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId,
String taskName,
GridCacheVersion dhtVer,
Long updateCntr) |
GridCacheUpdateTxResult |
GridCacheMapEntry.innerRemove(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
boolean retval,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId,
String taskName,
GridCacheVersion dhtVer,
Long updateCntr) |
GridCacheUpdateTxResult |
GridCacheEntryEx.innerSet(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId,
String taskName,
GridCacheVersion dhtVer,
Long updateCntr) |
GridCacheUpdateTxResult |
GridCacheMapEntry.innerSet(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId,
String taskName,
GridCacheVersion dhtVer,
Long updateCntr) |
GridCacheUpdateAtomicResult |
GridCacheEntryEx.innerUpdate(GridCacheVersion ver,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object val,
Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
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,
CacheObject prevVal,
Long updateCntr,
GridDhtAtomicAbstractUpdateFuture fut) |
GridCacheUpdateAtomicResult |
GridCacheMapEntry.innerUpdate(GridCacheVersion newVer,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object writeObj,
Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
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,
CacheObject prevVal,
Long updateCntr,
GridDhtAtomicAbstractUpdateFuture fut) |
GridTuple3<Boolean,Object,javax.cache.processor.EntryProcessorResult<Object>> |
GridCacheEntryEx.innerUpdateLocal(GridCacheVersion ver,
GridCacheOperation op,
Object writeObj,
Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
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 readThrough,
boolean retval,
boolean keepBinary,
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(Ignite ignite,
IgniteCache<K,V> cache,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
IgniteInClosureX<IgniteCache<K,V>> clo)
Execute closure inside cache transaction.
|
static <K,V> void |
GridCacheUtils.inTx(IgniteInternalCache<K,V> cache,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
IgniteInClosureX<IgniteInternalCache<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(AffinityTopologyVersion topVer,
K key,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> javax.cache.processor.EntryProcessorResult<T> |
IgniteInternalCache.invoke(AffinityTopologyVersion topVer,
K key,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> javax.cache.processor.EntryProcessorResult<T> |
GridCacheAdapter.invoke(AffinityTopologyVersion topVer,
K key,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<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> |
IgniteInternalCache.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) |
void |
IgniteCacheOffheapManager.invoke(KeyCacheObject key,
GridDhtLocalPartition part,
IgniteCacheOffheapManager.OffheapInvokeClosure c) |
void |
IgniteCacheOffheapManagerImpl.invoke(KeyCacheObject key,
GridDhtLocalPartition part,
IgniteCacheOffheapManager.OffheapInvokeClosure c) |
void |
IgniteCacheOffheapManager.CacheDataStore.invoke(KeyCacheObject key,
IgniteCacheOffheapManager.OffheapInvokeClosure c) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.invoke(KeyCacheObject key,
IgniteCacheOffheapManager.OffheapInvokeClosure c) |
<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>> |
IgniteInternalCache.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>> |
IgniteInternalCache.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) |
GridIterator<CacheDataRow> |
IgniteCacheOffheapManager.iterator(boolean primary,
boolean backup,
AffinityTopologyVersion topVer) |
GridIterator<CacheDataRow> |
IgniteCacheOffheapManagerImpl.iterator(boolean primary,
boolean backups,
AffinityTopologyVersion topVer) |
GridIterator<CacheDataRow> |
IgniteCacheOffheapManager.iterator(int part) |
GridIterator<CacheDataRow> |
IgniteCacheOffheapManagerImpl.iterator(int part) |
GridCloseableIterator<KeyCacheObject> |
IgniteCacheOffheapManager.keysIterator(int part) |
GridCloseableIterator<KeyCacheObject> |
IgniteCacheOffheapManagerImpl.keysIterator(int part) |
Iterable<javax.cache.Cache.Entry<K,V>> |
GridCacheProxyImpl.localEntries(CachePeekMode[] peekModes) |
Iterable<javax.cache.Cache.Entry<K,V>> |
IgniteInternalCache.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,
boolean keepBinary) |
void |
IgniteInternalCache.localLoadCache(IgniteBiPredicate<K,V> p,
Object... args)
Delegates to
CacheStore.loadCache(IgniteBiInClosure, Object...) method
to load state from the underlying persistent storage. |
void |
GridCacheProxyImpl.localLoadCache(IgniteBiPredicate<K,V> p,
Object[] args)
Delegates to
CacheStore.loadCache(IgniteBiInClosure, Object...) method
to load state from the underlying persistent storage. |
void |
GridCacheAdapter.localLoadCache(IgniteBiPredicate<K,V> p,
Object[] args)
Delegates to
CacheStore.loadCache(IgniteBiInClosure, Object...) method
to load state from the underlying persistent storage. |
V |
GridCacheProxyImpl.localPeek(K key,
CachePeekMode[] peekModes,
IgniteCacheExpiryPolicy plc) |
V |
IgniteInternalCache.localPeek(K key,
CachePeekMode[] peekModes,
IgniteCacheExpiryPolicy plc) |
V |
GridCacheAdapter.localPeek(K key,
CachePeekMode[] peekModes,
IgniteCacheExpiryPolicy plc) |
int |
GridCacheProxyImpl.localSize(CachePeekMode[] peekModes) |
int |
IgniteInternalCache.localSize(CachePeekMode[] peekModes) |
int |
GridCacheAdapter.localSize(CachePeekMode[] peekModes) |
long |
GridCacheProxyImpl.localSizeLong(CachePeekMode[] peekModes) |
long |
IgniteInternalCache.localSizeLong(CachePeekMode[] peekModes) |
long |
GridCacheProxyImpl.localSizeLong(int partition,
CachePeekMode[] peekModes) |
long |
IgniteInternalCache.localSizeLong(int partition,
CachePeekMode[] peekModes) |
boolean |
GridCacheProxyImpl.lock(K key,
long timeout)
Synchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
boolean |
IgniteInternalCache.lock(K key,
long timeout)
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)
Synchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
boolean |
GridCacheProxyImpl.lockAll(Collection<? extends K> keys,
long timeout)
All or nothing synchronous lock for passed in keys.
|
boolean |
IgniteInternalCache.lockAll(Collection<? extends K> keys,
long timeout)
All or nothing synchronous lock for passed in keys.
|
boolean |
GridCacheAdapter.lockAll(Collection<? extends K> keys,
long timeout)
All or nothing synchronous lock for passed in keys.
|
protected void |
GridCacheMapEntry.logUpdate(GridCacheOperation op,
CacheObject val,
GridCacheVersion writeVer,
long expireTime,
long updCntr) |
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 obsoleteVer)
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(GridCacheContext ctx,
Object obj) |
static byte[] |
GridCacheUtils.marshal(GridCacheSharedContext ctx,
boolean depEnabled,
Object obj) |
protected List<byte[]> |
GridCacheMessage.marshalCollection(Collection<?> col,
GridCacheContext 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,
GridCacheContext ctx) |
int |
GridCacheEntryInfo.marshalledSize(GridCacheContext ctx) |
protected void |
GridCacheMessage.marshalTx(Iterable<IgniteTxEntry> txEntries,
GridCacheSharedContext ctx) |
int |
GridCacheEntryEx.memorySize() |
int |
GridCacheMapEntry.memorySize() |
boolean |
CacheAffinitySharedManager.onCacheChangeRequest(GridDhtPartitionsExchangeFuture fut,
boolean crd,
Collection<DynamicCacheChangeRequest> reqs)
Called on exchange initiated for cache start/stop request.
|
void |
CacheAffinitySharedManager.onChangeAffinityMessage(GridDhtPartitionsExchangeFuture exchFut,
boolean crd,
CacheAffinityChangeMessage msg)
Called on exchange initiated by
CacheAffinityChangeMessage which sent after rebalance finished. |
void |
CacheAffinitySharedManager.onClientEvent(GridDhtPartitionsExchangeFuture fut,
boolean crd)
Called on exchange initiated by client node join/fail.
|
protected void |
CacheWeakQueryIteratorsHolder.WeakQueryCloseableIterator.onClose()
Invoked on iterator close.
|
void |
GridCacheProcessor.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
protected boolean |
CacheWeakQueryIteratorsHolder.WeakQueryCloseableIterator.onHasNext() |
void |
GridCachePreloaderAdapter.onKernalStart()
Kernal start callback.
|
void |
GridCachePreloader.onKernalStart()
Kernal start callback.
|
void |
CacheOsConflictResolutionManager.onKernalStart() |
void |
GridCacheManagerAdapter.onKernalStart() |
protected void |
GridCacheAdapter.onKernalStart()
Kernal start callback.
|
void |
GridCacheManager.onKernalStart() |
void |
GridCacheProcessor.onKernalStart(boolean activeOnStart)
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
void |
GridCacheSharedManager.onKernalStart(boolean reconnect) |
void |
GridCacheSharedManagerAdapter.onKernalStart(boolean reconnect) |
protected void |
GridCacheAffinityManager.onKernalStart0() |
protected void |
GridCacheManagerAdapter.onKernalStart0() |
protected void |
GridCachePartitionExchangeManager.onKernalStart0(boolean reconnect) |
protected void |
GridCacheMvccManager.onKernalStart0(boolean reconnect) |
protected void |
GridCacheSharedManagerAdapter.onKernalStart0(boolean reconnect) |
protected T |
CacheWeakQueryIteratorsHolder.WeakQueryCloseableIterator.onNext() |
IgniteInternalFuture<?> |
GridCacheProcessor.onReconnected(boolean clusterRestarted)
Client reconnected callback.
|
protected void |
CacheWeakQueryIteratorsHolder.WeakQueryCloseableIterator.onRemove()
Called on remove from iterator.
|
void |
CacheAffinitySharedManager.onServerJoin(GridDhtPartitionsExchangeFuture fut,
boolean crd)
Called on exchange initiated by server node join.
|
boolean |
CacheAffinitySharedManager.onServerLeft(GridDhtPartitionsExchangeFuture fut)
Called on exchange initiated by server node leave.
|
CacheObject |
GridCacheEntryEx.peek(boolean heap,
boolean offheap,
AffinityTopologyVersion topVer,
IgniteCacheExpiryPolicy plc)
Peeks into entry without loading value or updating statistics.
|
CacheObject |
GridCacheMapEntry.peek(boolean heap,
boolean offheap,
AffinityTopologyVersion topVer,
IgniteCacheExpiryPolicy expiryPlc)
Peeks into entry without loading value or updating statistics.
|
CacheObject |
GridCacheEntryEx.peek(IgniteCacheExpiryPolicy plc)
Peeks into entry without loading value or updating statistics.
|
CacheObject |
GridCacheMapEntry.peek(IgniteCacheExpiryPolicy plc)
Peeks into entry without loading value or updating statistics.
|
long |
GridCacheTtlManager.pendingSize() |
void |
GridCacheProcessor.prepareCacheStart(DynamicCacheChangeRequest req,
AffinityTopologyVersion topVer) |
void |
KeyCacheObjectImpl.prepareMarshal(CacheObjectContext ctx) |
void |
CacheObjectByteArrayImpl.prepareMarshal(CacheObjectContext ctx) |
void |
CacheObject.prepareMarshal(CacheObjectContext ctx) |
void |
CacheObjectImpl.prepareMarshal(CacheObjectContext ctx) |
void |
CacheEntryPredicate.prepareMarshal(GridCacheContext ctx) |
void |
GridCacheReturn.prepareMarshal(GridCacheContext ctx) |
void |
CacheEntryPredicateContainsValue.prepareMarshal(GridCacheContext ctx) |
void |
CacheEntryPredicateAdapter.prepareMarshal(GridCacheContext ctx) |
void |
CacheEvictionEntry.prepareMarshal(GridCacheContext ctx) |
void |
CacheEntrySerializablePredicate.prepareMarshal(GridCacheContext ctx) |
void |
CacheInvokeDirectResult.prepareMarshal(GridCacheContext ctx) |
void |
GridCacheMessage.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridChangeGlobalStateMessageResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
protected void |
GridCacheMessage.prepareMarshalCacheObject(CacheObject obj,
GridCacheContext ctx) |
protected void |
GridCacheMessage.prepareMarshalCacheObjects(Collection<? extends CacheObject> col,
GridCacheContext ctx) |
void |
GridCacheMessage.prepareMarshalCacheObjects(List<? extends CacheObject> col,
GridCacheContext ctx) |
protected void |
GridCacheMessage.prepareObject(Object o,
GridCacheContext ctx) |
<K,V> IgniteCacheProxy<K,V> |
GridCacheProcessor.publicJCache(String cacheName) |
<K,V> IgniteCacheProxy<K,V> |
GridCacheProcessor.publicJCache(String cacheName,
boolean failIfNotStarted,
boolean checkThreadTx) |
boolean |
GridCacheProxyImpl.put(K key,
V val)
Stores given key-value pair in cache.
|
boolean |
IgniteInternalCache.put(K key,
V val)
Stores given key-value pair in cache.
|
boolean |
GridCacheAdapter.put(K key,
V val)
Stores given key-value pair in cache.
|
boolean |
GridCacheAdapter.put(K key,
V val,
CacheEntryPredicate filter) |
protected boolean |
GridCacheAdapter.put0(K key,
V val,
CacheEntryPredicate filter) |
void |
GridCacheProxyImpl.putAll(Map<? extends K,? extends V> m)
Stores given key-value pairs in cache.
|
void |
IgniteInternalCache.putAll(Map<? extends K,? extends V> m)
Stores given key-value pairs in cache.
|
void |
GridCacheAdapter.putAll(Map<? extends K,? extends V> m)
Stores given key-value pairs in cache.
|
protected void |
GridCacheAdapter.putAll0(Map<? extends K,? extends V> m) |
void |
GridCacheProxyImpl.putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data.
|
void |
IgniteInternalCache.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<?> |
IgniteInternalCache.putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data asynchronously.
|
IgniteInternalFuture<?> |
GridCacheAdapter.putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data asynchronously.
|
boolean |
GridCacheProxyImpl.putIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
boolean |
IgniteInternalCache.putIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
boolean |
GridCacheAdapter.putIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
boolean |
CacheObjectByteArrayImpl.putValue(ByteBuffer buf) |
boolean |
CacheObjectAdapter.putValue(ByteBuffer buf) |
boolean |
CacheObject.putValue(ByteBuffer buf) |
boolean |
CacheObjectByteArrayImpl.putValue(ByteBuffer buf,
int off,
int len) |
boolean |
CacheObjectAdapter.putValue(ByteBuffer buf,
int off,
int len) |
boolean |
CacheObject.putValue(ByteBuffer buf,
int off,
int len) |
static boolean |
CacheObjectAdapter.putValue(byte cacheObjType,
ByteBuffer buf,
int off,
int len,
byte[] valBytes,
int start) |
int |
CacheObjectByteArrayImpl.putValue(long addr) |
int |
CacheObjectAdapter.putValue(long addr) |
int |
CacheObject.putValue(long addr) |
CacheDataRow |
IgniteCacheOffheapManager.read(GridCacheMapEntry entry) |
CacheDataRow |
IgniteCacheOffheapManagerImpl.read(GridCacheMapEntry entry) |
protected Object |
GridCacheMapEntry.readThrough(IgniteInternalTx tx,
KeyCacheObject key,
boolean reload,
UUID subjId,
String taskName) |
IgniteRebalanceIterator |
IgniteCacheOffheapManager.rebalanceIterator(int part,
AffinityTopologyVersion topVer,
Long partCntr) |
IgniteRebalanceIterator |
IgniteCacheOffheapManagerImpl.rebalanceIterator(int part,
AffinityTopologyVersion topVer,
Long partCntr) |
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.
|
boolean |
GridCacheProxyImpl.remove(K key)
Removes given key mapping from cache.
|
boolean |
IgniteInternalCache.remove(K key)
Removes given key mapping from cache.
|
boolean |
GridCacheAdapter.remove(K key)
Removes given key mapping from cache.
|
boolean |
GridCacheAdapter.remove(K key,
CacheEntryPredicate filter) |
void |
IgniteCacheOffheapManager.CacheDataStore.remove(KeyCacheObject key,
int partId) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.remove(KeyCacheObject key,
int partId) |
void |
IgniteCacheOffheapManager.remove(KeyCacheObject key,
int partId,
GridDhtLocalPartition part) |
void |
IgniteCacheOffheapManagerImpl.remove(KeyCacheObject key,
int partId,
GridDhtLocalPartition part) |
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 |
IgniteInternalCache.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.
|
protected boolean |
GridCacheAdapter.remove0(K key,
CacheEntryPredicate filter) |
void |
GridCacheProxyImpl.removeAll()
Removes mappings from cache.
|
void |
IgniteInternalCache.removeAll()
Removes mappings from cache.
|
void |
GridCacheAdapter.removeAll()
Removes mappings from cache.
|
void |
GridCacheProxyImpl.removeAll(Collection<? extends K> keys)
Removes given key mappings from cache.
|
void |
IgniteInternalCache.removeAll(Collection<? extends K> keys)
Removes given key mappings from cache.
|
void |
GridCacheAdapter.removeAll(Collection<? extends K> keys)
Removes given key mappings from cache.
|
protected void |
GridCacheAdapter.removeAll0(Collection<? extends K> keys) |
void |
GridCacheProxyImpl.removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data.
|
void |
IgniteInternalCache.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<?> |
IgniteInternalCache.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
IgniteInternalFuture<?> |
GridCacheAdapter.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
void |
CacheWeakQueryIteratorsHolder.removeIterator(CacheWeakQueryIteratorsHolder.WeakReferenceCloseableIterator it) |
protected void |
GridCacheMapEntry.removeValue()
Removes value from offheap.
|
boolean |
GridCacheProxyImpl.replace(K key,
V val)
Stores given key-value pair in cache only if only if there is a previous mapping for it.
|
boolean |
IgniteInternalCache.replace(K key,
V val)
Stores given key-value pair in cache only if only if there is a previous mapping for it.
|
boolean |
GridCacheAdapter.replace(K key,
V val)
Stores given key-value pair in cache only if 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 |
IgniteInternalCache.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. |
static <S> S |
GridCacheUtils.retryTopologySafe(Callable<S> c) |
ReuseList |
IgniteCacheOffheapManager.reuseListForIndex(String idxName) |
IgniteInternalFuture |
GridCacheSharedContext.rollbackTxAsync(GridNearTxLocal tx) |
RootPage |
IgniteCacheOffheapManager.rootPageForIndex(String idxName) |
RootPage |
IgniteCacheOffheapManagerImpl.rootPageForIndex(String idxName) |
void |
GridCacheIoManager.safeSend(Collection<? extends ClusterNode> nodes,
GridCacheMessage msg,
byte plc,
IgnitePredicate<ClusterNode> fallback)
Sends message and automatically accounts for lefts nodes.
|
Iterator<javax.cache.Cache.Entry<K,V>> |
GridCacheProxyImpl.scanIterator(boolean keepBinary,
IgniteBiPredicate<Object,Object> p) |
Iterator<javax.cache.Cache.Entry<K,V>> |
IgniteInternalCache.scanIterator(boolean keepBinary,
IgniteBiPredicate<Object,Object> p) |
Iterator<javax.cache.Cache.Entry<K,V>> |
GridCacheAdapter.scanIterator(boolean keepBinary,
IgniteBiPredicate<Object,Object> p) |
void |
GridCacheIoManager.send(ClusterNode node,
GridCacheMessage msg,
byte plc)
Sends communication message.
|
void |
GridCacheIoManager.send(UUID nodeId,
GridCacheMessage msg,
byte plc)
Sends communication message.
|
void |
GridCacheIoManager.sendOrderedMessage(ClusterNode node,
Object topic,
GridCacheMessage msg,
byte plc,
long timeout) |
int |
GridCacheProxyImpl.size(CachePeekMode[] peekModes) |
int |
IgniteInternalCache.size(CachePeekMode[] peekModes) |
int |
GridCacheAdapter.size(CachePeekMode[] peekModes) |
long |
GridCacheProxyImpl.sizeLong(CachePeekMode[] peekModes) |
long |
IgniteInternalCache.sizeLong(CachePeekMode[] peekModes) |
long |
GridCacheAdapter.sizeLong(CachePeekMode[] peekModes) |
long |
GridCacheProxyImpl.sizeLong(int partition,
CachePeekMode[] peekModes) |
long |
IgniteInternalCache.sizeLong(int partition,
CachePeekMode[] peekModes) |
long |
GridCacheAdapter.sizeLong(int partition,
CachePeekMode[] peekModes) |
void |
GridCachePreloaderAdapter.start()
Starts preloading.
|
void |
GridCachePreloader.start()
Starts preloading.
|
void |
GridCacheAdapter.start()
Starts this cache.
|
void |
GridCacheProcessor.start(boolean activeOnStart)
Starts grid component.
|
void |
CacheOsConflictResolutionManager.start(GridCacheContext<K,V> cctx)
Starts manager.
|
void |
GridCacheManagerAdapter.start(GridCacheContext<K,V> cctx)
Starts manager.
|
void |
GridCacheManager.start(GridCacheContext<K,V> cctx)
Starts manager.
|
void |
GridCacheSharedManager.start(GridCacheSharedContext<K,V> cctx)
Starts manager.
|
void |
GridCacheSharedManagerAdapter.start(GridCacheSharedContext<K,V> cctx)
Starts manager.
|
void |
GridCacheDeploymentManager.start0() |
void |
GridCacheIoManager.start0() |
protected void |
GridCacheTtlManager.start0() |
protected void |
CacheAffinitySharedManager.start0() |
protected void |
GridCachePartitionExchangeManager.start0() |
protected void |
GridCacheMvccManager.start0() |
void |
GridCacheAffinityManager.start0() |
protected void |
GridCacheSharedManagerAdapter.start0() |
protected void |
GridCacheManagerAdapter.start0() |
void |
GridCacheEvictionManager.start0() |
protected void |
IgniteCacheOffheapManagerImpl.start0() |
Collection<DynamicCacheChangeRequest> |
GridCacheProcessor.startAllCachesRequests() |
Collection<DynamicCacheDescriptor> |
GridCacheProcessor.startReceivedCaches(AffinityTopologyVersion topVer)
Starts statically configured caches received from remote nodes during exchange.
|
static Collection<CacheStoreSessionListener> |
GridCacheUtils.startStoreSessionListeners(GridKernalContext ctx,
javax.cache.configuration.Factory<CacheStoreSessionListener>[] factories)
Creates and starts store session listeners.
|
void |
GridCacheProcessor.stop(boolean cancel)
Stops grid component.
|
static void |
GridCacheUtils.stopStoreSessionListeners(GridKernalContext ctx,
Collection<CacheStoreSessionListener> sesLsnrs)
Stops store session listeners.
|
void |
IgniteCacheOffheapManagerImpl.PendingEntryInnerIO.store(long dstPageAddr,
int dstIdx,
BPlusIO<org.apache.ignite.internal.processors.cache.IgniteCacheOffheapManagerImpl.PendingRow> srcIo,
long srcPageAddr,
int srcIdx)
Store row info from the given source.
|
void |
IgniteCacheOffheapManagerImpl.PendingEntryLeafIO.store(long dstPageAddr,
int dstIdx,
BPlusIO<org.apache.ignite.internal.processors.cache.IgniteCacheOffheapManagerImpl.PendingRow> srcIo,
long srcPageAddr,
int srcIdx)
Store row info from the given source.
|
void |
IgniteCacheOffheapManagerImpl.PendingEntryInnerIO.storeByOffset(long pageAddr,
int off,
org.apache.ignite.internal.processors.cache.IgniteCacheOffheapManagerImpl.PendingRow row)
Store the needed info about the row in the page.
|
void |
IgniteCacheOffheapManagerImpl.PendingEntryLeafIO.storeByOffset(long pageAddr,
int off,
org.apache.ignite.internal.processors.cache.IgniteCacheOffheapManagerImpl.PendingRow row)
Store the needed info about the row in the page.
|
protected void |
GridCacheMapEntry.storeValue(CacheObject val,
long expireTime,
GridCacheVersion ver,
CacheDataRow oldRow)
Stores value in offheap.
|
KeyCacheObject |
GridCacheContext.toCacheKeyObject(byte[] bytes) |
void |
GridCacheProxyImpl.unlock(K key)
Unlocks given key only if current thread owns the lock.
|
void |
IgniteInternalCache.unlock(K key)
Unlocks given key only if current thread owns the lock.
|
void |
GridCacheAdapter.unlock(K key)
Unlocks given key only if current thread owns the lock.
|
void |
GridCacheProxyImpl.unlockAll(Collection<? extends K> keys)
Unlocks given keys only if current thread owns the locks.
|
void |
IgniteInternalCache.unlockAll(Collection<? extends K> keys)
Unlocks given keys only if current thread owns the locks.
|
void |
GridCacheEntryInfo.unmarshal(GridCacheContext ctx,
ClassLoader clsLdr)
Unmarshalls entry.
|
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 needVal)
Unswap ignoring flags.
|
CacheObject |
GridCacheMapEntry.unswap(boolean needVal)
Unswap ignoring flags.
|
protected CacheDataRow |
GridCacheMapEntry.unswap(boolean needVal,
boolean checkExpire)
Unswaps an entry.
|
void |
IgniteCacheOffheapManager.update(KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
int partId,
GridDhtLocalPartition part,
CacheDataRow oldRow) |
void |
IgniteCacheOffheapManagerImpl.update(KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
int partId,
GridDhtLocalPartition part,
CacheDataRow oldRow) |
void |
IgniteCacheOffheapManager.CacheDataStore.update(KeyCacheObject key,
int part,
CacheObject val,
GridCacheVersion ver,
long expireTime,
CacheDataRow oldRow) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.update(KeyCacheObject key,
int p,
CacheObject val,
GridCacheVersion ver,
long expireTime,
CacheDataRow oldRow) |
void |
GridCacheEntryEx.updateIndex(SchemaIndexCacheVisitorClosure clo,
long link)
Update index from within entry lock, passing key, value, and expiration time to provided closure.
|
void |
GridCacheMapEntry.updateIndex(SchemaIndexCacheVisitorClosure clo,
long link)
Update index from within entry lock, passing key, value, and expiration time to provided closure.
|
byte[] |
KeyCacheObjectImpl.valueBytes(CacheObjectContext ctx) |
byte[] |
CacheObjectByteArrayImpl.valueBytes(CacheObjectContext ctx) |
byte[] |
CacheObject.valueBytes(CacheObjectContext ctx) |
byte[] |
CacheObjectImpl.valueBytes(CacheObjectContext ctx) |
CacheObject |
GridCacheEntryEx.valueBytes(GridCacheVersion ver)
Gets cached serialized value bytes.
|
CacheObject |
GridCacheMapEntry.valueBytes(GridCacheVersion ver)
Gets cached serialized value bytes.
|
int |
CacheObjectByteArrayImpl.valueBytesLength(CacheObjectContext ctx) |
int |
CacheObjectAdapter.valueBytesLength(CacheObjectContext ctx) |
int |
CacheObject.valueBytesLength(CacheObjectContext ctx) |
GridCacheVersionedEntryEx |
GridCacheMapEntry.versionedEntry(boolean keepBinary)
Create versioned entry for this cache entry.
|
<K,V> GridCacheVersionedEntryEx<K,V> |
GridCacheEntryEx.versionedEntry(boolean keepBinary)
Create versioned entry for this cache entry.
|
EntryGetResult |
GridCacheEntryEx.versionedValue(CacheObject val,
GridCacheVersion curVer,
GridCacheVersion newVer,
IgniteCacheExpiryPolicy loadExpiryPlc,
ReaderArguments readerArgs)
Sets new value if passed in version matches the current version
(used for read-through only).
|
EntryGetResult |
GridCacheMapEntry.versionedValue(CacheObject val,
GridCacheVersion curVer,
GridCacheVersion newVer,
IgniteCacheExpiryPolicy loadExpiryPlc,
ReaderArguments readerArgs)
Sets new value if passed in version matches the current version
(used for read-through only).
|
| Constructor and Description |
|---|
IgniteCacheOffheapManagerImpl.CacheDataTree(String name,
ReuseList reuseList,
IgniteCacheOffheapManagerImpl.CacheDataRowStore rowStore,
GridCacheContext cctx,
long metaPageId,
boolean initNew) |
IgniteCacheOffheapManagerImpl.PendingEntriesTree(GridCacheContext cctx,
String name,
PageMemory pageMem,
long metaPageId,
ReuseList reuseList,
boolean initNew) |
| Modifier and Type | Method and Description |
|---|---|
CacheObjectContext |
CacheObjectBinaryProcessorImpl.contextForCache(CacheConfiguration cfg) |
byte[] |
CacheObjectBinaryProcessorImpl.marshal(CacheObjectContext ctx,
Object val) |
void |
CacheObjectBinaryProcessorImpl.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
void |
CacheObjectBinaryProcessorImpl.onKernalStart(boolean activeOnStart)
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
void |
CacheObjectBinaryProcessorImpl.start(boolean activeOnStart)
Starts grid component.
|
KeyCacheObject |
CacheObjectBinaryProcessorImpl.toKeyCacheObject(CacheObjectContext ctx,
byte type,
byte[] bytes) |
Object |
CacheObjectBinaryProcessorImpl.unmarshal(CacheObjectContext ctx,
byte[] bytes,
ClassLoader clsLdr) |
| Modifier and Type | Method and Description |
|---|---|
protected long |
DataStructure.acquirePage(long pageId) |
void |
RowStore.addRow(CacheDataRow row) |
protected long |
DataStructure.allocatePage(ReuseBag bag) |
protected long |
DataStructure.allocatePageNoReuse() |
void |
IgniteCacheDatabaseSharedManager.beforeCachesStop() |
void |
IgniteCacheDatabaseSharedManager.beforeExchange(GridDhtPartitionsExchangeFuture discoEvt) |
protected void |
IgniteCacheDatabaseSharedManager.checkPolicyEvictionProperties(MemoryPolicyConfiguration plcCfg,
MemoryConfiguration dbCfg) |
void |
MetadataStorage.destroy()
Destroy this meta store.
|
void |
MetaStore.destroy()
Destroy this meta store.
|
RootPage |
MetadataStorage.dropRootPage(String idxName)
Deallocate index page and remove from tree.
|
RootPage |
MetaStore.dropRootPage(String idxName)
Deallocate index page and remove from tree.
|
void |
IgniteCacheDatabaseSharedManager.ensureFreeSpace(MemoryPolicy memPlc)
|
org.apache.ignite.internal.processors.cache.database.MetadataStorage.IndexItem |
MetadataStorage.MetaStoreInnerIO.getLookupRow(BPlusTree<org.apache.ignite.internal.processors.cache.database.MetadataStorage.IndexItem,?> tree,
long pageAddr,
int idx)
Get lookup row.
|
org.apache.ignite.internal.processors.cache.database.MetadataStorage.IndexItem |
MetadataStorage.MetaStoreLeafIO.getLookupRow(BPlusTree<org.apache.ignite.internal.processors.cache.database.MetadataStorage.IndexItem,?> tree,
long pageAddr,
int idx)
Get lookup row.
|
RootPage |
MetadataStorage.getOrAllocateForTree(String idxName)
Get or allocate initial page for an index.
|
RootPage |
MetaStore.getOrAllocateForTree(String idxName)
Get or allocate initial page for an index.
|
void |
IgniteCacheDatabaseSharedManager.init() |
protected void |
DataStructure.init(long pageId,
PageIO init) |
void |
IgniteCacheDatabaseSharedManager.initDataBase() |
void |
CacheDataRowAdapter.initFromLink(GridCacheContext<?,?> cctx,
CacheDataRowAdapter.RowData rowData)
Read row from data pages.
|
void |
CacheDataRowAdapter.initFromLink(GridCacheContext<?,?> cctx,
GridCacheSharedContext<?,?> sharedCtx,
PageMemory pageMem,
CacheDataRowAdapter.RowData rowData)
Read row from data pages.
|
protected void |
IgniteCacheDatabaseSharedManager.initPageMemoryDataStructures(MemoryConfiguration dbCfg) |
void |
IgniteCacheDatabaseSharedManager.lock() |
MemoryPolicy |
IgniteCacheDatabaseSharedManager.memoryPolicy(String memPlcName) |
void |
IgniteCacheDatabaseSharedManager.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
IgniteCacheDatabaseSharedManager.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
protected <X,R> R |
DataStructure.read(long pageId,
long page,
PageHandler<X,R> h,
X arg,
int intArg,
R lockFailed) |
protected <X,R> R |
DataStructure.read(long pageId,
PageHandler<X,R> h,
X arg,
int intArg,
R lockFailed) |
protected long |
DataStructure.recyclePage(long pageId,
long page,
long pageAddr,
Boolean walPlc) |
void |
RowStore.removeRow(long link) |
protected void |
IgniteCacheDatabaseSharedManager.start0() |
IgniteInternalFuture |
IgniteCacheDatabaseSharedManager.startLocalSnapshotCreation(StartFullSnapshotAckDiscoveryMessage snapshotMsg,
ClusterNode initiator,
String msg) |
void |
MetadataStorage.MetaStoreInnerIO.store(long dstPageAddr,
int dstIdx,
BPlusIO<org.apache.ignite.internal.processors.cache.database.MetadataStorage.IndexItem> srcIo,
long srcPageAddr,
int srcIdx)
Store row info from the given source.
|
void |
MetadataStorage.MetaStoreLeafIO.store(long dstPageAddr,
int dstIdx,
BPlusIO<org.apache.ignite.internal.processors.cache.database.MetadataStorage.IndexItem> srcIo,
long srcPageAddr,
int srcIdx)
Store row info from the given source.
|
void |
MetadataStorage.MetaStoreInnerIO.storeByOffset(long pageAddr,
int off,
org.apache.ignite.internal.processors.cache.database.MetadataStorage.IndexItem row)
Store the needed info about the row in the page.
|
void |
MetadataStorage.MetaStoreLeafIO.storeByOffset(long buf,
int off,
org.apache.ignite.internal.processors.cache.database.MetadataStorage.IndexItem row)
Store the needed info about the row in the page.
|
boolean |
RowStore.updateRow(long link,
CacheDataRow row) |
void |
IgniteCacheDatabaseSharedManager.waitForCheckpoint(String reason)
Waits until current state is checkpointed.
|
protected <X,R> R |
DataStructure.write(long pageId,
long page,
PageHandler<X,R> h,
X arg,
int intArg,
R lockFailed) |
protected <R> R |
DataStructure.write(long pageId,
PageHandler<?,R> h,
int intArg,
R lockFailed) |
protected <X,R> R |
DataStructure.write(long pageId,
PageHandler<X,R> h,
PageIO init,
X arg,
int intArg,
R lockFailed) |
protected <X,R> R |
DataStructure.write(long pageId,
PageHandler<X,R> h,
X arg,
int intArg,
R lockFailed) |
| Modifier and Type | Method and Description |
|---|---|
void |
PageEvictionTracker.evictDataPage()
Evicts one data page.
|
void |
NoOpPageEvictionTracker.evictDataPage()
Evicts one data page.
|
void |
Random2LruPageEvictionTracker.evictDataPage()
Evicts one data page.
|
void |
RandomLruPageEvictionTracker.evictDataPage()
Evicts one data page.
|
void |
FairFifoPageEvictionTracker.evictDataPage()
Evicts one data page.
|
void |
PageEvictionTracker.forgetPage(long pageId)
Call this method when last entry is removed from data page.
|
void |
NoOpPageEvictionTracker.forgetPage(long pageId)
Call this method when last entry is removed from data page.
|
void |
FairFifoPageEvictionTracker.forgetPage(long pageId)
Call this method when last entry is removed from data page.
|
void |
PageEvictionTracker.touchPage(long pageId)
Call this method when data page is accessed.
|
void |
NoOpPageEvictionTracker.touchPage(long pageId)
Call this method when data page is accessed.
|
void |
Random2LruPageEvictionTracker.touchPage(long pageId)
Call this method when data page is accessed.
|
void |
RandomLruPageEvictionTracker.touchPage(long pageId)
Call this method when data page is accessed.
|
void |
FairFifoPageEvictionTracker.touchPage(long pageId)
Call this method when data page is accessed.
|
| Modifier and Type | Method and Description |
|---|---|
void |
FreeListImpl.addForRecycle(ReuseBag bag) |
protected void |
PagesList.init(long metaPageId,
boolean initNew) |
void |
FreeList.insertDataRow(CacheDataRow row) |
void |
FreeListImpl.insertDataRow(CacheDataRow row) |
protected void |
PagesList.put(ReuseBag bag,
long dataId,
long dataPage,
long dataAddr,
int bucket) |
long |
FreeListImpl.recycledPagesCount() |
protected boolean |
PagesList.removeDataPage(long dataId,
long dataPage,
long dataAddr,
DataPageIO dataIO,
int bucket) |
void |
FreeList.removeDataRowByLink(long link) |
void |
FreeListImpl.removeDataRowByLink(long link) |
void |
PagesList.saveMetadata() |
protected long |
PagesList.storedPagesCount(int bucket)
!!!
|
protected long |
PagesList.takeEmptyPage(int bucket,
IOVersions initIoVers) |
long |
FreeListImpl.takeRecycledPage() |
boolean |
FreeList.updateDataRow(long link,
CacheDataRow row) |
boolean |
FreeListImpl.updateDataRow(long link,
CacheDataRow row) |
| Constructor and Description |
|---|
FreeListImpl(int cacheId,
String name,
MemoryMetricsImpl memMetrics,
MemoryPolicy memPlc,
ReuseList reuseList,
IgniteWriteAheadLogManager wal,
long metaPageId,
boolean initNew) |
PagesList(int cacheId,
String name,
PageMemory pageMem,
int buckets,
IgniteWriteAheadLogManager wal,
long metaPageId) |
| Modifier and Type | Method and Description |
|---|---|
protected abstract int |
BPlusTree.compare(BPlusIO<L> io,
long pageAddr,
int idx,
L row) |
long |
BPlusTree.destroy()
Destroys tree.
|
long |
BPlusTree.destroy(IgniteInClosure<L> c)
Destroys tree.
|
GridCursor<T> |
BPlusTree.find(L lower,
L upper) |
T |
BPlusTree.findFirst()
Returns a value mapped to the lowest key, or
null if tree is empty |
T |
BPlusTree.findLast()
Returns a value mapped to the greatest key, or
null if tree is empty |
T |
BPlusTree.findOne(L row) |
<R> R |
BPlusTree.findOne(L row,
Object x) |
protected T |
BPlusTree.getRow(BPlusIO<L> io,
long pageAddr,
int idx)
Get a full detached data row.
|
protected abstract T |
BPlusTree.getRow(BPlusIO<L> io,
long pageAddr,
int idx,
Object x)
Get data row.
|
protected void |
BPlusTree.initTree(boolean initNew)
Initialize new tree.
|
protected void |
BPlusTree.initTree(boolean initNew,
int inlineSize)
Initialize new tree.
|
void |
BPlusTree.invoke(L row,
Object z,
IgniteTree.InvokeClosure<T> c) |
String |
BPlusTree.printTree()
For debug.
|
T |
BPlusTree.put(T row)
Put value in this tree.
|
boolean |
BPlusTree.putx(T row) |
T |
BPlusTree.remove(L row) |
boolean |
BPlusTree.removex(L row) |
int |
BPlusTree.rootLevel() |
long |
BPlusTree.size()
!!!
|
void |
BPlusTree.validateTree() |
| Constructor and Description |
|---|
BPlusTree(String name,
int cacheId,
PageMemory pageMem,
IgniteWriteAheadLogManager wal,
AtomicLong globalRmvId,
long metaPageId,
ReuseList reuseList) |
BPlusTree(String name,
int cacheId,
PageMemory pageMem,
IgniteWriteAheadLogManager wal,
AtomicLong globalRmvId,
long metaPageId,
ReuseList reuseList,
IOVersions<? extends BPlusInnerIO<L>> innerIos,
IOVersions<? extends BPlusLeafIO<L>> leafIos) |
| Modifier and Type | Method and Description |
|---|---|
void |
DataPageIO.addRow(long pageAddr,
byte[] payload,
int pageSize)
Adds row to this data page and sets respective link to the given row object.
|
void |
DataPageIO.addRow(long pageAddr,
CacheDataRow row,
int rowSize,
int pageSize)
Adds row to this data page and sets respective link to the given row object.
|
void |
DataPageIO.addRowFragment(long pageAddr,
byte[] payload,
long lastLink,
int pageSize)
Adds this payload as a fragment to this data page.
|
int |
DataPageIO.addRowFragment(PageMemory pageMem,
long pageAddr,
CacheDataRow row,
int written,
int rowSize,
int pageSize)
Adds maximum possible fragment of the given row to this data page and sets respective link to the row.
|
T |
DataPageIO.CC.apply(long link)
Closure body.
|
void |
BPlusLeafIO.copyItems(long srcPageAddr,
long dstPageAddr,
int srcIdx,
int dstIdx,
int cnt,
boolean cpLeft)
Copy items from source page to destination page.
|
void |
BPlusInnerIO.copyItems(long srcPageAddr,
long dstPageAddr,
int srcIdx,
int dstIdx,
int cnt,
boolean cpLeft)
Copy items from source page to destination page.
|
abstract void |
BPlusIO.copyItems(long srcPageAddr,
long dstPageAddr,
int srcIdx,
int dstIdx,
int cnt,
boolean cpLeft)
Copy items from source page to destination page.
|
<T> List<T> |
DataPageIO.forAllItems(long pageAddr,
DataPageIO.CC<T> c) |
static <Q extends BPlusIO<?>> |
PageIO.getBPlusIO(int type,
int ver) |
static <Q extends BPlusIO<?>> |
PageIO.getBPlusIO(long pageAddr) |
abstract L |
BPlusIO.getLookupRow(BPlusTree<L,?> tree,
long pageAddr,
int idx)
Get lookup row.
|
static <Q extends PageIO> |
PageIO.getPageIO(int type,
int ver) |
static <Q extends PageIO> |
PageIO.getPageIO(long pageAddr) |
byte[] |
BPlusInnerIO.initNewRoot(long newRootPageAddr,
long newRootId,
long leftChildId,
L row,
byte[] rowBytes,
long rightChildId,
int pageSize,
boolean needRowBytes) |
byte[] |
BPlusInnerIO.insert(long pageAddr,
int idx,
L row,
byte[] rowBytes,
long rightId,
boolean needRowBytes) |
byte[] |
BPlusIO.insert(long pageAddr,
int idx,
L row,
byte[] rowBytes,
long rightId,
boolean needRowBytes) |
boolean |
BPlusIO.merge(BPlusIO<L> prntIo,
long prntPageAddr,
int prntIdx,
long leftPageAddr,
long rightPageAddr,
boolean emptyBranch,
int pageSize) |
static GridCacheVersion |
CacheVersionIO.read(ByteBuffer buf,
boolean allowNull)
Reads GridCacheVersion instance from the given buffer.
|
static GridCacheVersion |
CacheVersionIO.read(long pageAddr,
boolean allowNull)
Reads GridCacheVersion instance from the given address.
|
static int |
CacheVersionIO.readSize(ByteBuffer buf,
boolean allowNull)
Gets needed buffer size to read the whole version instance.
|
void |
BPlusIO.remove(long pageAddr,
int idx,
int cnt) |
long |
DataPageIO.removeRow(long pageAddr,
int itemId,
int pageSize) |
void |
BPlusIO.splitForwardPage(long pageAddr,
long fwdId,
long fwdPageAddr,
int mid,
int cnt,
int pageSize) |
abstract void |
BPlusIO.store(long dstPageAddr,
int dstIdx,
BPlusIO<L> srcIo,
long srcPageAddr,
int srcIdx)
Store row info from the given source.
|
byte[] |
BPlusIO.store(long pageAddr,
int idx,
L row,
byte[] rowBytes,
boolean needRowBytes)
Store the needed info about the row in the page.
|
abstract void |
BPlusIO.storeByOffset(long pageAddr,
int off,
L row)
Store the needed info about the row in the page.
|
boolean |
DataPageIO.updateRow(long pageAddr,
int itemId,
int pageSize,
byte[] payload,
CacheDataRow row,
int rowSize) |
| Modifier and Type | Method and Description |
|---|---|
void |
ReuseListImpl.addForRecycle(ReuseBag bag) |
void |
ReuseList.addForRecycle(ReuseBag bag) |
long |
ReuseListImpl.recycledPagesCount() |
long |
ReuseList.recycledPagesCount() |
long |
ReuseListImpl.takeRecycledPage() |
long |
ReuseList.takeRecycledPage() |
| Constructor and Description |
|---|
ReuseListImpl(int cacheId,
String name,
PageMemory pageMem,
IgniteWriteAheadLogManager wal,
long metaPageId,
boolean initNew) |
| Modifier and Type | Method and Description |
|---|---|
static void |
PageHandler.initPage(PageMemory pageMem,
int cacheId,
long pageId,
PageIO init,
IgniteWriteAheadLogManager wal,
PageLockListener lsnr) |
static <X,R> R |
PageHandler.readPage(PageMemory pageMem,
int cacheId,
long pageId,
long page,
PageLockListener lsnr,
PageHandler<X,R> h,
X arg,
int intArg,
R lockFailed) |
static <X,R> R |
PageHandler.readPage(PageMemory pageMem,
int cacheId,
long pageId,
PageLockListener lsnr,
PageHandler<X,R> h,
X arg,
int intArg,
R lockFailed) |
abstract R |
PageHandler.run(int cacheId,
long pageId,
long page,
long pageAddr,
PageIO io,
Boolean walPlc,
X arg,
int intArg) |
static <X,R> R |
PageHandler.writePage(PageMemory pageMem,
int cacheId,
long pageId,
long page,
PageLockListener lsnr,
PageHandler<X,R> h,
PageIO init,
IgniteWriteAheadLogManager wal,
Boolean walPlc,
X arg,
int intArg,
R lockFailed) |
static <X,R> R |
PageHandler.writePage(PageMemory pageMem,
int cacheId,
long pageId,
PageLockListener lsnr,
PageHandler<X,R> h,
PageIO init,
IgniteWriteAheadLogManager wal,
Boolean walPlc,
X arg,
int intArg,
R lockFailed) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
CacheDataStructuresManager.onKernalStart0() |
void |
CacheDataStructuresManager.onReconnected(boolean clusterRestarted) |
<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,
GridCacheContext ctx)
Adds a key.
|
void |
GridDistributedTxRemoteAdapter.commitRemoteTx() |
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 |
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 |
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 |
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 |
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 |
GridDistributedTxRemoteAdapter.forceCommit()
Forces commit for this tx.
|
long |
GridDistributedCacheAdapter.localSizeLong(CachePeekMode[] peekModes) |
long |
GridDistributedCacheAdapter.localSizeLong(int partition,
CachePeekMode[] peekModes) |
void |
GridDistributedTxPrepareResponse.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 |
GridDistributedLockResponse.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 |
GridCacheTtlUpdateRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedTxRemoteAdapter.prepareRemoteTx() |
void |
GridDistributedCacheAdapter.removeAll()
Removes mappings from cache.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridDhtUnreservedPartitionException
Exception that is thrown when a partition reservation failed.
|
| 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 |
GridDhtUnlockRequest.addNearKey(KeyCacheObject key)
Adds a Near key.
|
void |
GridDhtLockRequest.addNearKey(KeyCacheObject key,
GridCacheSharedContext ctx)
Adds a Near key.
|
void |
GridDhtTxRemote.addWrite(IgniteTxEntry entry,
ClassLoader ldr) |
boolean |
GridDhtPartitionTopology.afterExchange(GridDhtPartitionsExchangeFuture exchFut)
Post-initializes this topology.
|
boolean |
GridClientPartitionTopology.afterExchange(GridDhtPartitionsExchangeFuture exchFut)
Post-initializes this topology.
|
void |
GridDhtPartitionTopology.beforeExchange(GridDhtPartitionsExchangeFuture exchFut,
boolean affReady)
Pre-initializes this topology.
|
void |
GridClientPartitionTopology.beforeExchange(GridDhtPartitionsExchangeFuture exchFut,
boolean initParts)
Pre-initializes this topology.
|
AffinityTopologyVersion |
GridDhtCacheAdapter.beginMultiUpdate()
Starts multi-update lock.
|
boolean |
GridDhtCacheEntry.clearInternal(GridCacheVersion ver,
GridCacheObsoleteEntryExtras extras)
Marks entry as obsolete and, if possible or required, removes it
from swap storage.
|
void |
GridDhtCacheAdapter.endMultiUpdate()
Ends multi-update lock.
|
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 |
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 |
GridDhtTxFinishResponse.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 |
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 |
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. |
boolean |
GridDhtTxLocalAdapter.localFinish(boolean commit)
Finishes transaction (either commit or rollback).
|
boolean |
GridDhtTxLocal.localFinish(boolean commit)
Finishes transaction (either commit or rollback).
|
void |
GridDhtCacheAdapter.localLoad(Collection<? extends K> keys,
javax.cache.expiry.ExpiryPolicy plc,
boolean keepBinary) |
void |
GridDhtCacheAdapter.localLoadCache(IgniteBiPredicate<K,V> p,
Object[] args)
Delegates to
CacheStore.loadCache(IgniteBiInClosure, Object...) method
to load state from the underlying persistent storage. |
int |
GridDhtCacheEntry.memorySize() |
void |
GridDhtCacheAdapter.onKernalStart()
Kernal start callback.
|
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 |
GridDhtTxPrepareRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtTxFinishResponse.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 |
GridDhtLockResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtLockRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtTxLocal.rollbackDhtLocal() |
void |
GridDhtCache.start()
Starts this cache.
|
void |
GridDhtTransactionalCacheAdapter.start()
Starts this cache.
|
void |
GridDhtCacheAdapter.start()
Starts this cache.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteCheckedException |
UpdateErrors.error() |
IgniteCheckedException |
GridNearAtomicUpdateResponse.error() |
IgniteCheckedException |
GridDhtAtomicUpdateResponse.error() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearAtomicUpdateResponse.error(IgniteCheckedException err)
Sets update error.
|
void |
UpdateErrors.onError(IgniteCheckedException err) |
void |
GridDhtAtomicUpdateResponse.onError(IgniteCheckedException err)
Sets update error.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridDhtAtomicCache.checkJta()
Checks if cache is working in JTA transaction and enlist cache as XAResource if necessary.
|
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 |
GridNearAtomicFullUpdateRequest.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 |
GridNearAtomicSingleUpdateInvokeRequest.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 |
GridDhtAtomicNearResponse.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 |
GridNearAtomicSingleUpdateFilterRequest.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 |
GridNearAtomicSingleUpdateRequest.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 |
GridDhtAtomicSingleUpdateRequest.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. |
V |
GridDhtAtomicCache.get0(K key,
boolean deserializeBinary,
boolean needVer) |
protected Map<K,V> |
GridDhtAtomicCache.getAll0(Collection<? extends K> keys,
boolean deserializeBinary,
boolean needVer) |
protected V |
GridDhtAtomicCache.getAndPut0(K key,
V val,
CacheEntryPredicate filter) |
V |
GridDhtAtomicCache.getAndRemove0(K key) |
<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 |
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 |
GridNearAtomicFullUpdateRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearAtomicSingleUpdateInvokeRequest.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 |
GridDhtAtomicNearResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearAtomicSingleUpdateFilterRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearAtomicSingleUpdateRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtAtomicSingleUpdateRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
protected boolean |
GridDhtAtomicCache.put0(K key,
V val,
CacheEntryPredicate filter) |
protected void |
GridDhtAtomicCache.putAll0(Map<? extends K,? extends V> m) |
void |
GridDhtAtomicCache.putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> conflictMap)
Store DR data.
|
protected boolean |
GridDhtAtomicCache.remove0(K key,
CacheEntryPredicate filter) |
protected void |
GridDhtAtomicCache.removeAll0(Collection<? extends K> keys) |
void |
GridDhtAtomicCache.removeAllConflict(Map<KeyCacheObject,GridCacheVersion> conflictMap)
Removes DR data.
|
void |
GridDhtAtomicCache.start()
Starts this cache.
|
| Constructor and Description |
|---|
UpdateErrors(IgniteCheckedException err) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridDhtDetachedCacheEntry.logUpdate(GridCacheOperation op,
CacheObject val,
GridCacheVersion writeVer,
long expireTime,
long updCntr) |
protected void |
GridDhtDetachedCacheEntry.removeValue()
Removes value from offheap.
|
void |
GridDhtColocatedCache.start()
Starts this cache.
|
protected void |
GridDhtDetachedCacheEntry.storeValue(CacheObject val,
long expireTime,
GridCacheVersion ver,
CacheDataRow oldRow)
Stores value in offheap.
|
CacheDataRow |
GridDhtDetachedCacheEntry.unswap(boolean needVal,
boolean checkExpire)
Unswaps an entry.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteCheckedException |
GridDhtForceKeysResponse.error() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtForceKeysResponse.error(IgniteCheckedException err)
Sets error.
|
| Modifier and Type | Method and Description |
|---|---|
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 |
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 |
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 |
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 |
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 |
GridDhtForceKeysRequest.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 |
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.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteCheckedException |
GridNearGetResponse.error() |
IgniteCheckedException |
GridNearSingleGetResponse.error() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearGetResponse.error(IgniteCheckedException err) |
void |
GridNearSingleGetResponse.error(IgniteCheckedException err) |
| 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,
boolean skipStore,
boolean keepBinary) |
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() |
void |
GridNearTxLocal.commit() |
void |
GridNearLockRequest.filter(CacheEntryPredicate[] filter,
GridCacheContext ctx) |
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 |
GridNearSingleGetRequest.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. |
void |
GridNearSingleGetResponse.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. |
V |
GridNearAtomicCache.getAndPut(K key,
V val,
CacheEntryPredicate filter) |
V |
GridNearAtomicCache.getAndRemove(K key)
Removes given key mapping from cache.
|
<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,
long ttl,
long expireTime,
boolean evt,
boolean keepBinary,
AffinityTopologyVersion topVer,
UUID subjId) |
boolean |
GridNearTxLocal.localFinish(boolean commit)
Finishes transaction (either commit or rollback).
|
void |
GridNearCacheAdapter.localLoad(Collection<? extends K> keys,
javax.cache.expiry.ExpiryPolicy plc,
boolean keepBinary) |
void |
GridNearCacheAdapter.localLoadCache(IgniteBiPredicate<K,V> p,
Object[] args)
Delegates to
CacheStore.loadCache(IgniteBiInClosure, Object...) method
to load state from the underlying persistent storage. |
protected void |
GridNearCacheEntry.logUpdate(GridCacheOperation op,
CacheObject val,
GridCacheVersion ver,
long expireTime,
long updCntr) |
int |
GridNearCacheEntry.memorySize() |
void |
GridNearTxLocal.prepare() |
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 |
GridNearSingleGetRequest.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.
|
void |
GridNearSingleGetResponse.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.
|
boolean |
GridNearAtomicCache.put(K key,
V val,
CacheEntryPredicate filter) |
void |
GridNearAtomicCache.putAll(Map<? extends K,? extends V> m)
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.
|
protected Object |
GridNearCacheEntry.readThrough(IgniteInternalTx tx,
KeyCacheObject key,
boolean reload,
UUID subjId,
String taskName) |
boolean |
GridNearAtomicCache.remove(K key)
Removes given key mapping from cache.
|
boolean |
GridNearAtomicCache.remove(K key,
CacheEntryPredicate filter) |
void |
GridNearAtomicCache.removeAll()
Removes mappings from cache.
|
void |
GridNearAtomicCache.removeAll(Collection<? extends K> keys)
Removes given key mappings from cache.
|
void |
GridNearAtomicCache.removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data.
|
IgniteInternalFuture<?> |
GridNearAtomicCache.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
void |
GridNearTxLocal.rollback() |
void |
GridNearAtomicCache.start()
Starts this cache.
|
void |
GridNearTransactionalCache.start()
Starts this cache.
|
GridNearTxRemote |
GridNearTransactionalCache.startRemoteTx(UUID nodeId,
GridDhtLockRequest req) |
void |
GridNearAtomicCache.unlockAll(Collection<? extends K> keys)
Unlocks given keys only if current thread owns the locks.
|
| Constructor and Description |
|---|
GridNearTxRemote(GridCacheSharedContext ctx,
AffinityTopologyVersion topVer,
ClassLoader ldr,
UUID nodeId,
UUID nearNodeId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
byte plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
Collection<IgniteTxEntry> writeEntries,
int txSize,
UUID subjId,
int taskNameHash)
This constructor is meant for optimistic transactions.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridOsCacheDrManager.onExchange(AffinityTopologyVersion topVer,
boolean left)
Process partitions exchange event.
|
void |
GridCacheDrManager.onExchange(AffinityTopologyVersion topVer,
boolean left)
Process partitions exchange event.
|
void |
GridOsCacheDrManager.onKernalStart() |
void |
GridCacheDrManager.replicate(KeyCacheObject key,
CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
GridDrType drType,
AffinityTopologyVersion topVer)
Performs replication.
|
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.registerCache(CacheConfiguration<?,?> cfg) |
| Modifier and Type | Method and Description |
|---|---|
long |
GridLocalCache.localSizeLong(CachePeekMode[] peekModes) |
long |
GridLocalCache.localSizeLong(int part,
CachePeekMode[] peekModes) |
void |
GridLocalCache.unlockAll(Collection<? extends K> keys)
Unlocks given keys only if current thread owns the locks.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridLocalAtomicCache.checkJta()
Checks if cache is working in JTA transaction and enlist cache as XAResource if necessary.
|
protected V |
GridLocalAtomicCache.get0(K key,
String taskName,
boolean deserializeBinary,
boolean needVer) |
Map<K,V> |
GridLocalAtomicCache.getAll0(Collection<? extends K> keys,
boolean deserializeBinary,
boolean needVer) |
protected V |
GridLocalAtomicCache.getAndPut0(K key,
V val,
CacheEntryPredicate filter) |
protected V |
GridLocalAtomicCache.getAndRemove0(K key) |
<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) |
protected boolean |
GridLocalAtomicCache.put0(K key,
V val,
CacheEntryPredicate filter) |
protected void |
GridLocalAtomicCache.putAll0(Map<? extends K,? extends V> m) |
boolean |
GridLocalAtomicCache.remove0(K key,
CacheEntryPredicate filter) |
void |
GridLocalAtomicCache.removeAll0(Collection<? extends K> keys) |
void |
GridLocalAtomicCache.unlockAll(Collection<? extends K> keys)
Unlocks given keys only if current thread owns the locks.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheLocalQueryFuture.awaitFirstPage()
Waits for the first page to be received from remote node(s), if any.
|
abstract void |
GridCacheQueryFutureAdapter.awaitFirstPage()
Waits for the first page to be received from remote node(s), if any.
|
void |
GridCacheDistributedQueryFuture.awaitFirstPage()
Waits for the first page to be received from remote node(s), if any.
|
boolean |
GridCacheQueryFutureAdapter.cancel()
Default no-op implementation that always returns
false. |
boolean |
CacheQueryFuture.cancel()
Cancels this query future and stop receiving any further results for the query
associated with this future.
|
protected void |
GridCacheLocalQueryFuture.cancelQuery() |
protected abstract void |
GridCacheQueryFutureAdapter.cancelQuery() |
protected void |
GridCacheDistributedQueryFuture.cancelQuery() |
void |
QueryCursorEx.Consumer.consume(T val)
Consume value.
|
GridCloseableIterator |
CacheQuery.executeScanQuery() |
GridCloseableIterator |
GridCacheQueryAdapter.executeScanQuery() |
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.
|
Collection<R> |
GridCacheQueryFutureAdapter.getUninterruptibly()
Synchronously waits for completion of the computation and returns computation result ignoring interrupts.
|
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 |
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(KeyCacheObject key,
int partId,
CacheObject val,
GridCacheVersion ver) |
abstract GridCloseableIterator |
GridCacheQueryManager.scanQueryDistributed(GridCacheQueryAdapter qry,
Collection<ClusterNode> nodes)
Executes distributed SCAN query.
|
GridCloseableIterator |
GridCacheLocalQueryManager.scanQueryDistributed(GridCacheQueryAdapter qry,
Collection<ClusterNode> nodes)
Executes distributed SCAN query.
|
GridCloseableIterator |
GridCacheDistributedQueryManager.scanQueryDistributed(GridCacheQueryAdapter qry,
Collection<ClusterNode> nodes)
Executes distributed SCAN query.
|
protected GridCloseableIterator |
GridCacheQueryManager.scanQueryLocal(GridCacheQueryAdapter qry,
boolean updStatisticsIfNeeded)
Process local scan query.
|
Collection<GridCacheSqlMetadata> |
GridCacheQueryManager.sqlMetadata()
Gets SQL metadata.
|
void |
GridCacheQueryManager.start0() |
void |
GridCacheLocalQueryManager.start0() |
void |
GridCacheDistributedQueryManager.start0() |
void |
GridCacheQueryManager.store(KeyCacheObject key,
int partId,
CacheObject prevVal,
GridCacheVersion prevVer,
CacheObject val,
GridCacheVersion ver,
long expirationTime,
long link)
Writes key-value pair to index.
|
protected <T> List<T> |
GridCacheQueryResponse.unmarshalCollection0(Collection<byte[]> byteCol,
GridCacheSharedContext ctx,
ClassLoader ldr) |
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,
boolean ignoreClassNotFound) |
void |
CacheContinuousQueryManager.executeJCacheQuery(javax.cache.configuration.CacheEntryListenerConfiguration cfg,
boolean onStart,
boolean keepBinary) |
UUID |
CacheContinuousQueryManager.executeQuery(javax.cache.event.CacheEntryUpdatedListener locLsnr,
CacheEntryEventSerializableFilter rmtFilter,
javax.cache.configuration.Factory<? extends javax.cache.event.CacheEntryEventFilter> rmtFilterFactory,
int bufSize,
long timeInterval,
boolean autoUnsubscribe,
boolean loc,
boolean keepBinary,
boolean includeExpired) |
Iterable<javax.cache.event.CacheEntryEvent<?,?>> |
CacheContinuousQueryManager.existingEntries(boolean keepBinary,
javax.cache.event.CacheEntryEventFilter filter) |
void |
CacheContinuousQueryManager.onEntryExpired(GridCacheEntryEx e,
KeyCacheObject key,
CacheObject oldVal) |
void |
CacheContinuousQueryManager.onEntryUpdated(KeyCacheObject key,
CacheObject newVal,
CacheObject oldVal,
boolean internal,
int partId,
boolean primary,
boolean preload,
long updateCntr,
GridDhtAtomicAbstractUpdateFuture fut,
AffinityTopologyVersion topVer) |
void |
CacheContinuousQueryManager.onEntryUpdated(Map<UUID,CacheContinuousQueryListener> lsnrCol,
KeyCacheObject key,
CacheObject newVal,
CacheObject oldVal,
boolean internal,
int partId,
boolean primary,
boolean preload,
long updateCntr,
GridDhtAtomicAbstractUpdateFuture fut,
AffinityTopologyVersion topVer) |
protected void |
CacheContinuousQueryManager.onKernalStart0() |
void |
CacheContinuousQueryHandlerV2.p2pMarshal(GridKernalContext ctx)
Deploys and marshals inner objects (called only if peer deployment is enabled).
|
void |
CacheContinuousQueryHandler.p2pMarshal(GridKernalContext ctx)
Deploys and marshals inner objects (called only if peer deployment is enabled).
|
void |
CacheContinuousQueryHandlerV2.p2pUnmarshal(UUID nodeId,
GridKernalContext ctx)
Unmarshals inner objects (called only if peer deployment is enabled).
|
void |
CacheContinuousQueryHandler.p2pUnmarshal(UUID nodeId,
GridKernalContext ctx)
Unmarshals inner objects (called only if peer deployment is enabled).
|
GridContinuousHandler.RegisterStatus |
CacheContinuousQueryHandler.register(UUID nodeId,
UUID routineId,
GridKernalContext ctx)
Registers listener.
|
protected void |
CacheContinuousQueryManager.start0() |
void |
CacheContinuousQueryHandler.waitTopologyFuture(GridKernalContext ctx)
Wait topology.
|
| Constructor and Description |
|---|
CacheContinuousQueryHandler.DeployableObject(Object obj,
GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
void |
CacheStoreManager.forceFlush() |
void |
GridCacheWriteBehindStore.forceFlush()
Forces all entries collected to be flushed to the underlying store.
|
void |
GridCacheStoreManagerAdapter.forceFlush() |
void |
CacheStoreManager.initialize(CacheStore<?,?> cfgStore,
Map<CacheStore,ThreadLocal> sesHolders)
Initialize store manager.
|
void |
GridCacheStoreManagerAdapter.initialize(CacheStore cfgStore,
Map sesHolders)
Initialize store manager.
|
Object |
CacheStoreManager.load(IgniteInternalTx tx,
KeyCacheObject key)
Loads data from persistent store.
|
Object |
GridCacheStoreManagerAdapter.load(IgniteInternalTx tx,
KeyCacheObject key)
Loads data from persistent store.
|
boolean |
CacheStoreManager.loadAll(IgniteInternalTx tx,
Collection<? extends KeyCacheObject> keys,
IgniteBiInClosure<KeyCacheObject,Object> vis)
Loads data from persistent store.
|
boolean |
GridCacheStoreManagerAdapter.loadAll(IgniteInternalTx tx,
Collection keys,
IgniteBiInClosure vis)
Loads data from persistent store.
|
boolean |
CacheStoreManager.loadCache(GridInClosure3<KeyCacheObject,Object,GridCacheVersion> vis,
Object[] args)
Loads data from persistent store.
|
boolean |
GridCacheStoreManagerAdapter.loadCache(GridInClosure3 vis,
Object[] args)
Loads data from persistent store.
|
void |
CacheStoreManager.localStoreLoadAll(IgniteInternalTx tx,
Collection<? extends KeyCacheObject> keys,
GridInClosure3<KeyCacheObject,Object,GridCacheVersion> vis) |
void |
GridCacheStoreManagerAdapter.localStoreLoadAll(IgniteInternalTx tx,
Collection keys,
GridInClosure3 vis) |
boolean |
CacheStoreManager.put(IgniteInternalTx tx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver)
Puts key-value pair into storage.
|
boolean |
GridCacheStoreManagerAdapter.put(IgniteInternalTx tx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver)
Puts key-value pair into storage.
|
boolean |
CacheStoreManager.putAll(IgniteInternalTx tx,
Map<? extends KeyCacheObject,IgniteBiTuple<? extends CacheObject,GridCacheVersion>> map)
Puts key-value pair into storage.
|
boolean |
GridCacheStoreManagerAdapter.putAll(IgniteInternalTx tx,
Map<? extends KeyCacheObject,IgniteBiTuple<? extends CacheObject,GridCacheVersion>> map)
Puts key-value pair into storage.
|
boolean |
CacheStoreManager.remove(IgniteInternalTx tx,
KeyCacheObject key) |
boolean |
GridCacheStoreManagerAdapter.remove(IgniteInternalTx tx,
KeyCacheObject key) |
boolean |
CacheStoreManager.removeAll(IgniteInternalTx tx,
Collection<? extends KeyCacheObject> keys) |
boolean |
GridCacheStoreManagerAdapter.removeAll(IgniteInternalTx tx,
Collection<? extends KeyCacheObject> keys) |
void |
CacheStoreManager.sessionEnd(IgniteInternalTx tx,
boolean commit,
boolean last) |
void |
GridCacheStoreManagerAdapter.sessionEnd(IgniteInternalTx tx,
boolean commit,
boolean last) |
protected void |
CacheOsStoreManager.start0() |
protected void |
GridCacheStoreManagerAdapter.start0() |
void |
CacheStoreManager.writeBehindSessionEnd(boolean threwEx)
End session initiated by write-behind store.
|
void |
GridCacheStoreManagerAdapter.writeBehindSessionEnd(boolean threwEx)
End session initiated by write-behind store.
|
void |
CacheStoreManager.writeBehindSessionInit()
End session initiated by write-behind store.
|
void |
GridCacheStoreManagerAdapter.writeBehindSessionInit()
End session initiated by write-behind store.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteCheckedException |
IgniteTxAdapter.timeoutException() |
IgniteCheckedException |
IgniteTxImplicitSingleStateImpl.validateTopology(GridCacheSharedContext cctx,
boolean read,
GridDhtTopologyFuture topFut) |
IgniteCheckedException |
IgniteTxStateImpl.validateTopology(GridCacheSharedContext cctx,
boolean read,
GridDhtTopologyFuture topFut) |
IgniteCheckedException |
IgniteTxRemoteStateAdapter.validateTopology(GridCacheSharedContext cctx,
boolean read,
GridDhtTopologyFuture topFut) |
IgniteCheckedException |
IgniteTxState.validateTopology(GridCacheSharedContext cctx,
boolean read,
GridDhtTopologyFuture topFut) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
IgniteTxLocalAdapter.addActiveCache(GridCacheContext cacheCtx,
boolean recovery)
Adds cache to the list of active caches in transaction.
|
void |
IgniteTxImplicitSingleStateImpl.addActiveCache(GridCacheContext ctx,
boolean recovery,
IgniteTxLocalAdapter tx) |
void |
IgniteTxStateImpl.addActiveCache(GridCacheContext cacheCtx,
boolean recovery,
IgniteTxLocalAdapter tx) |
void |
IgniteTxRemoteStateAdapter.addActiveCache(GridCacheContext cacheCtx,
boolean recovery,
IgniteTxLocalAdapter tx) |
void |
IgniteTxState.addActiveCache(GridCacheContext cacheCtx,
boolean recovery,
IgniteTxLocalAdapter tx) |
protected IgniteBiTuple<GridCacheOperation,CacheObject> |
IgniteTxAdapter.applyTransformClosures(IgniteTxEntry txEntry,
boolean metrics,
GridCacheReturn ret) |
protected void |
IgniteTxAdapter.batchStoreCommit(Iterable<IgniteTxEntry> writeEntries)
Performs batch database operations.
|
protected void |
IgniteTxLocalAdapter.checkValid()
Checks transaction expiration.
|
void |
IgniteTxRemoteEx.commitRemoteTx() |
void |
IgniteTxManager.commitTx(IgniteInternalTx tx)
Commits a transaction.
|
protected IgniteBiTuple<GridCacheOperation,GridCacheVersionConflictContext> |
IgniteTxAdapter.conflictResolve(GridCacheOperation op,
IgniteTxEntry txEntry,
CacheObject newVal,
GridCacheVersion newVer,
GridCacheEntryEx old)
Resolve DR conflict.
|
void |
IgniteTxKey.finishUnmarshal(GridCacheContext ctx,
ClassLoader ldr) |
void |
TxLocksResponse.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 |
TxLocksRequest.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. |
boolean |
IgniteTxLocalEx.localFinish(boolean commit)
Finishes transaction (either commit or rollback).
|
void |
TxEntryValueHolder.marshal(GridCacheContext<?,?> ctx) |
void |
IgniteTxEntry.marshal(GridCacheSharedContext<?,?> ctx,
boolean transferExpiry) |
protected abstract IgniteInternalFuture<T> |
IgniteTxLocalAdapter.PostLockClosure2.postLock()
Post lock callback.
|
protected abstract T |
IgniteTxLocalAdapter.PostLockClosure1.postLock(T val)
Post lock callback.
|
protected void |
IgniteTxLocalAdapter.postLockWrite(GridCacheContext cacheCtx,
Iterable<KeyCacheObject> keys,
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 |
IgniteTxKey.prepareMarshal(GridCacheContext ctx) |
void |
TxLocksResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
TxLocksRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
IgniteTxManager.prepareTx(IgniteInternalTx tx,
Collection<IgniteTxEntry> entries)
Handles prepare stage.
|
protected void |
IgniteTxAdapter.sessionEnd(Collection<CacheStoreManager> stores,
boolean commit) |
protected void |
IgniteTxManager.start0() |
GridNearTxRemote |
IgniteTxHandler.startNearRemoteTx(ClassLoader ldr,
UUID nodeId,
GridDhtTxPrepareRequest req)
Called while processing dht tx prepare request.
|
void |
IgniteTxLocalAdapter.tmFinish(boolean commit)
Commits transaction to transaction manager.
|
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(Collection<IgniteTxEntry> entries) |
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(boolean reconnect) |
void |
GridCacheRawVersionedEntry.prepareDirectMarshal(CacheObjectContext ctx) |
<K,V> GridCacheVersionConflictContext<K,V> |
CacheVersionConflictResolver.resolve(GridCacheVersionedEntryEx<K,V> oldEntry,
GridCacheVersionedEntryEx<K,V> newEntry,
boolean atomicVerComparator)
Resolve the conflict.
|
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 |
|---|---|
<R> ComputeTaskInternalFuture<R> |
GridClosureProcessor.affinityCall(Collection<String> cacheNames,
int partId,
Callable<R> job,
Collection<ClusterNode> nodes,
String execName) |
ComputeTaskInternalFuture<?> |
GridClosureProcessor.affinityRun(Collection<String> cacheNames,
int partId,
Runnable job,
Collection<ClusterNode> nodes,
String execName) |
<R> IgniteInternalFuture<R> |
GridClosureProcessor.callLocal(Callable<R> c,
byte plc) |
IgniteInternalFuture<?> |
GridClosureProcessor.runLocal(Runnable c,
byte plc) |
void |
GridClosureProcessor.start(boolean activeOnStart)
Starts grid component.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteChangeGlobalStateSupport.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
IgniteChangeGlobalStateSupport.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
void |
ClusterProcessor.onKernalStart(boolean activeOnStart)
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
void |
GridClusterStateProcessor.start(boolean activeOnStart)
Starts grid component.
|
void |
ClusterProcessor.stop(boolean cancel)
Stops grid component.
|
void |
GridClusterStateProcessor.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
Map<UUID,IgniteCheckedException> |
StartRoutineAckDiscoveryMessage.errs() |
Map<UUID,IgniteCheckedException> |
StartRoutineDiscoveryMessage.errs() |
| Modifier and Type | Method and Description |
|---|---|
void |
StartRoutineDiscoveryMessage.addError(UUID nodeId,
IgniteCheckedException e) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridContinuousProcessor.addBackupNotification(UUID nodeId,
UUID routineId,
Collection<?> objs,
Object orderedTopic) |
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 |
GridContinuousProcessor.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
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.
|
UUID |
GridContinuousProcessor.registerStaticRoutine(String cacheName,
javax.cache.event.CacheEntryUpdatedListener<?,?> locLsnr,
CacheEntryEventSerializableFilter rmtFilter,
IgnitePredicate<ClusterNode> prjPred)
Registers routine info to be sent in discovery data during this node join
(to be used for internal queries started from client nodes).
|
void |
GridContinuousProcessor.start(boolean activeOnStart)
Starts grid component.
|
void |
GridContinuousProcessor.stop(boolean cancel)
Stops grid component.
|
| Constructor and Description |
|---|
StartRoutineAckDiscoveryMessage(UUID routineId,
Map<UUID,IgniteCheckedException> errs,
Map<Integer,T2<Long,Long>> cntrs,
Map<UUID,Map<Integer,T2<Long,Long>>> cntrsPerNode) |
| Modifier and Type | Method and Description |
|---|---|
void |
DataStreamerImpl.closeEx(boolean cancel) |
void |
DataStreamProcessor.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
void |
DataStreamerImpl.onDisconnected(IgniteFuture<?> reconnectFut) |
void |
DataStreamProcessor.start(boolean activeOnStart)
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.
|
boolean |
GridCacheSetImpl.checkHeader() |
IgniteCountDownLatch |
DataStructuresProcessor.countDownLatch(String name,
int cnt,
boolean autoDel,
boolean create)
Gets or creates count down latch.
|
void |
DataStructuresProcessor.onActivate(GridKernalContext ctx)
Called when cluster performing activation.
|
void |
GridCacheAtomicLongImpl.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
GridCacheAtomicReferenceImpl.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
GridCacheSemaphoreImpl.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
GridCacheCountDownLatchImpl.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
GridCacheAtomicStampedImpl.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
GridCacheLockImpl.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
GridCacheAtomicSequenceImpl.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
DataStructuresProcessor.onDeActivate(GridKernalContext ctx)
Called when cluster performing deactivation.
|
void |
GridCacheAtomicLongImpl.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
void |
GridCacheAtomicReferenceImpl.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
void |
GridCacheSemaphoreImpl.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
void |
GridCacheCountDownLatchImpl.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
void |
GridCacheAtomicStampedImpl.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
void |
GridCacheLockImpl.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
void |
GridCacheAtomicSequenceImpl.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
void |
DataStructuresProcessor.onKernalStart(boolean activeOnStart)
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
IgniteInternalFuture<?> |
DataStructuresProcessor.onReconnected(boolean clusterRestarted)
Client reconnected callback.
|
<T> IgniteQueue<T> |
DataStructuresProcessor.queue(String name,
int cap,
CollectionConfiguration cfg)
Gets a queue from cache or creates one if it's not cached.
|
IgniteLock |
DataStructuresProcessor.reentrantLock(String name,
boolean failoverSafe,
boolean fair,
boolean create)
Gets or creates reentrant lock.
|
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.removeReentrantLock(String name,
boolean broken)
Removes reentrant lock from cache.
|
void |
DataStructuresProcessor.removeSemaphore(String name)
Removes semaphore from cache.
|
void |
DataStructuresProcessor.removeSet(String name,
GridCacheContext cctx) |
static <R> R |
DataStructuresProcessor.retry(IgniteLogger log,
Callable<R> call) |
IgniteSemaphore |
DataStructuresProcessor.semaphore(String name,
int cnt,
boolean failoverSafe,
boolean create)
Gets or creates semaphore.
|
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.
|
void |
DataStructuresProcessor.start(boolean activeOnStart)
Starts grid component.
|
| Modifier and Type | Method and Description |
|---|---|
abstract void |
HadoopTaskContext.cleanupTaskEnvironment()
Cleans up local environment of the task.
|
abstract void |
HadoopJobEx.cleanupTaskEnvironment(HadoopTaskInfo info)
Cleans up local environment of the task.
|
void |
HadoopTaskOutput.close()
Closes output.
|
void |
HadoopTaskInput.close()
Closes input.
|
void |
HadoopSerialization.close()
Finalise the internal objects.
|
abstract HadoopCounters |
HadoopProcessorAdapter.counters(HadoopJobId jobId)
Returns Hadoop job counters.
|
HadoopCounters |
Hadoop.counters(HadoopJobId jobId)
Returns job counters.
|
HadoopJobEx |
HadoopJobInfo.createJob(Class<? extends HadoopJobEx> jobCls,
HadoopJobId jobId,
IgniteLogger log,
String[] libNames,
HadoopHelper helper)
Creates new job instance for the given ID.
|
HadoopJobEx |
HadoopDefaultJobInfo.createJob(Class<? extends HadoopJobEx> jobCls,
HadoopJobId jobId,
IgniteLogger log,
String[] libNames,
HadoopHelper helper)
Creates new job instance for the given ID.
|
abstract void |
HadoopJobEx.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.
|
abstract HadoopTaskContext |
HadoopJobEx.getTaskContext(HadoopTaskInfo info)
Returns context for task execution.
|
static Collection<URL> |
HadoopClassLoader.hadoopUrls() |
abstract void |
HadoopJobEx.initialize(boolean external,
UUID locNodeId)
Does all the needed initialization for the 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.
|
void |
HadoopTaskContext.onMapperFinished()
Callback invoked from mapper thread when map is finished.
|
void |
HadoopMapperAwareTaskOutput.onMapperFinished()
Callback invoked when mapper finished writing data.
|
abstract HadoopPartitioner |
HadoopTaskContext.partitioner()
Gets partitioner.
|
abstract void |
HadoopTaskContext.prepareTaskEnvironment()
Prepare local environment for the task.
|
abstract void |
HadoopJobEx.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.
|
abstract <T> T |
HadoopTaskContext.runAsJobOwner(Callable<T> c)
Executes a callable on behalf of the job owner.
|
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.
|
void |
HadoopNoopProcessor.validateEnvironment()
Validate Hadoop environment.
|
abstract void |
HadoopProcessorAdapter.validateEnvironment()
Validate Hadoop environment.
|
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(HadoopJobEx job,
HadoopCounters cntrs)
Writes counters of given job to some statistics storage.
|
| Modifier and Type | Method and Description |
|---|---|
void |
HadoopShuffleMessage.Visitor.onKey(byte[] buf,
int off,
int len) |
void |
HadoopShuffleMessage.Visitor.onValue(byte[] buf,
int off,
int len) |
void |
HadoopShuffleMessage.visit(HadoopShuffleMessage.Visitor v) |
| Modifier and Type | Class and Description |
|---|---|
class |
IgfsFileWorkerBatchCancelledException
Exception indicating that file batch processing was cancelled.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteCheckedException |
IgfsDeleteMessage.error() |
IgniteCheckedException |
IgfsAckMessage.error() |
| Modifier and Type | Method and Description |
|---|---|
Collection<IgfsBlockLocation> |
IgfsDataManager.affinity(IgfsEntryInfo info,
long start,
long len)
Resolve affinity nodes for specified part of file.
|
Collection<IgfsBlockLocation> |
IgfsDataManager.affinity(IgfsEntryInfo info,
long start,
long len,
long maxLen)
Resolve affinity nodes for specified part of file.
|
IgfsCreateResult |
IgfsMetaManager.appendDual(IgfsSecondaryFileSystem fs,
IgfsPath path,
int bufSize,
boolean create)
Append to a file in DUAL mode.
|
IgniteInternalFuture<byte[]> |
IgfsDataManager.dataBlock(IgfsEntryInfo fileInfo,
IgfsPath path,
long blockIdx,
IgfsSecondaryFileSystemPositionedReadable secReader)
Get data block for specified file ID and block index.
|
protected IgniteInternalFuture<byte[]> |
IgfsInputStreamImpl.dataBlock(long blockIdx)
Get data block for specified block index.
|
Map<String,IgfsListingEntry> |
IgfsMetaManager.directoryListing(IgniteUuid fileId)
List child files for specified file ID.
|
static <T> T |
IgfsUtils.doInTransactionWithRetries(IgniteInternalCache cache,
IgniteOutClosureX<T> clo)
Performs an operation with transaction with retries.
|
boolean |
IgfsMetaManager.exists(IgniteUuid fileId)
Ensure that entry with the given ID exists in meta cache.
|
IgfsEntryInfo |
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 |
IgfsDeleteMessage.finishUnmarshal(Marshaller marsh,
ClassLoader ldr) |
void |
IgfsCommunicationMessage.finishUnmarshal(Marshaller marsh,
ClassLoader ldr) |
void |
IgfsAckMessage.finishUnmarshal(Marshaller marsh,
ClassLoader ldr) |
void |
IgfsEx.globalSampling(Boolean val)
Enables, disables or clears sampling flag.
|
void |
IgfsImpl.globalSampling(Boolean val)
Enables, disables or clears sampling flag.
|
void |
IgfsAsyncImpl.globalSampling(Boolean val)
Enables, disables or clears sampling flag.
|
IgfsStatus |
IgfsEx.globalSpace()
Gets global space counters.
|
IgfsStatus |
IgfsAsyncImpl.globalSpace()
Gets global space counters.
|
List<IgniteUuid> |
IgfsMetaManager.idsForPath(IgfsPath path)
Get IDs for the given path.
|
IgfsEntryInfo |
IgfsMetaManager.info(IgniteUuid fileId)
Gets file info by its ID.
|
IgfsEntryInfo |
IgfsMetaManager.infoForPath(IgfsPath path)
Get info for the given path.
|
Map<IgniteUuid,IgfsEntryInfo> |
IgfsMetaManager.infos(Collection<IgniteUuid> fileIds)
Gets files details by their IDs.
|
IgfsEntryInfo |
IgfsMetaManager.lock(IgniteUuid fileId,
boolean del)
Lock the file explicitly outside of transaction.
|
boolean |
IgfsMetaManager.mkdirsDual(IgfsSecondaryFileSystem fs,
IgfsPath path,
Map<String,String> props)
Create directory in DUAL mode.
|
void |
IgfsMetaManager.move(IgfsPath srcPath,
IgfsPath dstPath)
Move routine.
|
void |
IgfsManager.onKernalStart() |
void |
IgfsProcessor.onKernalStart(boolean activeOnStart)
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
protected void |
IgfsMetaManager.onKernalStart0() |
protected void |
IgfsManager.onKernalStart0() |
protected void |
IgfsServerManager.onKernalStart0() |
protected void |
IgfsDataManager.onKernalStart0() |
protected void |
IgfsFragmentizerManager.onKernalStart0() |
IgfsSecondaryInputStreamDescriptor |
IgfsMetaManager.openDual(IgfsSecondaryFileSystem fs,
IgfsPath path,
int bufSize)
Open file in DUAL mode.
|
IgfsPathIds |
IgfsMetaManager.pathIds(IgfsPath path)
Gets all file IDs for components of specified path.
|
static void |
IgfsUtils.prepareCacheConfigurations(IgniteConfiguration cfg)
Prepare cache configuration if this is IGFS meta or data cache.
|
void |
IgfsDeleteMessage.prepareMarshal(Marshaller marsh) |
void |
IgfsCommunicationMessage.prepareMarshal(Marshaller marsh) |
void |
IgfsAckMessage.prepareMarshal(Marshaller marsh) |
static ArrayList<T2<IgfsPath,IgfsMode>> |
IgfsUtils.preparePathModes(IgfsMode dfltMode,
List<T2<IgfsPath,IgfsMode>> modes,
Set<IgfsPath> dualParentsContainingPrimaryChildren)
Checks, filters and sorts the modes.
|
boolean |
IgfsMetaManager.renameDual(IgfsSecondaryFileSystem fs,
IgfsPath src,
IgfsPath dest)
Rename path in DUAL mode.
|
IgfsEntryInfo |
IgfsMetaManager.reserveSpace(IgniteUuid fileId,
long space,
IgfsFileAffinityRange affRange)
Reserve space for file.
|
Boolean |
IgfsMetaManager.sampling()
Get sampling flag state.
|
boolean |
IgfsMetaManager.sampling(Boolean val)
Set sampling flag.
|
byte[] |
IgfsDataManager.secondaryDataBlock(IgfsPath path,
long blockIdx,
IgfsSecondaryFileSystemPositionedReadable secReader,
int blockSize)
Get data block for specified block index from secondary reader.
|
void |
IgfsContext.send(ClusterNode node,
Object topic,
IgfsCommunicationMessage msg,
byte plc) |
void |
IgfsContext.send(UUID nodeId,
Object topic,
IgfsCommunicationMessage msg,
byte plc) |
void |
IgfsServer.start()
Starts this server.
|
void |
IgfsProcessor.start(boolean activeOnStart)
Starts grid component.
|
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 |
IgfsServerManager.start0()
Start manager implementation.
|
protected void |
IgfsDataManager.start0()
Start manager implementation.
|
protected void |
IgfsFragmentizerManager.start0()
Start manager implementation.
|
void |
IgfsServerHandler.stop()
Stops handling of incoming requests.
|
byte[] |
IgfsDataManager.storeDataBlocks(IgfsEntryInfo fileInfo,
long reservedLen,
byte[] remainder,
int remainderLen,
ByteBuffer data,
boolean flush,
IgfsFileAffinityRange affinityRange,
IgfsFileWorkerBatch batch)
Store data blocks in file.
|
byte[] |
IgfsDataManager.storeDataBlocks(IgfsEntryInfo fileInfo,
long reservedLen,
byte[] remainder,
int remainderLen,
DataInput in,
int len,
boolean flush,
IgfsFileAffinityRange affinityRange,
IgfsFileWorkerBatch batch)
Store data blocks in file.
|
IgfsEntryInfo |
IgfsMetaManager.synchronizeFileDual(IgfsSecondaryFileSystem fs,
IgfsPath path)
Synchronizes with secondary file system.
|
void |
IgfsMetaManager.unlock(IgniteUuid fileId,
IgniteUuid lockId,
long modificationTime)
Remove explicit lock on file held by the current stream.
|
void |
IgfsMetaManager.unlock(IgniteUuid fileId,
IgniteUuid lockId,
long modificationTime,
boolean updateSpace,
long space,
IgfsFileAffinityRange affRange)
Remove explicit lock on file held by the current stream.
|
IgfsEntryInfo |
IgfsMetaManager.updateDual(IgfsSecondaryFileSystem fs,
IgfsPath path,
Map<String,String> props)
Update path in DUAL mode.
|
IgfsEntryInfo |
IgfsMetaManager.updateInfo(IgniteUuid fileId,
javax.cache.processor.EntryProcessor<IgniteUuid,IgfsEntryInfo,IgfsEntryInfo> proc)
Update file info in cache.
|
IgfsEntryInfo |
IgfsMetaManager.updateProperties(IgniteUuid fileId,
Map<String,String> props)
Update file info (file properties) in cache.
|
void |
IgfsMetaManager.updateTimes(IgfsPath path,
long modificationTime,
long accessTime,
IgfsSecondaryFileSystem secondaryFs)
Update times.
|
void |
IgfsNoopHelper.validateCacheConfiguration(CacheConfiguration cfg)
Validate cache configuration for IGFS.
|
void |
IgfsHelper.validateCacheConfiguration(CacheConfiguration cfg)
Validate cache configuration for IGFS.
|
void |
IgfsHelperImpl.validateCacheConfiguration(CacheConfiguration cfg)
Validate cache configuration for IGFS.
|
void |
IgfsDataManager.writeClose(IgniteUuid fileId)
Notifies data manager that no further writes will be performed on stream.
|
| 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) |
IgfsModeResolver(IgfsMode dfltMode,
ArrayList<T2<IgfsPath,IgfsMode>> modes)
Constructor
|
| Modifier and Type | Method and Description |
|---|---|
Collection<ComputeJobSibling> |
GridJobProcessor.requestJobSiblings(ComputeTaskSession ses) |
void |
GridJobProcessor.setAttributes(GridJobSessionImpl ses,
Map<?,?> attrs) |
void |
GridJobProcessor.start(boolean activeOnStart)
Starts grid component.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridJobMetricsProcessor.start(boolean activeOnStart)
Starts grid component.
|
void |
GridJobMetricsProcessor.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteCheckedException |
MappingExchangeResult.error() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridMarshallerMappingProcessor.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
GridFutureAdapter<MappingExchangeResult> |
MarshallerMappingTransport.proposeMapping(MarshallerMappingItem item,
ConcurrentMap<Integer,MappedName> cache) |
void |
GridMarshallerMappingProcessor.start(boolean activeOnStart)
Starts grid component.
|
| Modifier and Type | Method and Description |
|---|---|
byte[] |
OdbcBufferedParser.decode(GridNioSession ses,
ByteBuffer buf)
This method is called when input bytes are available on the underlying network connection.
|
ByteBuffer |
OdbcBufferedParser.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.
|
byte[] |
OdbcNioServerBuffer.read(ByteBuffer buf) |
void |
OdbcProcessor.start(boolean activeOnStart)
Starts grid component.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridOffHeapProcessor.contains(String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes)
Checks if offheap space contains value for the given key.
|
void |
GridOffHeapProcessor.enableEviction(String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes)
Enables eviction for entry after
GridOffHeapProcessor.valuePointer(java.lang.String, int, org.apache.ignite.internal.processors.cache.KeyCacheObject, byte[]) was called. |
byte[] |
GridOffHeapProcessor.get(String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes)
Gets value bytes from offheap space for the given key.
|
<T> T |
GridOffHeapProcessor.getValue(String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes,
ClassLoader ldr)
Gets value from offheap space for the given key.
|
void |
GridOffHeapProcessor.put(String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes,
byte[] valBytes)
Puts the given value to offheap space for the given key.
|
byte[] |
GridOffHeapProcessor.remove(String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes)
Removes value from offheap space for the given key.
|
boolean |
GridOffHeapProcessor.removex(String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes)
Removes value from offheap space for the given key.
|
boolean |
GridOffHeapProcessor.removex(String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes,
IgniteBiPredicate<Long,Integer> p)
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,
KeyCacheObject key,
byte[] keyBytes)
Gets value pointer from offheap space for the given key.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PlatformException
Interop checked exception.
|
class |
PlatformExtendedException
Denotes an exception which has some data to be written in a special manner.
|
class |
PlatformNativeException
Exception occurred on native side.
|
class |
PlatformNoCallbackException
Exception raised when interop callback is not set in native platform.
|
| Modifier and Type | Method and Description |
|---|---|
PlatformTargetProxy |
PlatformNoopProcessor.affinity(String name)
Get affinity.
|
PlatformTargetProxy |
PlatformProcessorImpl.affinity(String name)
Get affinity.
|
PlatformTargetProxy |
PlatformProcessor.affinity(String name)
Get affinity.
|
void |
PlatformNoopProcessor.awaitStart()
Await until platform processor is safe to use (i.e.
|
void |
PlatformProcessorImpl.awaitStart()
Await until platform processor is safe to use (i.e.
|
void |
PlatformProcessor.awaitStart()
Await until platform processor is safe to use (i.e.
|
PlatformTargetProxy |
PlatformNoopProcessor.cache(String name)
Get cache.
|
PlatformTargetProxy |
PlatformProcessorImpl.cache(String name)
Get cache.
|
PlatformTargetProxy |
PlatformProcessor.cache(String name)
Get cache.
|
PlatformTargetProxy |
PlatformNoopProcessor.createCache(String name)
Create cache.
|
PlatformTargetProxy |
PlatformProcessorImpl.createCache(String name)
Create cache.
|
PlatformTargetProxy |
PlatformProcessor.createCache(String name)
Create cache.
|
PlatformTargetProxy |
PlatformNoopProcessor.createCacheFromConfig(long memPtr)
Create cache.
|
PlatformTargetProxy |
PlatformProcessorImpl.createCacheFromConfig(long memPtr)
Create cache.
|
PlatformTargetProxy |
PlatformProcessor.createCacheFromConfig(long memPtr)
Create cache.
|
PlatformTargetProxy |
PlatformNoopProcessor.dataStreamer(String cacheName,
boolean keepBinary)
Get data streamer.
|
PlatformTargetProxy |
PlatformProcessorImpl.dataStreamer(String cacheName,
boolean keepBinary)
Get data streamer.
|
PlatformTargetProxy |
PlatformProcessor.dataStreamer(String cacheName,
boolean keepBinary)
Get data streamer.
|
void |
PlatformNoopProcessor.destroyCache(String name)
Destroy dynamically created cache.
|
void |
PlatformProcessorImpl.destroyCache(String name)
Destroy dynamically created cache.
|
void |
PlatformProcessor.destroyCache(String name)
Destroy dynamically created cache.
|
PlatformTargetProxy |
PlatformNoopProcessor.getOrCreateCache(String name)
Get or create cache.
|
PlatformTargetProxy |
PlatformProcessorImpl.getOrCreateCache(String name)
Get or create cache.
|
PlatformTargetProxy |
PlatformProcessor.getOrCreateCache(String name)
Get or create cache.
|
PlatformTargetProxy |
PlatformNoopProcessor.getOrCreateCacheFromConfig(long memPtr)
Get or create cache.
|
PlatformTargetProxy |
PlatformProcessorImpl.getOrCreateCacheFromConfig(long memPtr)
Get or create cache.
|
PlatformTargetProxy |
PlatformProcessor.getOrCreateCacheFromConfig(long memPtr)
Get or create cache.
|
void |
PlatformProcessorImpl.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
IgniteInternalFuture<?> |
PlatformProcessorImpl.onReconnected(boolean clusterRestarted)
Client reconnected callback.
|
long |
PlatformAbstractTarget.processInLongOutLong(int type,
long val)
Process IN operation.
|
long |
PlatformTarget.processInLongOutLong(int type,
long val)
Process IN operation.
|
PlatformTarget |
PlatformAbstractTarget.processInObjectStreamOutObjectStream(int type,
PlatformTarget arg,
BinaryRawReaderEx reader,
BinaryRawWriterEx writer)
Process IN-OUT operation.
|
PlatformTarget |
PlatformTarget.processInObjectStreamOutObjectStream(int type,
PlatformTarget arg,
BinaryRawReaderEx reader,
BinaryRawWriterEx writer)
Process IN-OUT operation.
|
PlatformAsyncResult |
PlatformAbstractTarget.processInStreamAsync(int type,
BinaryRawReaderEx reader)
Process asynchronous operation.
|
PlatformAsyncResult |
PlatformTarget.processInStreamAsync(int type,
BinaryRawReaderEx reader)
Process asynchronous operation.
|
long |
PlatformAbstractTarget.processInStreamOutLong(int type,
BinaryRawReaderEx reader)
Process IN operation.
|
long |
PlatformTarget.processInStreamOutLong(int type,
BinaryRawReaderEx reader)
Process IN operation.
|
long |
PlatformAbstractTarget.processInStreamOutLong(int type,
BinaryRawReaderEx reader,
PlatformMemory mem)
Process IN operation.
|
long |
PlatformTarget.processInStreamOutLong(int type,
BinaryRawReaderEx reader,
PlatformMemory mem)
Process IN operation.
|
PlatformTarget |
PlatformAbstractTarget.processInStreamOutObject(int type,
BinaryRawReaderEx reader)
Process IN-OUT operation.
|
PlatformTarget |
PlatformTarget.processInStreamOutObject(int type,
BinaryRawReaderEx reader)
Process IN-OUT operation.
|
void |
PlatformAbstractTarget.processInStreamOutStream(int type,
BinaryRawReaderEx reader,
BinaryRawWriterEx writer)
Process IN-OUT operation.
|
void |
PlatformTarget.processInStreamOutStream(int type,
BinaryRawReaderEx reader,
BinaryRawWriterEx writer)
Process IN-OUT operation.
|
PlatformTarget |
PlatformAbstractTarget.processOutObject(int type)
Process OUT operation.
|
PlatformTarget |
PlatformTarget.processOutObject(int type)
Process OUT operation.
|
void |
PlatformAbstractTarget.processOutStream(int type,
BinaryRawWriterEx writer)
Process OUT operation.
|
void |
PlatformTarget.processOutStream(int type,
BinaryRawWriterEx writer)
Process OUT operation.
|
PlatformTargetProxy |
PlatformNoopProcessor.projection()
Get projection.
|
PlatformTargetProxy |
PlatformProcessorImpl.projection()
Get projection.
|
PlatformTargetProxy |
PlatformProcessor.projection()
Get projection.
|
protected PlatformListenable |
PlatformAbstractTarget.readAndListenFuture(BinaryRawReader reader,
IgniteFuture fut)
Reads future information and listens.
|
protected PlatformListenable |
PlatformAbstractTarget.readAndListenFuture(BinaryRawReader reader,
IgniteFuture fut,
PlatformFutureUtils.Writer writer)
Reads future information and listens.
|
protected PlatformListenable |
PlatformAbstractTarget.readAndListenFuture(BinaryRawReader reader,
IgniteInternalFuture fut)
Reads future information and listens.
|
protected PlatformListenable |
PlatformAbstractTarget.readAndListenFuture(BinaryRawReader reader,
IgniteInternalFuture fut,
PlatformFutureUtils.Writer writer)
Reads future information and listens.
|
void |
PlatformNoopProcessor.registerStore(PlatformCacheStore store,
boolean convertBinary)
Register cache store.
|
void |
PlatformProcessorImpl.registerStore(PlatformCacheStore store,
boolean convertBinary)
Register cache store.
|
void |
PlatformProcessor.registerStore(PlatformCacheStore store,
boolean convertBinary)
Register cache store.
|
void |
PlatformProcessorImpl.start(boolean activeOnStart)
Starts grid component.
|
void |
PlatformProcessorImpl.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
long |
PlatformBinaryProcessor.processInStreamOutLong(int type,
BinaryRawReaderEx reader)
Process IN operation.
|
void |
PlatformBinaryProcessor.processInStreamOutStream(int type,
BinaryRawReaderEx reader,
BinaryRawWriterEx writer)
Process IN-OUT operation.
|
void |
PlatformBinaryProcessor.processOutStream(int type,
BinaryRawWriterEx writer)
Process OUT operation.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PlatformCachePartialUpdateException
Interop cache partial update exception.
|
| Modifier and Type | Method and Description |
|---|---|
long |
PlatformCache.processInLongOutLong(int type,
long val)
Process IN operation.
|
long |
PlatformCacheExtension.processInOutStreamLong(PlatformCache target,
int type,
BinaryRawReaderEx reader,
PlatformMemory mem)
Invokes in-out operation with long return type.
|
long |
PlatformCache.processInStreamOutLong(int type,
BinaryRawReaderEx reader,
PlatformMemory mem)
Process IN operation.
|
PlatformTarget |
PlatformCache.processInStreamOutObject(int type,
BinaryRawReaderEx reader)
Process IN-OUT operation.
|
PlatformTarget |
PlatformCache.processOutObject(int type)
Process OUT operation.
|
void |
PlatformCache.processOutStream(int type,
BinaryRawWriterEx writer)
Process OUT operation.
|
void |
PlatformCacheIterator.processOutStream(int type,
BinaryRawWriterEx writer)
Process OUT operation.
|
| Modifier and Type | Method and Description |
|---|---|
long |
PlatformAffinity.processInLongOutLong(int type,
long val)
Process IN operation.
|
long |
PlatformAffinityFunctionTarget.processInStreamOutLong(int type,
BinaryRawReaderEx reader)
Process IN operation.
|
long |
PlatformAffinity.processInStreamOutLong(int type,
BinaryRawReaderEx reader)
Process IN operation.
|
void |
PlatformAffinity.processInStreamOutStream(int type,
BinaryRawReaderEx reader,
BinaryRawWriterEx writer)
Process IN-OUT operation.
|
void |
PlatformAffinityFunctionTarget.processOutStream(int type,
BinaryRawWriterEx writer)
Process OUT operation.
|
void |
PlatformAffinityFunction.setIgnite(Ignite ignite)
Injects the Ignite.
|
| Constructor and Description |
|---|
PlatformAffinity(PlatformContext platformCtx,
GridKernalContext igniteCtx,
String name)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
long |
PlatformContinuousQueryProxy.processInLongOutLong(int type,
long val)
Process IN operation.
|
long |
PlatformAbstractQueryCursor.processInLongOutLong(int type,
long val)
Process IN operation.
|
PlatformTarget |
PlatformContinuousQueryProxy.processOutObject(int type)
Process OUT operation.
|
void |
PlatformAbstractQueryCursor.processOutStream(int type,
BinaryRawWriterEx writer)
Process OUT operation.
|
void |
PlatformContinuousQuery.start(IgniteCacheProxy cache,
boolean loc,
int bufSize,
long timeInterval,
boolean autoUnsubscribe,
Query initialQry)
Start continuous query execution.
|
void |
PlatformContinuousQueryImpl.start(IgniteCacheProxy cache,
boolean loc,
int bufSize,
long timeInterval,
boolean autoUnsubscribe,
Query initialQry)
Start query execution.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PlatformCallbackGateway.serviceCancel(long memPtr)
Cancels native service.
|
void |
PlatformCallbackGateway.serviceExecute(long memPtr)
Executes native service.
|
long |
PlatformCallbackGateway.serviceInit(long memPtr)
Initializes native service.
|
void |
PlatformCallbackGateway.serviceInvokeMethod(long memPtr)
Invokes service method.
|
| Modifier and Type | Method and Description |
|---|---|
long |
PlatformClusterGroup.processInLongOutLong(int type,
long val)
Process IN operation.
|
PlatformTarget |
PlatformClusterGroup.processInObjectStreamOutObjectStream(int type,
PlatformTarget arg,
BinaryRawReaderEx reader,
BinaryRawWriterEx writer)
Process IN-OUT operation.
|
long |
PlatformClusterGroup.processInStreamOutLong(int type,
BinaryRawReaderEx reader)
Process IN operation.
|
PlatformTarget |
PlatformClusterGroup.processInStreamOutObject(int type,
BinaryRawReaderEx reader)
Process IN-OUT operation.
|
void |
PlatformClusterGroup.processInStreamOutStream(int type,
BinaryRawReaderEx reader,
BinaryRawWriterEx writer)
Process IN-OUT operation.
|
PlatformTarget |
PlatformClusterGroup.processOutObject(int type)
Process OUT operation.
|
void |
PlatformClusterGroup.processOutStream(int type,
BinaryRawWriterEx writer)
Process OUT operation.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
PlatformCompute.ComputeConvertingFuture.cancel()
Cancels this future.
|
protected boolean |
PlatformAbstractJob.createJob(PlatformContext ctx)
Create job in native platform if needed.
|
Object |
PlatformFullJob.execute0(PlatformContext ctx)
Internal job execution routine.
|
Object |
PlatformClosureJob.execute0(PlatformContext ctx)
Internal job execution routine.
|
protected abstract Object |
PlatformAbstractJob.execute0(PlatformContext ctx)
Internal job execution routine.
|
protected Object |
PlatformCompute.executeJavaTask(BinaryRawReaderEx reader,
boolean async)
Execute task taking arguments from the given reader.
|
Object |
PlatformCompute.ComputeConvertingFuture.get()
Synchronously waits for completion of the computation and
returns computation result.
|
Object |
PlatformCompute.ComputeConvertingFuture.get(long timeout)
Synchronously waits for completion of the computation for
up to the timeout specified and returns computation result.
|
Object |
PlatformCompute.ComputeConvertingFuture.get(long timeout,
TimeUnit unit)
Synchronously waits for completion of the computation for
up to the timeout specified and returns computation result.
|
Object |
PlatformCompute.ComputeConvertingFuture.getUninterruptibly()
Synchronously waits for completion of the computation and returns computation result ignoring interrupts.
|
long |
PlatformCompute.processInLongOutLong(int type,
long val)
Process IN operation.
|
PlatformTarget |
PlatformCompute.processInStreamOutObject(int type,
BinaryRawReaderEx reader)
Process IN-OUT operation.
|
void |
PlatformCompute.processInStreamOutStream(int type,
BinaryRawReaderEx reader,
BinaryRawWriterEx writer)
Process IN-OUT operation.
|
| Modifier and Type | Method and Description |
|---|---|
long |
PlatformDataStreamer.processInLongOutLong(int type,
long val)
Process IN operation.
|
long |
PlatformDataStreamer.processInStreamOutLong(int type,
BinaryRawReaderEx reader)
Process IN operation.
|
| Modifier and Type | Method and Description |
|---|---|
long |
PlatformAtomicLong.processInLongOutLong(int type,
long val)
Process IN operation.
|
long |
PlatformAtomicReference.processInLongOutLong(int type,
long val)
Process IN operation.
|
long |
PlatformAtomicSequence.processInLongOutLong(int type,
long val)
Process IN operation.
|
long |
PlatformAtomicLong.processInStreamOutLong(int type,
BinaryRawReaderEx reader)
Process IN operation.
|
long |
PlatformAtomicReference.processInStreamOutLong(int type,
BinaryRawReaderEx reader)
Process IN operation.
|
void |
PlatformAtomicReference.processInStreamOutStream(int type,
BinaryRawReaderEx reader,
BinaryRawWriterEx writer)
Process IN-OUT operation.
|
void |
PlatformAtomicReference.processOutStream(int type,
BinaryRawWriterEx writer)
Process OUT operation.
|
| Modifier and Type | Method and Description |
|---|---|
protected int |
PlatformDotNetCacheStore.doInvoke(IgniteInClosure<BinaryRawWriterEx> task,
IgniteInClosure<BinaryRawReaderEx> readClo)
Perform actual invoke.
|
void |
PlatformDotNetCacheStore.initialize(GridKernalContext ctx,
boolean convertBinary)
Initialize the store.
|
| Modifier and Type | Method and Description |
|---|---|
long |
PlatformDotNetEntityFrameworkCacheExtension.processInOutStreamLong(PlatformCache target,
int type,
BinaryRawReaderEx reader,
PlatformMemory mem)
Invokes in-out operation with long return type.
|
| Modifier and Type | Method and Description |
|---|---|
long |
PlatformEvents.processInLongOutLong(int type,
long val)
Process IN operation.
|
long |
PlatformEvents.processInStreamOutLong(int type,
BinaryRawReaderEx reader)
Process IN operation.
|
void |
PlatformEvents.processInStreamOutStream(int type,
BinaryRawReaderEx reader,
BinaryRawWriterEx writer)
Process IN-OUT operation.
|
PlatformTarget |
PlatformEvents.processOutObject(int type)
Process OUT operation.
|
void |
PlatformEvents.processOutStream(int type,
BinaryRawWriterEx writer)
Process OUT operation.
|
| Modifier and Type | Method and Description |
|---|---|
long |
PlatformMessaging.processInStreamOutLong(int type,
BinaryRawReaderEx reader)
Process IN operation.
|
void |
PlatformMessaging.processInStreamOutStream(int type,
BinaryRawReaderEx reader,
BinaryRawWriterEx writer)
Process IN-OUT operation.
|
PlatformTarget |
PlatformMessaging.processOutObject(int type)
Process OUT operation.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PlatformPluginProcessor.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
Object |
PlatformAbstractService.invokeMethod(String mthdName,
boolean srvKeepBinary,
Object[] args)
Invokes native service method.
|
Object |
PlatformService.invokeMethod(String mthdName,
boolean srvKeepBinary,
Object[] args)
Invokes native service method.
|
long |
PlatformServices.processInLongOutLong(int type,
long val)
Process IN operation.
|
PlatformTarget |
PlatformServices.processInObjectStreamOutObjectStream(int type,
PlatformTarget arg,
BinaryRawReaderEx reader,
BinaryRawWriterEx writer)
Process IN-OUT operation.
|
long |
PlatformServices.processInStreamOutLong(int type,
BinaryRawReaderEx reader)
Process IN operation.
|
PlatformTarget |
PlatformServices.processInStreamOutObject(int type,
BinaryRawReaderEx reader)
Process IN-OUT operation.
|
void |
PlatformServices.processInStreamOutStream(int type,
BinaryRawReaderEx reader,
BinaryRawWriterEx writer)
Process IN-OUT operation.
|
PlatformTarget |
PlatformServices.processOutObject(int type)
Process OUT operation.
|
void |
PlatformServices.processOutStream(int type,
BinaryRawWriterEx writer)
Process OUT operation.
|
| Modifier and Type | Method and Description |
|---|---|
long |
PlatformTransactions.processInLongOutLong(int type,
long val)
Process IN operation.
|
long |
PlatformTransactions.processInStreamOutLong(int type,
BinaryRawReaderEx reader)
Process IN operation.
|
void |
PlatformTransactions.processInStreamOutStream(int type,
BinaryRawReaderEx reader,
BinaryRawWriterEx writer)
Process IN-OUT operation.
|
void |
PlatformTransactions.processOutStream(int type,
BinaryRawWriterEx writer)
Process OUT operation.
|
| Modifier and Type | Method and Description |
|---|---|
static IgniteCheckedException |
PlatformUtils.unwrapQueryException(Throwable err)
Unwrap query exception.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
PlatformListenable.cancel()
Cancel this instance.
|
long |
PlatformListenableTarget.processInLongOutLong(int type,
long val)
Process IN operation.
|
static Object |
PlatformUtils.readInvocationResult(PlatformContext ctx,
BinaryRawReaderEx reader)
Reads invocation result (of a job/service/etc) using a common protocol.
|
| Modifier and Type | Method and Description |
|---|---|
long |
PlatformDotNetSessionCacheExtension.processInOutStreamLong(PlatformCache target,
int type,
BinaryRawReaderEx reader,
PlatformMemory mem)
Invokes in-out operation with long return type.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
CachePluginManager.onKernalStart0() |
void |
IgnitePluginProcessor.start(boolean activeOnStart)
Starts grid component.
|
protected void |
CachePluginManager.start0() |
void |
CachePluginManager.validate()
Validates cache plugin configurations.
|
void |
CachePluginManager.validateRemotes(CacheConfiguration rmtCfg,
ClusterNode rmtNode)
Checks that remote caches has configuration compatible with the local.
|
| Constructor and Description |
|---|
IgnitePluginProcessor(GridKernalContext ctx,
IgniteConfiguration cfg,
List<PluginProvider> providers) |
| Modifier and Type | Method and Description |
|---|---|
Executor |
PoolProcessor.poolForPolicy(byte plc)
Get executor service for policy.
|
void |
PoolProcessor.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridPortProcessor.start(boolean activeOnStart)
Starts grid component.
|
void |
GridPortProcessor.stop(boolean cancel)
Stops grid component.
|
| Modifier and Type | Method and Description |
|---|---|
QueryIndexDescriptorImpl |
QueryIndexDescriptorImpl.addField(String field,
int orderNum,
boolean descending)
Adds field to this index.
|
void |
QueryTypeDescriptorImpl.addFieldToTextIndex(String field)
Adds field to text index.
|
void |
QueryTypeDescriptorImpl.addIndex(QueryIndexDescriptorImpl idx)
Add index.
|
void |
QueryTypeDescriptorImpl.addProperty(GridQueryProperty prop,
boolean failOnDuplicate)
Adds property to the type descriptor.
|
boolean |
GridQueryProcessor.belongsToTable(GridCacheContext cctx,
String expSpace,
String expTblName,
KeyCacheObject key,
CacheObject val)
Check whether provided key and value belongs to expected space and table.
|
static QueryBinaryProperty |
QueryUtils.buildBinaryProperty(GridKernalContext ctx,
String pathStr,
Class<?> resType,
Map<String,String> aliases,
Boolean isKeyField)
Builds binary object property.
|
static QueryClassProperty |
QueryUtils.buildClassProperty(Class<?> keyCls,
Class<?> valCls,
String pathStr,
Class<?> resType,
Map<String,String> aliases,
CacheObjectContext coCtx) |
static GridQueryProperty |
QueryUtils.buildProperty(Class<?> keyCls,
Class<?> valCls,
String keyFieldName,
String valueFieldName,
String pathStr,
Class<?> resType,
Map<String,String> aliases,
CacheObjectContext coCtx) |
static QueryIndexDescriptorImpl |
QueryUtils.createIndexDescriptor(QueryTypeDescriptorImpl typeDesc,
QueryIndex idx)
Create index descriptor.
|
void |
GridQueryIndexing.dynamicIndexCreate(String spaceName,
String tblName,
QueryIndexDescriptorImpl idxDesc,
boolean ifNotExists,
SchemaIndexCacheVisitor cacheVisitor)
Create new index locally.
|
void |
GridQueryIndexing.dynamicIndexDrop(String spaceName,
String idxName,
boolean ifExists)
Remove index from the space.
|
<R> R |
GridQueryProcessor.executeQuery(GridCacheQueryType qryType,
String qry,
GridCacheContext<?,?> cctx,
IgniteOutClosureX<R> clo,
boolean complete) |
IgniteSpiCloseableIterator<List<?>> |
GridQueryFieldsResult.iterator()
Gets iterator over queried fields.
|
GridCloseableIterator<List<?>> |
GridQueryFieldsResultAdapter.iterator()
Gets iterator over queried fields.
|
void |
GridQueryProcessor.onCacheKernalStart()
Handle cache kernal start.
|
void |
GridQueryProcessor.onCacheReconnect()
Handle cache reconnect.
|
void |
GridQueryProcessor.onCacheStart(GridCacheContext cctx,
QuerySchema schema)
Handle cache start.
|
void |
GridQueryProcessor.onCacheStart0(GridCacheContext<?,?> cctx,
QuerySchema schema)
Create type descriptors from schema and initialize indexing for given cache.
|
void |
GridQueryProcessor.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
static void |
QueryUtils.processBinaryMeta(GridKernalContext ctx,
QueryEntity qryEntity,
QueryTypeDescriptorImpl d)
Processes declarative metadata for binary object.
|
static void |
QueryUtils.processClassMeta(QueryEntity qryEntity,
QueryTypeDescriptorImpl d,
CacheObjectContext coCtx)
Processes declarative metadata for binary object.
|
static void |
QueryUtils.processDynamicIndexChange(String idxName,
QueryIndex idx,
QueryTypeDescriptorImpl d)
Process dynamic index change.
|
<K,V> QueryCursor<javax.cache.Cache.Entry<K,V>> |
GridQueryIndexing.queryLocalSql(GridCacheContext<?,?> cctx,
SqlQuery qry,
IndexingQueryFilter filter,
boolean keepBinary)
Executes regular query.
|
<K,V> QueryCursor<List<?>> |
GridQueryIndexing.queryLocalSqlFields(GridCacheContext<?,?> cctx,
SqlFieldsQuery qry,
IndexingQueryFilter filter,
GridQueryCancel cancel)
Queries individual fields (generally used by JDBC drivers).
|
<K,V> GridCloseableIterator<IgniteBiTuple<K,V>> |
GridQueryIndexing.queryLocalText(String spaceName,
String qry,
String typeName,
IndexingQueryFilter filter)
Executes text query.
|
<K,V> GridCloseableIterator<IgniteBiTuple<K,V>> |
GridQueryProcessor.queryText(String space,
String clause,
String resType,
IndexingQueryFilter filters) |
QueryCursor<List<?>> |
GridQueryIndexing.queryTwoStep(GridCacheContext<?,?> cctx,
SqlFieldsQuery qry,
GridQueryCancel cancel)
Parses SQL query into two step query and executes it.
|
<K,V> QueryCursor<javax.cache.Cache.Entry<K,V>> |
GridQueryIndexing.queryTwoStep(GridCacheContext<?,?> cctx,
SqlQuery qry)
Parses SQL query into two step query and executes it.
|
void |
GridQueryIndexing.rebuildIndexesFromHash(String spaceName,
GridQueryTypeDescriptor type)
Rebuilds all indexes of given type from hash index.
|
void |
GridQueryIndexing.registerCache(String spaceName,
GridCacheContext<?,?> cctx,
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,
GridQueryTypeDescriptor type,
KeyCacheObject key,
int partId,
CacheObject val,
GridCacheVersion ver)
Removes index entry by key.
|
void |
GridQueryProcessor.remove(String space,
KeyCacheObject key,
int partId,
CacheObject val,
GridCacheVersion ver) |
void |
QueryUtils.KeyOrValProperty.setValue(Object key,
Object val,
Object propVal)
Sets this property value for the given object.
|
void |
GridQueryProperty.setValue(Object key,
Object val,
Object propVal)
Sets this property value for the given object.
|
void |
GridQueryTypeDescriptor.setValue(String field,
Object key,
Object val,
Object propVal)
Sets field value for given key and value.
|
void |
QueryTypeDescriptorImpl.setValue(String field,
Object key,
Object val,
Object propVal)
Sets field value for given key and value.
|
void |
GridQueryProcessor.start(boolean activeOnStart)
Starts grid component.
|
void |
GridQueryIndexing.start(GridKernalContext ctx,
GridSpinBusyLock busyLock)
Starts indexing.
|
void |
GridQueryIndexing.stop()
Stops indexing.
|
void |
GridQueryProcessor.stop(boolean cancel)
Stops grid component.
|
void |
GridQueryProcessor.store(String space,
KeyCacheObject key,
int partId,
CacheObject prevVal,
GridCacheVersion prevVer,
CacheObject val,
GridCacheVersion ver,
long expirationTime,
long link)
Writes key-value pair to index.
|
void |
GridQueryIndexing.store(String spaceName,
String typeName,
KeyCacheObject key,
int partId,
CacheObject val,
GridCacheVersion ver,
long expirationTime,
long link)
Updates index.
|
long |
GridQueryIndexing.streamUpdateQuery(String spaceName,
String qry,
Object[] params,
IgniteDataStreamer<?,?> streamer)
Perform a MERGE statement using data streamer as receiver.
|
static QueryTypeCandidate |
QueryUtils.typeForQueryEntity(String space,
GridCacheContext cctx,
QueryEntity qryEntity,
List<Class<?>> mustDeserializeClss)
Create type candidate for query entity.
|
void |
GridQueryIndexing.unregisterCache(String spaceName)
Unregisters cache.
|
void |
GridQueryIndexing.unregisterType(String spaceName,
String typeName)
Unregisters type and removes all corresponding data.
|
static void |
QueryUtils.validateCacheConfiguration(CacheConfiguration ccfg)
Prepare cache configuration.
|
Object |
QueryUtils.KeyOrValProperty.value(Object key,
Object val)
Gets this property value from the given object.
|
Object |
GridQueryProperty.value(Object key,
Object val)
Gets this property value from the given object.
|
<T> T |
GridQueryTypeDescriptor.value(String field,
Object key,
Object val)
Gets field value for given key and value.
|
<T> T |
QueryTypeDescriptorImpl.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 |
|---|---|
Object |
QueryFieldAccessor.getValue(Object obj)
Get property value from given object.
|
Object |
QueryPropertyAccessor.getValue(Object obj)
Get property value from given object.
|
Object |
QueryReadOnlyMethodsAccessor.getValue(Object obj)
Get property value from given object.
|
Object |
QueryMethodsAccessor.getValue(Object obj)
Get property value from given object.
|
void |
QueryFieldAccessor.setValue(Object obj,
Object newVal)
Set property value on given object.
|
void |
QueryPropertyAccessor.setValue(Object obj,
Object newVal)
Set property value on given object.
|
void |
QueryReadOnlyMethodsAccessor.setValue(Object obj,
Object newVal)
Set property value on given object.
|
void |
QueryMethodsAccessor.setValue(Object obj,
Object newVal)
Set property value on given object.
|
void |
QueryBinaryProperty.setValue(Object key,
Object val,
Object propVal)
Sets this property value for the given object.
|
void |
QueryClassProperty.setValue(Object key,
Object val,
Object propVal)
Sets this property value for the given object.
|
Object |
QueryBinaryProperty.value(Object key,
Object val)
Gets this property value from the given object.
|
Object |
QueryClassProperty.value(Object key,
Object val)
Gets this property value from the given object.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SchemaOperationException
Schema operation exception.
|
| Modifier and Type | Method and Description |
|---|---|
void |
SchemaIndexCacheVisitorClosure.apply(KeyCacheObject key,
int part,
CacheObject val,
GridCacheVersion ver,
long expiration,
long link)
Apply closure.
|
void |
SchemaIndexCacheVisitor.visit(SchemaIndexCacheVisitorClosure clo)
Visit cache entries and pass them to closure.
|
void |
SchemaIndexCacheVisitorImpl.visit(SchemaIndexCacheVisitorClosure clo)
Visit cache entries and pass them to closure.
|
| 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 |
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.GridResourceField field,
Object target,
Class<?> depCls,
GridDeployment dep)
Injects resource into field.
|
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 |
GridResourceLoggerInjector.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(Object obj,
GridResourceIoc.AnnotationSet annSet,
Object... params) |
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.injectCacheName(Object obj,
String cacheName)
Injects cache name into given object.
|
boolean |
GridResourceProcessor.injectFileSystem(Object obj,
IgniteFileSystem igfs)
Injects filesystem instance 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(boolean activeOnStart)
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(boolean activeOnStart)
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
void |
GridRestProcessor.start(boolean activeOnStart)
Starts grid component.
|
void |
GridRestProtocol.start(GridRestProtocolHandler hnd)
Starts protocol.
|
| Modifier and Type | Method and Description |
|---|---|
protected IgniteInternalCache<Object,Object> |
GridCacheCommandHandler.localCache(String cacheName) |
| Modifier and Type | Method and Description |
|---|---|
abstract GridRestRequest |
GridRedisRestCommandHandler.asRestRequest(GridRedisMessage msg)
Converts
GridRedisMessage to GridRestRequest. |
| Modifier and Type | Class and Description |
|---|---|
class |
GridRedisGenericException
Generic Redis protocol exception.
|
class |
GridRedisTypeException
Exception on operation on the wrong data type.
|
| Modifier and Type | Method and Description |
|---|---|
GridRestRequest |
GridRedisDelCommandHandler.asRestRequest(GridRedisMessage msg)
Converts
GridRedisMessage to GridRestRequest. |
GridRestRequest |
GridRedisExistsCommandHandler.asRestRequest(GridRedisMessage msg)
Converts
GridRedisMessage to GridRestRequest. |
| Modifier and Type | Method and Description |
|---|---|
GridRestRequest |
GridRedisDbSizeCommandHandler.asRestRequest(GridRedisMessage msg)
Converts
GridRedisMessage to GridRestRequest. |
| 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 |
|---|---|
static GridRedisMessage |
GridRedisProtocolParser.readArray(ByteBuffer buf)
Reads an array into
GridRedisMessage. |
static String |
GridRedisProtocolParser.readBulkStr(ByteBuffer buf)
Reads a bulk string.
|
| Modifier and Type | Method and Description |
|---|---|
SecurityContext |
GridSecurityProcessor.authenticate(AuthenticationContext ctx)
Authenticates subject via underlying Authenticator.
|
SecuritySubject |
GridSecurityProcessor.authenticatedSubject(UUID subjId)
Gets authenticated node subject.
|
Collection<SecuritySubject> |
GridSecurityProcessor.authenticatedSubjects()
Gets collection of authenticated nodes.
|
SecurityContext |
GridSecurityProcessor.authenticateNode(ClusterNode node,
SecurityCredentials 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,
SecurityCredentials 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.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
GridServiceProcessor.onContinuousProcessorStarted(GridKernalContext ctx) |
void |
GridServiceProcessor.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
void |
GridServiceProcessor.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
void |
GridServiceProcessor.onKernalStart(boolean activeOnStart)
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
Map<UUID,Integer> |
GridServiceProcessor.serviceTopology(String name,
long timeout) |
void |
GridServiceProcessor.start(boolean activeOnStart)
Starts grid component.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridTaskSessionProcessor.start(boolean activeOnStart)
Starts session processor.
|
void |
GridTaskSessionProcessor.stop(boolean cancel)
Stops session processor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridTaskProcessor.onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
void |
GridTaskProcessor.onKernalStart(boolean activeOnStart)
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 |
IgniteTree.InvokeClosure.call(T row) |
void |
GridEmptyCloseableIterator.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 |
GridCloseableIteratorAdapterEx.close()
Closes the iterator and frees all the resources held by the iterator.
|
void |
GridWeakIterator.close()
Closes 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 String |
IgniteUtils.defaultWorkDirectory()
Get default work directory.
|
static byte |
IgniteUtils.directProtocolVersion(GridKernalContext ctx,
UUID nodeId)
Defines which protocol version to use for
communication with the provided node.
|
static void |
IgniteUtils.ensureDirectory(File dir,
String msg,
IgniteLogger log)
Checks if the given directory exists and attempts to create one if not.
|
static <T> T |
IgniteUtils.field(Class<?> cls,
String fieldName)
Gets field value.
|
GridCursor<T> |
IgniteTree.find(L lower,
L upper)
Returns a cursor from lower to upper bounds inclusive.
|
T |
IgniteTree.findFirst()
Returns a value mapped to the lowest key, or
null if tree is empty |
T |
IgniteTree.findLast()
Returns a value mapped to the greatest key, or
null if tree is empty |
T |
IgniteTree.findOne(L key)
Returns the value to which the specified key is mapped, or
null if this tree contains no mapping for the
key. |
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.
|
V |
GridCursorIteratorWrapper.get()
Gets element at current position.
|
static <T> T |
IgniteUtils.get(Future<T> fut)
Gets result from the given future with right exception handling.
|
boolean |
GridCloseableIteratorAdapter.hasNextX()
This method is the same as
Iterator.hasNext(), but allows for failure
with exception. |
boolean |
GridCloseableIteratorAdapterEx.hasNextX()
This method is the same as
Iterator.hasNext(), but allows for failure
with exception. |
T |
GridAtomicInitializer.init(Callable<T> c)
Executes initialization operation only once.
|
static <T> T |
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.
|
void |
IgniteTree.invoke(L key,
Object x,
IgniteTree.InvokeClosure<T> c) |
static byte[] |
IgniteUtils.marshal(GridCacheSharedContext ctx,
Object obj)
Marshals object to byte array.
|
static byte[] |
IgniteUtils.marshal(GridKernalContext ctx,
Object obj)
Marshals object to byte array.
|
static byte[] |
IgniteUtils.marshal(Marshaller marsh,
Object obj)
Marshals object to byte array.
|
static void |
IgniteUtils.marshal(Marshaller marsh,
Object obj,
OutputStream out)
Marshals object to byte array.
|
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).
|
boolean |
GridCursorIteratorWrapper.next()
Attempt to move cursor position forward.
|
T |
GridCloseableIteratorAdapter.nextX()
This method is the same as
Iterator.next(), but allows for failure
with exception. |
T |
GridCloseableIteratorAdapterEx.nextX()
This method is the same as
Iterator.next(), but allows for failure
with exception. |
protected void |
GridCloseableIteratorAdapter.onClose()
Invoked on iterator close.
|
protected void |
GridCloseableIteratorAdapterEx.onClose()
Invoked on iterator close.
|
protected void |
GridSpiCloseableIteratorWrapper.onClose()
Invoked on iterator close.
|
protected abstract boolean |
GridCloseableIteratorAdapter.onHasNext() |
protected abstract boolean |
GridCloseableIteratorAdapterEx.onHasNext() |
protected boolean |
GridSpiCloseableIteratorWrapper.onHasNext() |
protected abstract T |
GridCloseableIteratorAdapter.onNext() |
protected abstract T |
GridCloseableIteratorAdapterEx.onNext() |
protected T |
GridSpiCloseableIteratorWrapper.onNext() |
protected void |
GridCloseableIteratorAdapter.onRemove()
Called on remove from iterator.
|
protected void |
GridCloseableIteratorAdapterEx.onRemove()
Called on remove from iterator.
|
protected void |
GridSpiCloseableIteratorWrapper.onRemove()
Called on remove from iterator.
|
static HostAndPortRange |
HostAndPortRange.parse(String addrStr,
int dfltPortFrom,
int dfltPortTo,
String errMsgPrefix)
Parse string into host and port pair.
|
static Calendar |
IgniteUtils.parseIsoDate(String str) |
T |
IgniteTree.put(T val)
Put value in this tree.
|
T |
IgniteTree.remove(L key)
Removes the mapping for a key from this tree if it is present.
|
static void |
IgniteUtils.removeLog4jNoOpLogger(IgniteBiTuple<Object,Object> t)
Removes previously added no-op logger via method
IgniteUtils.addLog4jNoOpLogger(). |
void |
GridCloseableIteratorAdapter.removeX()
This method is the same as
Iterator.remove(), but allows for failure
with exception. |
void |
GridCloseableIteratorAdapterEx.removeX()
This method is the same as
Iterator.remove(), but allows for failure
with exception. |
static IgniteBiTuple<Collection<String>,Collection<String>> |
IgniteUtils.resolveLocalAddresses(InetAddress locAddr)
Returns host names consistent with
IgniteUtils.resolveLocalHost(String). |
static IgniteBiTuple<Collection<String>,Collection<String>> |
IgniteUtils.resolveLocalAddresses(InetAddress locAddr,
boolean allHostNames)
Returns host names consistent with
IgniteUtils.resolveLocalHost(String). |
static URL |
IgniteUtils.resolveSpringUrl(String springCfgPath)
Resolve Spring configuration URL.
|
static File |
IgniteUtils.resolveWorkDirectory(String workDir,
String path,
boolean delIfExist)
Resolves work directory.
|
long |
IgniteTree.size()
Returns the number of elements in this tree.
|
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 <T> T |
IgniteUtils.unmarshal(GridCacheSharedContext ctx,
byte[] arr,
ClassLoader clsLdr)
Unmarshals object from the input stream using given class loader.
|
static <T> T |
IgniteUtils.unmarshal(GridKernalContext ctx,
byte[] arr,
ClassLoader clsLdr)
Unmarshals object from the input stream using given class loader.
|
static <T> T |
IgniteUtils.unmarshal(Marshaller marsh,
byte[] arr,
ClassLoader clsLdr)
Unmarshals object from the input stream using given class loader.
|
static <T> T |
IgniteUtils.unmarshal(Marshaller marsh,
InputStream in,
ClassLoader clsLdr)
Unmarshals object from the input stream using given class loader.
|
static <T> T |
IgniteUtils.unmarshalZip(Marshaller marsh,
byte[] zipBytes,
ClassLoader clsLdr) |
static String |
IgniteUtils.workDirectory(String userWorkDir,
String userIgniteHome)
Get work directory for the given user-provided work directory and Ignite home.
|
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.
|
static byte[] |
IgniteUtils.zip(byte[] bytes) |
| Modifier and Type | Method and Description |
|---|---|
protected RuntimeException |
IgniteFutureImpl.convertException(IgniteCheckedException e)
Convert internal exception to public exception.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridCompoundFuture.cancel()
Default no-op implementation that always returns
false. |
boolean |
GridFutureAdapter.cancel()
Default no-op implementation that always returns
false. |
boolean |
GridEmbeddedFuture.cancel()
Default no-op implementation that always returns
false. |
T |
GridFinishedFuture.get()
Synchronously waits for completion of the computation and
returns computation result.
|
R |
GridFutureAdapter.get()
Synchronously waits for completion of the computation 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)
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.
|
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.getUninterruptibly()
Synchronously waits for completion of the computation and returns computation result ignoring interrupts.
|
R |
GridFutureAdapter.getUninterruptibly()
Synchronously waits for completion of the computation and returns computation result ignoring interrupts.
|
| 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(IgniteLogger log) |
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 |
|---|---|
R |
GridPlainOutClosure.apply() |
void |
GridPlainAbsClosure.apply()
Applies this closure.
|
R |
GridPlainClosure.apply(T arg) |
void |
GridPlainInClosure.apply(T arg) |
R |
GridPlainClosure2.apply(T1 arg1,
T2 arg2) |
abstract T |
IgniteOutClosureX.applyx()
Out-closure body that can throw
IgniteCheckedException. |
abstract void |
GridAbsClosureX.applyx()
Closure body that can throw
IgniteCheckedException. |
abstract R |
IgniteReducerX.applyx()
Reducer body that can throw
IgniteCheckedException. |
abstract boolean |
GridAbsPredicateX.applyx()
Predicate body that can throw
IgniteCheckedException. |
abstract R |
IgniteReducer3X.applyx()
Reducer body that can throw
IgniteCheckedException. |
abstract R |
IgniteReducer2X.applyx()
Reducer 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 R |
IgniteClosure2X.applyx(E1 e1,
E2 e2)
Closure body that can throw
IgniteCheckedException. |
abstract void |
IgniteInClosure2X.applyx(E1 e1,
E2 e2)
In-closure body that can throw
IgniteCheckedException. |
abstract R |
GridClosure3X.applyx(E1 e1,
E2 e2,
E3 e3)
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 void |
IgniteInClosureX.applyx(T t)
In-closure body that can throw
IgniteCheckedException. |
static <T> void |
GridFunc.awaitAll(Collection<IgniteInternalFuture<T>> futs)
Deprecated.
|
static <T> void |
GridFunc.awaitAll(long timeout,
Collection<IgniteInternalFuture<T>> futs)
Deprecated.
|
static <T,R> R |
GridFunc.awaitAll(long timeout,
IgniteReducer<T,R> rdc,
Collection<IgniteInternalFuture<T>> futs)
Deprecated.
|
void |
GridCloseableIterator.close()
Closes the iterator and frees all the resources held by the iterator.
|
T |
GridCursor.get()
Gets element at current position.
|
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. |
boolean |
GridCursor.next()
Attempt to move cursor position forward.
|
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. |
protected boolean |
IgniteSingletonIterator.onHasNext() |
protected T |
IgniteSingletonIterator.onNext() |
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 |
GridNioCodecFilter.onExceptionCaught(GridNioSession ses,
IgniteCheckedException ex)
Invoked when exception is caught in filter processing.
|
void |
GridConnectionBytesVerifyFilter.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 |
GridNioFilterChain.onExceptionCaught(GridNioSession ses,
IgniteCheckedException e)
Starts chain notification from head to tail.
|
void |
GridNioFilter.onExceptionCaught(GridNioSession ses,
IgniteCheckedException ex)
Invoked when exception is caught in filter processing.
|
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.
|
byte[] |
GridDelimitedParser.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 |
GridShmemCommunicationClient.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.
|
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 |
GridDelimitedParser.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 |
GridNioCodecFilter.onExceptionCaught(GridNioSession ses,
IgniteCheckedException ex)
Invoked when exception is caught in filter processing.
|
void |
GridConnectionBytesVerifyFilter.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 |
GridNioCodecFilter.onMessageReceived(GridNioSession ses,
Object msg)
Invoked when a new messages received.
|
void |
GridConnectionBytesVerifyFilter.onMessageReceived(GridNioSession ses,
Object msg)
Invoked when a new messages received.
|
void |
GridNioAsyncNotifyFilter.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.
|
void |
GridNioFilter.onMessageReceived(GridNioSession ses,
Object msg)
Invoked when a new messages received.
|
GridNioFuture<?> |
GridNioFilterAdapter.onPauseReads(GridNioSession ses)
Pauses reads for session.
|
GridNioFuture<?> |
GridNioFilterChain.onPauseReads(GridNioSession ses)
Starts chain notification from tail to head.
|
GridNioFuture<?> |
GridNioFilter.onPauseReads(GridNioSession ses)
Pauses reads for session.
|
GridNioFuture<?> |
GridNioFilterAdapter.onResumeReads(GridNioSession ses)
Resumes reads for session.
|
GridNioFuture<?> |
GridNioFilterChain.onResumeReads(GridNioSession ses)
Starts chain notification from tail to head.
|
GridNioFuture<?> |
GridNioFilter.onResumeReads(GridNioSession ses)
Resumes reads for session.
|
GridNioFuture<Boolean> |
GridNioCodecFilter.onSessionClose(GridNioSession ses)
Invoked when a session close request is performed on session.
|
GridNioFuture<Boolean> |
GridConnectionBytesVerifyFilter.onSessionClose(GridNioSession ses)
Invoked when a session close request is performed on session.
|
GridNioFuture<Boolean> |
GridNioAsyncNotifyFilter.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.
|
GridNioFuture<Boolean> |
GridNioFilter.onSessionClose(GridNioSession ses)
Invoked when a session close request is performed on session.
|
void |
GridNioCodecFilter.onSessionClosed(GridNioSession ses)
Invoked after session get closed.
|
void |
GridConnectionBytesVerifyFilter.onSessionClosed(GridNioSession ses)
Invoked after session get closed.
|
void |
GridNioAsyncNotifyFilter.onSessionClosed(GridNioSession ses)
Invoked after session get closed.
|
void |
GridNioFilterChain.onSessionClosed(GridNioSession ses)
Starts chain notification from head to tail.
|
void |
GridNioFilter.onSessionClosed(GridNioSession ses)
Invoked after session get closed.
|
void |
GridNioCodecFilter.onSessionIdleTimeout(GridNioSession ses)
Called when session is idle for longer time that is
allowed by NIO server.
|
void |
GridConnectionBytesVerifyFilter.onSessionIdleTimeout(GridNioSession ses)
Called when session is idle for longer time that is
allowed by NIO server.
|
void |
GridNioAsyncNotifyFilter.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 |
GridNioFilter.onSessionIdleTimeout(GridNioSession ses)
Called when session is idle for longer time that is
allowed by NIO server.
|
void |
GridNioCodecFilter.onSessionOpened(GridNioSession ses)
Invoked when a new session was created.
|
void |
GridConnectionBytesVerifyFilter.onSessionOpened(GridNioSession ses)
Invoked when a new session was created.
|
void |
GridNioAsyncNotifyFilter.onSessionOpened(GridNioSession ses)
Invoked when a new session was created.
|
void |
GridNioFilterChain.onSessionOpened(GridNioSession ses)
Starts chain notification from head to tail.
|
void |
GridNioFilter.onSessionOpened(GridNioSession ses)
Invoked when a new session was created.
|
GridNioFuture<?> |
GridNioCodecFilter.onSessionWrite(GridNioSession ses,
Object msg,
boolean fut,
IgniteInClosure<IgniteException> ackC)
Invoked when a write request is performed on a session.
|
GridNioFuture<?> |
GridConnectionBytesVerifyFilter.onSessionWrite(GridNioSession ses,
Object msg,
boolean fut,
IgniteInClosure<IgniteException> ackC)
Invoked when a write request is performed on a session.
|
GridNioFuture<?> |
GridNioAsyncNotifyFilter.onSessionWrite(GridNioSession ses,
Object msg,
boolean fut,
IgniteInClosure<IgniteException> ackC)
Invoked when a write request is performed on a session.
|
GridNioFuture<?> |
GridNioFilterChain.onSessionWrite(GridNioSession ses,
Object msg,
boolean fut,
IgniteInClosure<IgniteException> ackC)
Starts chain notification from tail to head.
|
GridNioFuture<?> |
GridNioFilter.onSessionWrite(GridNioSession ses,
Object msg,
boolean fut,
IgniteInClosure<IgniteException> ackC)
Invoked when a write request is performed on a session.
|
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 |
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 |
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 |
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 |
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 |
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,
boolean fut,
IgniteInClosure<IgniteException> ackC)
Forwards write request to the next logical filter in filter chain.
|
GridNioFuture<?> |
GridNioFilter.proceedSessionWrite(GridNioSession ses,
Object msg,
boolean fut,
IgniteInClosure<IgniteException> ackC)
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) |
MessageReader |
GridNioMessageReaderFactory.reader(GridNioSession ses,
MessageFactory msgFactory)
Creates new reader.
|
void |
GridCommunicationClient.sendMessage(byte[] data,
int len) |
void |
GridShmemCommunicationClient.sendMessage(byte[] data,
int len) |
void |
GridTcpNioCommunicationClient.sendMessage(byte[] data,
int len) |
void |
GridCommunicationClient.sendMessage(ByteBuffer data) |
void |
GridShmemCommunicationClient.sendMessage(ByteBuffer data) |
void |
GridTcpNioCommunicationClient.sendMessage(ByteBuffer data) |
boolean |
GridCommunicationClient.sendMessage(UUID nodeId,
Message msg,
IgniteInClosure<IgniteException> c) |
boolean |
GridShmemCommunicationClient.sendMessage(UUID nodeId,
Message msg,
IgniteInClosure<IgniteException> c) |
boolean |
GridTcpNioCommunicationClient.sendMessage(UUID nodeId,
Message msg,
IgniteInClosure<IgniteException> c) |
void |
GridNioSession.sendNoFuture(Object msg,
IgniteInClosure<IgniteException> ackC) |
void |
GridNioSessionImpl.sendNoFuture(Object msg,
IgniteInClosure<IgniteException> ackC) |
void |
GridNioServer.sendSystem(GridNioSession ses,
Message msg)
Adds message at the front of the queue without acquiring back pressure semaphore.
|
void |
GridNioServer.sendSystem(GridNioSession ses,
Message msg,
IgniteInClosure<? super IgniteInternalFuture<?>> lsnr)
Adds message at the front of the queue without acquiring back pressure semaphore.
|
MessageWriter |
GridNioMessageWriterFactory.writer(GridNioSession ses)
Creates new writer.
|
| Constructor and Description |
|---|
GridShmemCommunicationClient(int connIdx,
GridNioMetricsListener metricsLsnr,
int port,
long connTimeout,
IgniteLogger log,
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 |
|---|---|
ByteBuffer |
BlockingSslHandler.decode(ByteBuffer buf)
Called by SSL filter when new message was received.
|
boolean |
BlockingSslHandler.handshake()
Performs handshake procedure with remote peer.
|
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,
boolean fut,
IgniteInClosure<IgniteException> ackC)
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(InputStream stream,
String beanName)
Loads bean instance by name.
|
<T> T |
IgniteSpringHelper.loadBean(URL url,
String beanName)
Loads bean instance by name.
|
<T> T |
IgniteSpringHelper.loadBeanFromAppContext(Object appContext,
String beanName)
Loads bean instance by name from application context.
|
Map<Class<?>,Object> |
IgniteSpringHelper.loadBeans(InputStream cfgStream,
Class<?>... beanClasses)
Loads bean instances that match the given types from given configuration input stream.
|
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(InputStream cfgStream,
Class<T> cls,
String... excludedProps)
Loads all configurations with given type specified within given configuration input stream.
|
IgniteBiTuple<Collection<IgniteConfiguration>,? extends GridSpringResourceContext> |
IgniteSpringHelper.loadConfigurations(InputStream cfgStream,
String... excludedProps)
Loads all grid configurations specified within given configuration input stream.
|
<T> IgniteBiTuple<Collection<T>,? extends GridSpringResourceContext> |
IgniteSpringHelper.loadConfigurations(URL cfgUrl,
Class<T> cls,
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.
|
| Constructor and Description |
|---|
VisorCache(IgniteEx ignite,
GridCacheAdapter ca,
int sample)
Create data transfer object for given cache.
|
| 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,
String workDir)
Sets Node id and instantiates
FileHandler delegate. |
| Modifier and Type | Method and Description |
|---|---|
Class |
MarshallerContext.getClass(int typeId,
ClassLoader ldr)
Gets class for provided type ID.
|
String |
MarshallerContext.getClassName(byte platformId,
int typeId)
Gets class name for provided (platformId, typeId) pair.
|
byte[] |
Marshaller.marshal(Object obj)
Marshals object to byte array.
|
byte[] |
AbstractNodeNameAwareMarshaller.marshal(Object obj)
Marshals object to byte array.
|
void |
Marshaller.marshal(Object obj,
OutputStream out)
Marshals object to the output stream.
|
void |
AbstractNodeNameAwareMarshaller.marshal(Object obj,
OutputStream out)
Marshals object to the output stream.
|
protected abstract byte[] |
AbstractNodeNameAwareMarshaller.marshal0(Object obj)
Marshals object to byte array.
|
protected abstract void |
AbstractNodeNameAwareMarshaller.marshal0(Object obj,
OutputStream out)
Marshals object to the output stream.
|
boolean |
MarshallerContext.registerClassName(byte platformId,
int typeId,
String clsName)
Registers class with provided type ID.
|
<T> T |
Marshaller.unmarshal(byte[] arr,
ClassLoader clsLdr)
Unmarshals object from byte array using given class loader.
|
<T> T |
AbstractNodeNameAwareMarshaller.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 input stream using given class loader.
|
<T> T |
AbstractNodeNameAwareMarshaller.unmarshal(InputStream in,
ClassLoader clsLdr)
Unmarshals object from the input stream using given class loader.
|
protected abstract <T> T |
AbstractNodeNameAwareMarshaller.unmarshal0(byte[] arr,
ClassLoader clsLdr)
Unmarshals object from byte array using given class loader.
|
protected abstract <T> T |
AbstractNodeNameAwareMarshaller.unmarshal0(InputStream in,
ClassLoader clsLdr)
Unmarshals object from the input stream using given class loader.
|
| Modifier and Type | Method and Description |
|---|---|
protected byte[] |
JdkMarshaller.marshal0(Object obj)
Marshals object to byte array.
|
protected void |
JdkMarshaller.marshal0(Object obj,
OutputStream out)
Marshals object to the output stream.
|
protected <T> T |
JdkMarshaller.unmarshal0(byte[] arr,
ClassLoader clsLdr)
Unmarshals object from byte array using given class loader.
|
protected <T> T |
JdkMarshaller.unmarshal0(InputStream in,
ClassLoader clsLdr)
Unmarshals object from the input stream using given class loader.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PluginProvider.initExtensions(PluginContext ctx,
ExtensionRegistry registry)
Registers extensions.
|
void |
PluginProvider.onIgniteStart()
Callback that notifies that Ignite has successfully started,
including all internal components.
|
void |
CachePluginProvider.onIgniteStart()
Callback that notifies that Ignite has successfully started,
including all internal components.
|
void |
CachePluginProvider.start()
Starts grid component.
|
void |
PluginProvider.start(PluginContext ctx)
Starts grid component.
|
void |
PluginProvider.stop(boolean cancel)
Stops grid component.
|
void |
CachePluginProvider.validate()
Validates cache plugin configuration in process of cache creation.
|
void |
CachePluginProvider.validateRemote(CacheConfiguration locCfg,
CacheConfiguration rmtCfg,
ClusterNode rmtNode)
Checks that remote caches has configuration compatible with the local.
|
| Modifier and Type | Method and Description |
|---|---|
MessageReader |
MessageFormatter.reader(UUID rmtNodeId,
MessageFactory msgFactory)
Creates new message reader instance.
|
MessageWriter |
MessageFormatter.writer(UUID rmtNodeId)
Creates new message writer instance.
|
| Modifier and Type | Method and Description |
|---|---|
SecurityCredentials |
SecurityCredentialsBasicProvider.credentials()
Gets security credentials.
|
SecurityCredentials |
SecurityCredentialsProvider.credentials()
Gets security credentials.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
SegmentationResolver.isValidSegment()
Checks whether segment is valid.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IgniteSpiOperationTimeoutException
Kind of exception that is used when failure detection timeout is enabled for
TcpDiscoverySpi or
TcpCommunicationSpi. |
| 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.createTcpClient(ClusterNode node,
int connIdx)
Establish TCP connection to remote node and returns client.
|
| Modifier and Type | Method and Description |
|---|---|
protected <T> T |
TcpDiscoverySpi.readMessage(Socket sock,
InputStream in,
long timeout)
Reads message from the socket limiting read time.
|
protected void |
TcpDiscoverySpi.writeToSocket(Socket sock,
OutputStream out,
TcpDiscoveryAbstractMessage msg,
long timeout)
Writes message to the socket.
|
protected void |
TcpDiscoverySpi.writeToSocket(Socket sock,
TcpDiscoveryAbstractMessage msg,
long timeout)
Writes message to the socket.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 2.0.0 Release Date : April 30 2017