Package org.apache.ignite.internal.processors.cache
This package contain cache-related processors & persistence implementation.
See also GitHub Package Readme
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 forExpiryPolicyused 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 ofCacheConfigurationthat are marked withSerializeSeparately.CacheConfigurationEnrichment Object that contains serialized values for fields marked withSerializeSeparatelyinCacheConfiguration.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 ofMutableEntrypassed to theEntryProcessor.process(MutableEntry, Object...).CacheInvokeResult<T> Implementation ofEntryProcessorResult.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 ofClearCachesTask.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 receiveDynamicCacheChangeBatchevent.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 forIgniteInternalCache.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 forGridCacheSharedContext.GridCacheSharedManagerAdapter<K,V> Convenience adapter for cache managers.GridCacheSharedTtlCleanupManager Periodically removes expired entities from caches withCacheConfiguration.isEagerTtl()flag set.GridCacheTtlManager Eagerly removes expired entries from cache whenCacheConfiguration.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 fromIgnitePageStoreManager.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.