Package org.apache.ignite.internal.processors.cache

This package contain cache-related processors & persistence implementation.
See also GitHub Package Readme

Interface Summary

Interface	Description
CacheClassLoaderMarker	It's a marker interface for detecting GridCacheDeploymentManager$CacheClassLoader.
CacheConfigurationSplitter	Splits cache configuration into two parts that can be serialized, deserialized separately.
CacheConflictResolutionManager<K,V>	Conflict resolver manager.
CacheEntryPredicate
CacheEvictionManager
CacheLockCandidates
CacheObject
CacheObjectValueContext	Context to get value of cache object.
CachePartitionExchangeWorkerTask	Cache partition exchange worker task marker interface.
CacheWeakQueryIteratorsHolder.WeakReferenceCloseableIterator<T>
GridCacheAtomicFuture<R>	Update future for atomic cache.
GridCacheConcurrentMap	Concurrent cache map.
GridCacheDeployable	Deployable cache message.
GridCacheEntryEx	Internal API for cache entry ('Ex' stands for extended).
GridCacheFuture<R>	This interface should be implemented by all distributed futures.
GridCacheInternal	Marker interface using in cache implementations.
GridCacheLockCallback	Lock and Unlock callbacks.
GridCacheManager<K,V>	Interface for cache managers.
GridCacheMapEntryFactory	Factory for cache entries.
GridCachePreloader	Cache preloader that is responsible for loading cache entries either from remote nodes (for distributed cache) or anywhere else at cache startup.
GridCacheSharedManager<K,V>	Cache manager shared across all caches.
GridCacheUtils.BackupPostProcessingClosure
GridCacheVersionedFuture<T>	Distributed future aware of lock version.
IgniteCacheExpiryPolicy	Wrapper for ExpiryPolicy used to track information about cache entries whose time to live was modified after access.
IgniteCacheOffheapManager
IgniteCacheOffheapManager.CacheDataStore
IgniteCacheOffheapManager.OffheapInvokeClosure
IgniteCacheProxy<K,V>	Cache proxy.
IgniteInternalCache<K,V>	This interface provides a rich API for working with distributed caches.
IgniteRebalanceIterator	Iterator over supplied data for rebalancing.
KeyCacheObject
PartitionUpdateCounter	Partition update counter maintains three entities for tracking partition update state.

Class Summary

