| Package | Description |
|---|---|
| org.apache.ignite |
Contains entry-point Ignite & HPC APIs.
|
| org.apache.ignite.configuration |
Contains configuration-related classes.
|
| org.apache.ignite.internal |
Contains main implementation.
|
| org.apache.ignite.internal.processors.cache | |
| org.apache.ignite.internal.processors.cache.jta | |
| org.apache.ignite.internal.processors.cache.store | |
| org.apache.ignite.internal.processors.cacheobject |
Cache object processor.
|
| org.apache.ignite.internal.processors.igfs |
Contains high performance file system processer.
|
| org.apache.ignite.internal.processors.plugin | |
| org.apache.ignite.internal.processors.query | |
| org.apache.ignite.internal.visor.cache | |
| org.apache.ignite.plugin |
Contains plugins management API.
|
| Modifier and Type | Method and Description |
|---|---|
<K,V> void |
Ignite.addCacheConfiguration(CacheConfiguration<K,V> cacheCfg)
Adds cache configuration template.
|
<K,V> IgniteCache<K,V> |
Ignite.createCache(CacheConfiguration<K,V> cacheCfg)
Dynamically starts new cache with the given cache configuration.
|
<K,V> IgniteCache<K,V> |
Ignite.createCache(CacheConfiguration<K,V> cacheCfg,
NearCacheConfiguration<K,V> nearCfg)
Dynamically starts new cache with the given cache configuration.
|
<K,V> IgniteCache<K,V> |
Ignite.getOrCreateCache(CacheConfiguration<K,V> cacheCfg)
Gets existing cache with the given name or creates new one with the given configuration.
|
<K,V> IgniteCache<K,V> |
Ignite.getOrCreateCache(CacheConfiguration<K,V> cacheCfg,
NearCacheConfiguration<K,V> nearCfg)
Gets existing cache with the given cache configuration or creates one if it does not exist.
|
| Modifier and Type | Method and Description |
|---|---|
CacheConfiguration[] |
IgniteConfiguration.getCacheConfiguration()
Gets configuration (descriptors) for all caches.
|
CacheConfiguration |
CacheConfiguration.setAffinity(AffinityFunction aff)
Sets affinity for cache keys.
|
CacheConfiguration |
CacheConfiguration.setAffinityMapper(AffinityKeyMapper affMapper)
Sets custom affinity mapper.
|
CacheConfiguration |
CacheConfiguration.setAtomicityMode(CacheAtomicityMode atomicityMode)
Sets cache atomicity mode.
|
CacheConfiguration |
CacheConfiguration.setAtomicWriteOrderMode(CacheAtomicWriteOrderMode atomicWriteOrderMode)
Sets cache write ordering mode.
|
CacheConfiguration |
CacheConfiguration.setBackups(int backups)
Sets number of nodes used to back up single partition for
CacheMode.PARTITIONED cache. |
CacheConfiguration |
CacheConfiguration.setCacheMode(CacheMode cacheMode)
Sets caching mode.
|
CacheConfiguration |
CacheConfiguration.setCacheStoreFactory(javax.cache.configuration.Factory<? extends CacheStore<? super K,? super V>> storeFactory)
Sets factory fpr persistent storage for cache data.
|
CacheConfiguration |
CacheConfiguration.setCopyOnRead(boolean cpOnRead)
Sets copy on read flag.
|
CacheConfiguration |
CacheConfiguration.setDefaultLockTimeout(long dfltLockTimeout)
Sets default lock timeout in milliseconds.
|
CacheConfiguration |
CacheConfiguration.setEagerTtl(boolean eagerTtl)
Sets eager ttl flag.
|
CacheConfiguration |
CacheConfiguration.setEvictionFilter(EvictionFilter<K,V> evictFilter)
Sets eviction filter.
|
CacheConfiguration |
CacheConfiguration.setEvictionPolicy(EvictionPolicy evictPlc)
Sets cache eviction policy.
|
CacheConfiguration |
CacheConfiguration.setEvictMaxOverflowRatio(float evictMaxOverflowRatio)
Sets maximum eviction overflow ratio.
|
CacheConfiguration |
CacheConfiguration.setEvictSynchronized(boolean evictSync)
Sets flag indicating whether eviction is synchronized with backup nodes or near caches
(or the rest of the nodes for replicated cache).
|
CacheConfiguration |
CacheConfiguration.setEvictSynchronizedConcurrencyLevel(int evictSyncConcurrencyLvl)
Sets concurrency level for synchronized evictions.
|
CacheConfiguration |
CacheConfiguration.setEvictSynchronizedKeyBufferSize(int evictKeyBufSize)
Sets eviction key buffer size.
|
CacheConfiguration |
CacheConfiguration.setEvictSynchronizedTimeout(long evictSyncTimeout)
Sets timeout for synchronized evictions.
|
CacheConfiguration |
CacheConfiguration.setIndexedTypes(Class<?>... indexedTypes)
Array of key and value type pairs to be indexed (thus array length must be always even).
|
CacheConfiguration |
CacheConfiguration.setInterceptor(CacheInterceptor<K,V> interceptor)
Sets cache interceptor.
|
CacheConfiguration |
CacheConfiguration.setInvalidate(boolean invalidate)
Sets invalidation flag for near cache entries in this transaction.
|
CacheConfiguration |
CacheConfiguration.setLoadPreviousValue(boolean loadPrevVal)
Sets flag indicating whether value should be loaded from store if it is not in the cache
for following cache operations:
IgniteCache.putIfAbsent(Object, Object)
IgniteCache.replace(Object, Object)
IgniteCache.replace(Object, Object, Object)
IgniteCache.remove(Object, Object)
IgniteCache.getAndPut(Object, Object)
IgniteCache.getAndRemove(Object)
IgniteCache.getAndReplace(Object, Object)
IgniteCache.getAndPutIfAbsent(Object, Object)
When not set, default value is DFLT_LOAD_PREV_VAL. |
CacheConfiguration |
CacheConfiguration.setLongQueryWarningTimeout(long longQryWarnTimeout)
Gets timeout in milliseconds after which long query warning will be printed.
|
CacheConfiguration |
CacheConfiguration.setMaxConcurrentAsyncOperations(int maxConcurrentAsyncOps)
Sets maximum number of concurrent asynchronous operations.
|
CacheConfiguration |
CacheConfiguration.setMemoryMode(CacheMemoryMode memMode)
Sets memory mode for cache.
|
CacheConfiguration |
CacheConfiguration.setName(String name)
Sets cache name.
|
CacheConfiguration |
CacheConfiguration.setNearConfiguration(NearCacheConfiguration<K,V> nearCfg) |
CacheConfiguration |
CacheConfiguration.setNodeFilter(IgnitePredicate<ClusterNode> nodeFilter)
Sets filter which determines on what nodes the cache should be started.
|
CacheConfiguration |
CacheConfiguration.setOffHeapMaxMemory(long offHeapMaxMem)
Sets maximum amount of memory available to off-heap storage.
|
CacheConfiguration |
CacheConfiguration.setPluginConfigurations(CachePluginConfiguration... pluginCfgs)
Sets cache plugin configurations.
|
CacheConfiguration |
CacheConfiguration.setReadFromBackup(boolean readFromBackup)
Sets read from backup flag.
|
CacheConfiguration |
CacheConfiguration.setRebalanceBatchSize(int rebalanceBatchSize)
Sets rebalance batch size.
|
CacheConfiguration |
CacheConfiguration.setRebalanceDelay(long rebalanceDelay)
Sets rebalance delay (see
getRebalanceDelay() for more information). |
CacheConfiguration |
CacheConfiguration.setRebalanceMode(CacheRebalanceMode rebalanceMode)
Sets cache rebalance mode.
|
CacheConfiguration |
CacheConfiguration.setRebalanceOrder(int rebalanceOrder)
Sets cache rebalance order.
|
CacheConfiguration |
CacheConfiguration.setRebalanceThreadPoolSize(int rebalancePoolSize)
Sets size of rebalancing thread pool.
|
CacheConfiguration |
CacheConfiguration.setRebalanceThrottle(long rebalanceThrottle)
Time in milliseconds to wait between rebalance messages to avoid overloading of CPU or network.
|
CacheConfiguration |
CacheConfiguration.setRebalanceTimeout(long rebalanceTimeout)
Sets rebalance timeout (ms).
|
CacheConfiguration |
CacheConfiguration.setSqlEscapeAll(boolean sqlEscapeAll)
If
true all the SQL table and field names will be escaped with double quotes like
({@code "tableName"." |
CacheConfiguration |
CacheConfiguration.setSqlFunctionClasses(Class<?>... cls)
Sets classes with methods annotated by
QuerySqlFunction
to be used as user-defined functions from SQL queries. |
CacheConfiguration |
CacheConfiguration.setSqlOnheapRowCacheSize(int size)
Number of SQL rows which will be cached onheap to avoid deserialization on each SQL index access.
|
CacheConfiguration |
CacheConfiguration.setStartSize(int startSize)
Initial size for internal hash map.
|
CacheConfiguration |
CacheConfiguration.setSwapEnabled(boolean swapEnabled)
Flag indicating whether swap storage is enabled or not.
|
CacheConfiguration |
CacheConfiguration.setTopologyValidator(TopologyValidator topValidator)
Sets topology validator.
|
CacheConfiguration |
CacheConfiguration.setTransactionManagerLookupClassName(String tmLookupClsName)
Sets look up mechanism for available
TransactionManager implementation, if any. |
CacheConfiguration |
CacheConfiguration.setTypeMetadata(Collection<CacheTypeMetadata> typeMeta)
Sets collection of type metadata objects.
|
CacheConfiguration |
CacheConfiguration.setWriteBehindBatchSize(int writeBehindBatchSize)
Sets maximum batch size for write-behind cache.
|
CacheConfiguration |
CacheConfiguration.setWriteBehindEnabled(boolean writeBehindEnabled)
Sets flag indicating whether write-behind is enabled.
|
CacheConfiguration |
CacheConfiguration.setWriteBehindFlushFrequency(long writeBehindFlushFreq)
Sets write-behind flush frequency.
|
CacheConfiguration |
CacheConfiguration.setWriteBehindFlushSize(int writeBehindFlushSize)
Sets write-behind flush size.
|
CacheConfiguration |
CacheConfiguration.setWriteBehindFlushThreadCount(int writeBehindFlushThreadCnt)
Sets flush thread count for write-behind cache.
|
CacheConfiguration |
CacheConfiguration.setWriteSynchronizationMode(CacheWriteSynchronizationMode writeSync)
Sets write synchronization mode.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteConfiguration |
IgniteConfiguration.setCacheConfiguration(CacheConfiguration... cacheCfg)
Sets cache configurations.
|
| Modifier and Type | Method and Description |
|---|---|
CacheConfiguration |
GridCachePluginContext.igniteCacheConfiguration() |
| Modifier and Type | Method and Description |
|---|---|
<K,V> void |
IgniteKernal.addCacheConfiguration(CacheConfiguration<K,V> cacheCfg)
Adds cache configuration template.
|
<K,V> IgniteCache<K,V> |
IgniteKernal.createCache(CacheConfiguration<K,V> cacheCfg)
Dynamically starts new cache with the given cache configuration.
|
<K,V> IgniteCache<K,V> |
IgniteKernal.createCache(CacheConfiguration<K,V> cacheCfg,
NearCacheConfiguration<K,V> nearCfg)
Dynamically starts new cache with the given cache configuration.
|
<K,V> IgniteCache<K,V> |
IgniteKernal.getOrCreateCache(CacheConfiguration<K,V> cacheCfg)
Gets existing cache with the given name or creates new one with the given configuration.
|
<K,V> IgniteCache<K,V> |
IgniteKernal.getOrCreateCache(CacheConfiguration<K,V> cacheCfg,
NearCacheConfiguration<K,V> nearCfg)
Gets existing cache with the given cache configuration or creates one if it does not exist.
|
| Constructor and Description |
|---|
GridCachePluginContext(GridKernalContext ctx,
CacheConfiguration igniteCacheCfg,
CachePluginConfiguration cachePluginCfg) |
| Modifier and Type | Field and Description |
|---|---|
protected CacheConfiguration |
GridCacheAdapter.cacheCfg
Cache configuration.
|
| Modifier and Type | Method and Description |
|---|---|
CacheConfiguration |
DynamicCacheDescriptor.cacheConfiguration() |
CacheConfiguration |
GridCacheProcessor.cacheConfiguration(String name)
Get configuration for the given cache.
|
CacheConfiguration |
GridCacheContext.config() |
CacheConfiguration |
GridCacheProxyImpl.configuration()
Gets configuration bean for this cache.
|
CacheConfiguration |
GridCacheAttributes.configuration() |
CacheConfiguration |
IgniteInternalCache.configuration()
Gets configuration bean for this cache.
|
CacheConfiguration |
GridCacheAdapter.configuration()
Gets configuration bean for this cache.
|
static CacheConfiguration |
GridCacheUtils.hadoopSystemCache()
Create system cache used by Hadoop component.
|
CacheConfiguration |
DynamicCacheDescriptor.remoteConfiguration(UUID nodeId) |
CacheConfiguration |
DynamicCacheChangeRequest.startCacheConfiguration() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheProcessor.addCacheConfiguration(CacheConfiguration cacheCfg) |
void |
DynamicCacheDescriptor.addRemoteConfiguration(UUID nodeId,
CacheConfiguration cfg) |
static <C extends CachePluginConfiguration> |
GridCacheUtils.cachePluginConfiguration(CacheConfiguration cfg,
Class<C> cl) |
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,
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.
|
IgniteInternalFuture<?> |
GridCacheProcessor.dynamicStartCache(CacheConfiguration ccfg,
String cacheName,
NearCacheConfiguration nearCfg,
boolean failIfExists)
Dynamically starts cache.
|
IgniteInternalFuture<?> |
GridCacheProcessor.dynamicStartCache(CacheConfiguration ccfg,
String cacheName,
NearCacheConfiguration nearCfg,
CacheType cacheType,
boolean failIfExists)
Dynamically starts cache.
|
static boolean |
GridCacheUtils.isNearEnabled(CacheConfiguration cfg)
Checks if near cache is enabled for cache configuration.
|
void |
DynamicCacheChangeRequest.startCacheConfiguration(CacheConfiguration startCfg) |
| Constructor and Description |
|---|
DynamicCacheDescriptor(GridKernalContext ctx,
CacheConfiguration cacheCfg,
CacheType cacheType,
boolean template,
IgniteUuid deploymentId) |
GridCacheAttributes(CacheConfiguration cfg) |
GridCacheContext(GridKernalContext ctx,
GridCacheSharedContext sharedCtx,
CacheConfiguration cacheCfg,
CacheType cacheType,
boolean affNode,
GridCacheEventManager evtMgr,
GridCacheSwapManager swapMgr,
CacheStoreManager storeMgr,
GridCacheEvictionManager evictMgr,
GridCacheQueryManager<K,V> qryMgr,
CacheContinuousQueryManager contQryMgr,
GridCacheAffinityManager affMgr,
CacheDataStructuresManager dataStructuresMgr,
GridCacheTtlManager ttlMgr,
GridCacheDrManager drMgr,
CacheJtaManagerAdapter jtaMgr,
CacheConflictResolutionManager<K,V> rslvrMgr,
CachePluginManager pluginMgr) |
| Modifier and Type | Method and Description |
|---|---|
abstract void |
CacheJtaManagerAdapter.createTmLookup(CacheConfiguration ccfg)
Creates transaction manager finder.
|
void |
CacheNoopJtaManager.createTmLookup(CacheConfiguration ccfg)
Creates transaction manager finder.
|
| Modifier and Type | Method and Description |
|---|---|
protected CacheConfiguration |
CacheOsStoreManager.cacheConfiguration() |
protected abstract CacheConfiguration |
GridCacheStoreManagerAdapter.cacheConfiguration() |
| Constructor and Description |
|---|
CacheOsStoreManager(GridKernalContext ctx,
CacheConfiguration cfg)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
CacheObjectContext |
IgniteCacheObjectProcessorImpl.contextForCache(CacheConfiguration ccfg) |
CacheObjectContext |
IgniteCacheObjectProcessor.contextForCache(CacheConfiguration ccfg) |
| Modifier and Type | Method and Description |
|---|---|
void |
IgfsNoopHelper.preProcessCacheConfiguration(CacheConfiguration cfg)
Pre-process cache configuration.
|
void |
IgfsHelperImpl.preProcessCacheConfiguration(CacheConfiguration cfg)
Pre-process cache configuration.
|
void |
IgfsHelper.preProcessCacheConfiguration(CacheConfiguration cfg)
Pre-process cache configuration.
|
void |
IgfsNoopHelper.validateCacheConfiguration(CacheConfiguration cfg)
Validate cache configuration for IGFS.
|
void |
IgfsHelperImpl.validateCacheConfiguration(CacheConfiguration cfg)
Validate cache configuration for IGFS.
|
void |
IgfsHelper.validateCacheConfiguration(CacheConfiguration cfg)
Validate cache configuration for IGFS.
|
| Modifier and Type | Method and Description |
|---|---|
void |
CachePluginManager.validateRemotes(CacheConfiguration rmtCfg,
ClusterNode rmtNode)
Checks that remote caches has configuration compatible with the local.
|
| Constructor and Description |
|---|
CachePluginManager(GridKernalContext ctx,
CacheConfiguration cfg) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridQueryProcessor.initializeCache(CacheConfiguration<?,?> ccfg) |
static boolean |
GridQueryProcessor.isEnabled(CacheConfiguration<?,?> ccfg) |
void |
GridQueryIndexing.registerCache(CacheConfiguration<?,?> ccfg)
Registers cache.
|
void |
GridQueryIndexing.unregisterCache(CacheConfiguration<?,?> ccfg)
Deregisters cache.
|
| Modifier and Type | Method and Description |
|---|---|
CacheConfiguration |
CachePluginContext.igniteCacheConfiguration() |
| Modifier and Type | Method and Description |
|---|---|
void |
CachePluginProvider.validateRemote(CacheConfiguration locCfg,
C locPluginCcfg,
CacheConfiguration rmtCfg,
ClusterNode rmtNode)
Checks that remote caches has configuration compatible with the local.
|
void |
CachePluginProvider.validateRemote(CacheConfiguration locCfg,
C locPluginCcfg,
CacheConfiguration rmtCfg,
ClusterNode rmtNode)
Checks that remote caches has configuration compatible with the local.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.1.0-incubating Release Date : May 20 2015