|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
CacheLoader
that holds common implementations for some methodsCacheStore
that holds common implementations for some methodsAbstractCacheStore
.AbstractDelegatingCache
, but for AdvancedCache
.AdvancedExternalizer
implementations that offers default
implementations for some of its methods.CacheManagerNotifierImpl
and
CacheNotifierImpl
ModuleLifecycle
interface, designed for easy
extension.AbstractConfigurationBean
.GlobalTransaction
TxInvocationContext
.SegmentReadLocker.deleteOrReleaseReadLock(String)
from deleting the file.
SegmentReadLocker.deleteOrReleaseReadLock(String)
from deleting the file.
BufferSizePredictor
that automatically increases and
decreases the predicted buffer size on feed back.AdvancedExternalizer
with the give id.
AdvancedExternalizer
.
AdvancedExternalizer
implementation
alongside its corresponding identifier.
AdvancedExternalizer
implementations.
CacheLoaderManagerConfig.addCacheLoader(org.infinispan.loaders.CacheLoaderConfig...)
instead
Fqn
under the current node.
AbstractComponentRegistry.Component.injectionMethods
.
Cache
.AdvancedExternalizer
provides an alternative way to provide
externalizers for marshalling/unmarshalling user defined classes that
overcome the deficiencies of the more user-friendly externalizer definition
model explained in Externalizer
.mods
atomically by creating a worker
and invoking
them in TransactionRunner.run(com.sleepycat.collections.TransactionWorker)
.
null
.
AtomicMap
.AtomicHashMap
to provide consistency and isolation for concurrent readers
while writes may also be going on.Base64.InputStream
will read data from another
java.io.InputStream, given in the constructor,
and encode/decode to/from Base64 notation on the fly.Base64.InputStream
in DECODE mode.
Base64.InputStream
in
either ENCODE or DECODE mode.
Base64.OutputStream
will write data to another
java.io.OutputStream, given in the constructor,
and encode/decode to/from Base64 notation on the fly.Base64.OutputStream
in ENCODE mode.
Base64.OutputStream
in
either ENCODE or DECODE mode.
InfinispanDirectory
,
this factory produces instances of BaseLuceneLock
.Cache.startBatch()
and
Cache.endBatch(boolean)
calls.CacheStore
.BdbjeCacheStore
.LinkedHashMap
except that this version makes use of the fact that entries are
bidirectionally linked and can hence be navigated either from the start or from the end.beforeCommand()
.
Executors
except that the factory methods here allow you to specify the
size of the blocking queue that backs the executor.RpcManager.broadcastRpcCommand(org.infinispan.commands.ReplicableCommand, boolean)
except that the task
is passed to the transport executor and a Future is returned.
RpcManager.broadcastRpcCommand(org.infinispan.commands.ReplicableCommand, boolean, boolean)
except that
the task is passed to the transport executor and a Future is returned.
CacheStoreConfig
level.
GetInDoubtTransactionsCommand
.
RemoveRecoveryInfoCommand
.
Cache
instance, and is often
used as a starting point to using the Cache
.CacheEntriesEvicted
.CacheEntryActivated
.CacheEntryCreated
.CacheLoader
.CacheEntryLoaded
.CacheEntryModified
The CacheEntryModifiedEvent.getValue()
method's behavior is specific to whether the callback is triggered before or after the event
in question.CacheEntryPassivated
.CacheEntryRemoved
.CacheEntryVisited
.Cache
fail unexpectedly.CacheContainer.getCache()
methods and has not yet been removed via
EmbeddedCacheManager.removeCache(String)
.
Configuration.isExposeJmxStatistics()
is true, then class will register all the MBeans from cache local's
ConfigurationRegistry to the MBean server.CacheLoader
implementation if there are problems reading from a loader.Cache
and AdvancedCache
.SearchManagerImpl
.CacheRemoveAll
interceptor.CacheRemoveEntry
interceptor.This interceptor uses the following algorithm
describes in JSR-107.CacheResult
interceptor.RpcManager
only replicates commands wrapped in a CacheRpcCommand
.CacheStarted
.CacheStopped
.CacheLoader
interface that can be written to.CacheLoader
based on Apache Cassandra project.CassandraCacheStore
.CacheStore.clear()
modificationMap.clear()
.
CloudCacheStore
.ClusterCacheLoader
.ClusteredGetCommand
s.Mapper
ReplicableCommand
s.Visitor
interface allowing it to
intercept invocations on VisitableCommand
s.DeltaAware.delta()
) and can be
discarded.
TransactionXaAdapter.prepare(javax.transaction.xa.Xid)
applies for commit.
FqnComparator
.
tx
.
RecoveryAwareRemoteTransaction.isOrphan()
.
ConcurrentHashMap
to deal with the fact that the
JDK does not have a proper concurrent Set implementation that uses efficient lock striping.ConcurrentMap
which is similar to ConcurrentHashMap
.Configuration
.Configuration
s.ConnectionFactory
.ConsistentHash
function.MurmurHash2
;FactoryBean
for creating a CacheManager
for a pre-defined CacheContainer
.CacheLoader.load(Object)
, to ensure that a response is
returned only if the entry is not expired.
JdbmCacheStoreConfig.setComparatorClassName(String)
.
TxInvocationContext
.
NonTxInvocationContext
with the
NonTxInvocationContext.isOriginLocal()
returning true.
NonTxInvocationContext
whose
NonTxInvocationContext.isOriginLocal()
flag will be true.
#createRemoteInvocationContext()
, but returning the flags to the context from
the Command if any Flag was set.
RemoteTransaction
based on the supplied params.
RemoteTransaction
with no modifications.
RemoteTxInvocationContext
.
StoredMap
persisted by the database
StoredMap
persisted by the database
Cache
as a parameter
LocalTxInvocationContext
.
JdbcStringBasedCacheStore
and JdbcBinaryCacheStore
.DataRehashed
.DldGlobalTransaction
with
appropriate information needed in order to accomplish deadlock detection.Version.getVersionShort()
.
ExecutorFactory
based on an ThreadPoolExecutor
.Cache
instance, and is often used as a
starting point to using the Cache
.ContextClassLoader
to add a default class loader
in case the context class loader is null
.ExecutorService
and DistributedExecutorService
.TwoWayKey2StringMapper
that knows how to
handle all primitive wrapper keys and Strings.InfinispanIndexInput
instances are reading from it, then it will
be effectively deleted.
DeltaAware
implementation.Delta
s.SpringEmbeddedCacheManager
instance created by this
FactoryBean
.
stop
the
RemoteCacheManager
created by this factory.
EmbeddedCacheManager
instance created by this
FactoryBean
.
org.infinispan.Cache
created by this FactoryBean
.
org.infinispan.Cache
created by this FactoryBean
.
stop
the
RemoteCacheManager
created by this factory.
FluentTypes.indexing()
method enables Indexing implicitly.
CompletionService
that uses a supplied DistributedExecutorService
to execute tasks.LinkedBlockingQueue
as a completion queue.
Modification
objects and
executes it against the CacheStore
. Current commands supported are: STORE CLEAR
REMOVE PURGE_EXPIRED
RemoteTransactionLogger.drain()
except that relevant locks are acquired so that no more commands are added to the
transaction log during this process, and transaction logging is disabled after draining.
RoundRobinBalancingStrategy.nextServer()
without modifying indexes/state.
DummyTransactionManager
.Configuration
as being modifiable even after the cache has started.Mapper
implementor
Group
annotations are honoured and any configured
groupers will be invoked
Cache.startBatch()
.
MVCCEntry
instances for use in the InvocationContext
.Set
view of the mappings contained in this map.
Set
view of the mappings contained in this map.
Map.entrySet()
functionality.Configuration.equalsIgnoreName(Object)
for equality that does not consider the name of the configuration.
Configuration.equals(Object)
but it ignores the Configuration.getName()
attribute in the comparison.
Collator
Collator
and wrapped by Future
Explanation
object describing the score computation for the matching object/document
in the current query
BucketBasedCacheStore
.FileCacheStore
.Flag
.RecoveryManager.forceTransactionCompletion(javax.transaction.xa.Xid, boolean)
on the specified node.
Node
in a TreeCache
.CacheKey
for the given InvocationContext
by using the given CacheKeyGenerator
class.
Node
.
null
if this map contains no mapping for the
key.
null
if this map contains no mapping for the key.
null
if this map contains no mapping for the
key.
Map.get(Object)
that allows user code to
retrieve the value associated with a key at a later stage, hence allowing
multiple parallel get requests to be sent.
RequestBalancingStrategy
may not be thread-safe.
RemoteCache.getBulk()
, but limits the returned set of values to the specified size.
CacheContainer.getCache(String)
does except that if offers the possibility for the
named cache not to be retrieved if it has not yet been started, or if
it's been removed after being started.
Configuration.getCacheLoaders()
, Configuration.isCacheLoaderShared()
Configuration.isFetchPersistentState()
, Configuration.isCacheLoaderPassivation()
and Configuration.isCacheLoaderPreload()
instead
org.infinispan.client.hotrod.RemoteCache
does
not support retrieving the set of all cache names from the hotrod server.
clone
of the Configuration
registered under the given name.
CacheLoaderConfig
type.
CacheLoaderConfig
type.
ConnectionFactory
based on the supplied class
name.
ConsistentHash
may not be thread-safe.
DefaultConsistentHash
.
RpcManager.retrieveState(String, long)
has been invoked and hasn't yet returned (i.e., a state transfer is in
progress), this method will return the current Address from which a state transfer is being attempted.
CustomInterceptorConfig
, if any, associated with this configuration
object.
Node
.
DataContainer
DistributionManager
if the cache is configured
to use Distribution.
Configuration.getExpirationWakeUpInterval()
Fqn
which represents the location of this