Class	Description
AbstractCachePartitionExchangeWorkerTask
CacheAffinityChangeMessage	CacheAffinityChangeMessage represent a message that switches to a new affinity assignmentafter rebalance is finished.
CacheAffinitySharedManager<K,V>
CacheClientReconnectDiscoveryData	Discovery data sent from client reconnecting to cluster.
CacheClusterMetricsMXBeanImpl	MX bean that keeps support of JCache specification.
CacheConfigurationEnricher	The responsibility of this class is to enrich cache configuration with stored enrichment, in other words it allows to deserialize fields of CacheConfiguration that are marked with SerializeSeparately.
CacheConfigurationEnrichment	Object that contains serialized values for fields marked with SerializeSeparately in CacheConfiguration.
CacheConfigurationOverride	Helper class to override cache configuration.
CacheConfigurationSplitterImpl	Splits cache configuration into two parts that can be serialized, deserialized separately.
CacheData	Cache information sent in discovery data to joining node.
CacheDefaultBinaryAffinityKeyMapper
CacheDiagnosticManager	Component for manage all cache diagnostic functionality.
CacheEntryImpl<K,V>
CacheEntryImpl0<K,V>
CacheEntryImplEx<K,V>
CacheEntryInfoCollection
CacheEntryPredicateAdapter
CacheEntryPredicateContainsValue
CacheEntryPredicateHasValue
CacheEntryPredicateNoValue
CacheEntrySerializablePredicate
CacheEvictableEntryImpl<K,V>	Entry wrapper that never obscures obsolete entries from user.
CacheEvictionEntry
CacheGroupContext
CacheGroupData
CacheGroupDescriptor
CacheGroupMetricsImpl	Cache group metrics.
CacheInvokeDirectResult
CacheInvokeEntry<K,V>	Implementation of MutableEntry passed to the EntryProcessor.process(MutableEntry, Object...).
CacheInvokeResult<T>	Implementation of EntryProcessorResult.
CacheIteratorConverter<T,V>
CacheJoinNodeDiscoveryData	Information about configured caches sent from joining node.
CacheJoinNodeDiscoveryData.CacheInfo
CacheLazyEntry<K,V>
CacheMetricsImpl	Adapter for cache metrics.
CacheMetricsImpl.EntriesStatMetrics	Entries and partitions metrics holder class.
CacheMetricsSnapshot	Metrics snapshot.
CacheNodeCommonDiscoveryData	Cache information sent in discovery data to joining node.
CacheObjectAdapter
CacheObjectByteArrayImpl	Cache object over byte array.
CacheObjectContext
CacheObjectImpl
CacheObjectsReleaseFuture<T,R>
CacheObjectTransformerUtils
CacheObjectUtils	Cache object utility methods.
CacheOffheapEvictionManager
CacheOperationContext	Cache operation context.
CacheOsConflictResolutionManager<K,V>	OS conflict resolver manager.
CachePeekModes
CachesRegistry	Class is responsible to hold and persist cache and cache group descriptors.
CacheStatisticsClearMessage	Cache statistics clear discovery message.
CacheStatisticsModeChangeMessage	Cache statistics mode change discovery message.
CacheStatisticsModeChangeTask	Cache statistics mode change task for exchange worker.
CacheStoreBalancingWrapper<K,V>	Cache store wrapper that ensures that there will be no more that one thread loading value from underlying store.
CacheWeakQueryIteratorsHolder<V>
ClearCachesTask	Clears specified caches.
ClearCachesTaskResult	Result of ClearCachesTask.
ClientCacheChangeDiscoveryMessage	Sent from cache client node to asynchronously notify about started.closed client caches.
ClientCacheChangeDummyDiscoveryMessage	Dummy discovery message which is not really sent via ring, it is just added in local discovery worker queue.
ClusterCachesInfo	Logic related to cache discovery data processing.
DynamicCacheChangeBatch	Cache change batch.
DynamicCacheChangeFailureMessage	This class represents discovery message that is used to provide information about dynamic cache start failure.
DynamicCacheChangeRequest	Cache start/stop request.
DynamicCacheDescriptor	Cache start descriptor.
EntryGetResult
EntryGetWithTtlResult
EntryProcessorResourceInjectorProxy<K,V,T>	Entry processor wrapper injecting Ignite resources into target processor before execution.
ExchangeActions	Cache change requests to execute when receive DynamicCacheChangeBatch event.
ExchangeActions.CacheActionData
ExchangeActions.CacheGroupActionData
ExchangeContext
ExchangeDiscoveryEvents	Discovery events processed in single exchange (contain multiple events if exchanges for multiple discovery events are merged into single exchange).
FetchActiveTxOwnerTraceClosure	Closure that is computed on near node to get the stack trace of active transaction owner thread.
GatewayProtectedCacheProxy<K,V>	Cache proxy wrapper with gateway lock provided operations and possibility to change cache operation context.
GridCacheAdapter<K,V>	Adapter for different cache implementations.
GridCacheAdapter.AtomicReadRepairEntryProcessor<K,V>
GridCacheAdapter.CacheExpiryPolicy
GridCacheAdapter.FutureHolder	Holder for last async operation future.
GridCacheAdapter.InvokeAllTimeStatClosure<T>
GridCacheAdapter.PeekModes
GridCacheAdapter.TopologyVersionAwareJob	Delayed callable class.
GridCacheAdapter.UpdateGetAllTimeStatClosure<T>
GridCacheAdapter.UpdateGetAndRemoveTimeStatClosure<T>
GridCacheAdapter.UpdateGetTimeStatClosure<T>
GridCacheAdapter.UpdatePutAllConflictTimeStatClosure<T>
GridCacheAdapter.UpdatePutAllTimeStatClosure<T>
GridCacheAdapter.UpdatePutAndGetTimeStatClosure<T>
GridCacheAdapter.UpdatePutTimeStatClosure<T>
GridCacheAdapter.UpdateRemoveAllConflictTimeStatClosure<T>
GridCacheAdapter.UpdateRemoveAllTimeStatClosure<T>
GridCacheAdapter.UpdateRemoveTimeStatClosure
GridCacheAdapter.UpdateTimeStatClosure<T>
GridCacheAffinityManager	Cache affinity manager.
GridCacheAtomicVersionComparator	Atomic cache version comparator.
GridCacheAttributes	Cache attributes.
GridCacheClearAllRunnable<K,V>	Base runnable for IgniteInternalCache.clearLocally(boolean, boolean, boolean) routine.
GridCacheCompoundFuture<T,R>
GridCacheCompoundIdentityFuture<T>
GridCacheConcurrentMap.CacheMapHolder
GridCacheConcurrentMapImpl	Implementation of concurrent cache map.
GridCacheContext<K,V>	Cache context.
GridCacheContextInfo<K,V>	Cache context information.
GridCacheDefaultAffinityKeyMapper	Default key affinity mapper.
GridCacheDeploymentManager<K,V>	Deployment manager for cache.
GridCacheEntryInfo	Entry information that gets passed over wire.
GridCacheEventManager	Cache event manager.
GridCacheEvictionManager
GridCacheExplicitLockSpan	Collection of near local locks acquired by a thread on one topology version.
GridCacheFutureAdapter<R>
GridCacheGateway<K,V>	Cache gateway.
GridCacheGroupIdMessage	Message related to particular cache group.
GridCacheIdMessage	Message related to particular cache.
GridCacheIoManager	Cache communication manager.
GridCacheIterator<K,V,T>	Cache-backed iterator.
GridCacheLocalConcurrentMap	GridCacheConcurrentMap implementation for local and near caches.
GridCacheManagerAdapter<K,V>	Convenience adapter for cache managers.
GridCacheMapEntry	Adapter for cache entry.
GridCacheMessage	Parent of all cache messages.
GridCacheMultiTxFuture<K,V>	Future which waits for completion of one or more transactions.
GridCacheMvcc	Replicated lock based on MVCC paradigm.
GridCacheMvccCandidate	Lock candidate.
GridCacheMvccManager	Manages lock order within a thread.
GridCachePartitionExchangeManager<K,V>	Partition exchange manager.
GridCachePreloaderAdapter	Adapter for preloading which always assumes that preloading finished.
GridCacheProcessor	The main responsibility of this processor is orchestrating of starting, stopping caches and everything related to that activity like validation of cache configuration, restoring configuration from persistence, etc.
GridCacheProxyImpl<K,V>	Cache proxy.
GridCacheReturn	Return value for cases where both, value and success flag need to be returned.
GridCacheReturnCompletableWrapper	Provides initialized GridCacheReturn.
GridCacheSharedContext<K,V>	Shared context.
GridCacheSharedContext.Builder	Builder for GridCacheSharedContext.
GridCacheSharedManagerAdapter<K,V>	Convenience adapter for cache managers.
GridCacheSharedTtlCleanupManager	Periodically removes expired entities from caches with CacheConfiguration.isEagerTtl() flag set.
GridCacheTtlManager	Eagerly removes expired entries from cache when CacheConfiguration.isEagerTtl() flag is set.
GridCacheUpdateAtomicResult	Cache entry atomic update result.
GridCacheUpdateTxResult	Cache entry transactional update result.
GridCacheUtilityKey<K extends GridCacheUtilityKey>	Key for system utility cache.
GridCacheUtils	Cache utility methods.
GridCacheValueCollection<K,V>	Value collection based on provided entries with all remove operations backed by underlying cache.
GridChangeGlobalStateMessageResponse
GridDeferredAckMessageSender<T>
GridLocalConfigManager	Responsible for restoring local cache configurations (both from static configuration and persistence).
GridNoStorageCacheMap	Empty cache map that will never store any entries.
IgniteCacheFutureImpl<V>	Implementation of public API future for cache.
IgniteCacheOffheapManagerImpl
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl
IgniteCacheOffheapManagerImpl.ExpiredKeyCacheObject	This entry key is used to indicate that an expired entry has already been deleted from PendingEntriesTree and doesn't need to participate in PendingEntriesTree cleanup again.
IgniteCacheProxyImpl<K,V>	Cache proxy implementation.
IgniteFinishedCacheFutureImpl<V>
IncompleteCacheObject	Cache object container that accumulates partial binary data unless all of them ready.
IncompleteObject<T>	Incomplete object.
KeyCacheObjectImpl
LocalJoinCachesContext	Context to capture caches state for a node joining to an active cluster.
LockedEntriesInfo	Helper class to acquire java level locks on unordered set of entries and avoid deadlocks.
PartitionUpdateCounterDebugWrapper	Update counter wrapper with logging capabilities.
PartitionUpdateCounterErrorWrapper	Update counter wrapper for error logging.
PartitionUpdateCounterTrackingImpl	Update counter implementation used for cache groups in persistent mode for both tx and atomic caches.
PartitionUpdateCounterVolatileImpl	Partition update counter for volatile caches.
PendingDiscoveryEvent
QueryCursorImpl<T>	Query cursor implementation.
ReaderArguments	Arguments required for adding near cache reader to entry.
StartCacheInfo	Specific cache information for start.
StateChangeRequest
StoredCacheData	Cache data to write to and read from IgnitePageStoreManager.
TxTimeoutOnPartitionMapExchangeChangeMessage	Discovery message for changing transaction timeout on partition map exchange.
TxTimeoutOnPartitionMapExchangeChangeTask	The task for changing transaction timeout on partition map exchange.
ValidationOnNodeJoinUtils	Util class for joining node validation.
WalStateAbstractMessage	WAL state change abstract message.
WalStateAckMessage	WAL state ack message (sent from participant node to coordinator).
WalStateDistributedProcess	Distributed process governing WAL state change.
WalStateFinishMessage	WAL state finish message.
WalStateManager	Write-ahead log state manager.
WalStateManager.WALDisableContext	Temporary storage for disabled WALs of group.
WalStateNodeLeaveExchangeTask	Exchange task to handle node leave for WAL state manager.
WalStateProposeMessage	WAL state propose message.
WalStateResult	Local WAL state change result.

Enum Summary

Enum	Description
CacheOperationFilter	Cache operation filter.
CacheType
GridCacheAdapter.BulkOperation
GridCacheOperation	Cache value operations.
GridCacheUpdateAtomicResult.UpdateOutcome
QueryCursorImpl.State	Query cursor state

Exception Summary

Exception	Description
CacheInvalidStateException	This exception is used to indicate that requested operation is unavailable in current cache state.
CachePartialUpdateCheckedException	Exception thrown from non-transactional cache in case when update succeeded only partially.
CacheStoppedException	Used to report attempts of accessing stopped cache.
CacheStorePartialUpdateException
GridCacheEntryRedeployException	Thrown when an entry could not be redeployed.
GridCacheEntryRemovedException	Thrown when an operation is performed on removed entry.
GridCacheFilterFailedException	Thrown when an operation is performed on removed entry.
GridCacheIndexUpdateException	Exception indicating that index update failed during cache entry update.
GridCacheLockTimeoutException	Used to internally indicate that lock acquisition has timed out.
IgnitePeerToPeerClassLoadingException	This exception is thrown in communication-related cases when it is impossible to load class from any peer.