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

This package contain cache-related processors & persistence implementation.

See: Description

Interface Summary

Interface	Description
CacheClassLoaderMarker	It's a marker interface for detecting GridCacheDeploymentManager$CacheClassLoader.
CacheConfigurationSplitter
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
CacheAffinityChangeMessage
CacheAffinitySharedManager<K,V>
CacheClientReconnectDiscoveryData	Discovery data sent from client reconnecting to cluster.
CacheCompressionManager	Cache compression manager.
CacheConfigurationEnricher
CacheConfigurationEnrichment	Object that contains serialized values for fields marked with SerializeSeparately in CacheConfiguration.
CacheConfigurationOverride	Helper class to override cache configuration.
CacheConfigurationSplitterImpl
CacheConfigurationSplitterOldFormat
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.
CacheGroupMetricsMXBeanImpl	Deprecated Use GridMetricManager instead.
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	Deprecated Replaced by CacheMetricsSnapshotV2 with versioning support.
CacheMetricsSnapshotV2	Metrics snapshot.
CacheNodeCommonDiscoveryData	Cache information sent in discovery data to joining node.
CacheObjectAdapter
CacheObjectByteArrayImpl	Cache object over byte array.
CacheObjectContext
CacheObjectImpl
CacheObjectsReleaseFuture<T,R>
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>
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.CacheExpiryPolicy
GridCacheAdapter.FutureHolder	Holder for last async operation future.
GridCacheAdapter.InvokeAllTimeStatClosure<T>
GridCacheAdapter.PeekModes
GridCacheAdapter.TopologyVersionAwareJob	Delayed callable class.
GridCacheAdapter.UpdateGetTimeStatClosure<T>
GridCacheAdapter.UpdatePutAndGetTimeStatClosure<T>
GridCacheAdapter.UpdatePutTimeStatClosure<T>
GridCacheAdapter.UpdateRemoveTimeStatClosure<T>
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.
GridCacheMvccEntryInfo
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.
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
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.
LongOperationsDumpSettingsClosure	Closure that is sent to the node in order to change "Long operations dump timeout" parameter and also reschedule the task for dumping long operations.
LongRunningTxTimeDumpSettingsClosure	Closure that is sent on all server nodes in order to change configuration parameters of dumping long running transactions' system and user time values.
PartitionUpdateCounterDebugWrapper	Update counter wrapper with logging capabilities.
PartitionUpdateCounterMvccImpl	Update counter implementation for MVCC mode.
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.
TxOwnerDumpRequestAllowedSettingClosure	Closure that is sent on all server nodes in order to change transaction configuration parameter that allows or disallows dump requests from local to near nodes while detection long running transactions.
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
CacheInvokeEntry.Operation
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.

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

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