| Modifier and Type | Interface and Description |
|---|---|
interface |
AdvancedCache<K,V>
An advanced interface that exposes additional methods not available on
Cache. |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractDelegatingAdvancedCache<K,V>
Similar to
AbstractDelegatingCache, but for AdvancedCache. |
class |
AbstractDelegatingCache<K,V>
This is a convenient base class for implementing a cache delegate.
|
class |
CacheImpl<K,V> |
class |
DecoratedCache<K,V>
A decorator to a cache, which can be built with a specific
ClassLoader and a set of Flags. |
| Modifier and Type | Method and Description |
|---|---|
Cache<K,V> |
AbstractDelegatingCache.getDelegate() |
| Constructor and Description |
|---|
AbstractDelegatingCache(Cache<K,V> cache) |
| Modifier and Type | Method and Description |
|---|---|
static <K,V> KeyAffinityService<K> |
KeyAffinityServiceFactory.newKeyAffinityService(Cache<K,V> cache,
Collection<Address> filter,
KeyGenerator<K> keyGenerator,
Executor ex,
int keyBufferSize)
|
static <K,V> KeyAffinityService<K> |
KeyAffinityServiceFactory.newKeyAffinityService(Cache<K,V> cache,
Collection<Address> filter,
KeyGenerator<K> keyGenerator,
Executor ex,
int keyBufferSize,
boolean start)
Creates a service that would only generate keys for addresses specified in filter.
|
static <K,V> KeyAffinityService<K> |
KeyAffinityServiceFactory.newKeyAffinityService(Cache<K,V> cache,
Executor ex,
KeyGenerator<K> keyGenerator,
int keyBufferSize)
|
static <K,V> KeyAffinityService<K> |
KeyAffinityServiceFactory.newKeyAffinityService(Cache<K,V> cache,
Executor ex,
KeyGenerator<K> keyGenerator,
int keyBufferSize,
boolean start)
Creates an
KeyAffinityService instance that generates keys mapped to all addresses
in the cluster. |
static <K,V> KeyAffinityService<K> |
KeyAffinityServiceFactory.newLocalKeyAffinityService(Cache<K,V> cache,
KeyGenerator<K> keyGenerator,
Executor ex,
int keyBufferSize)
|
static <K,V> KeyAffinityService<K> |
KeyAffinityServiceFactory.newLocalKeyAffinityService(Cache<K,V> cache,
KeyGenerator<K> keyGenerator,
Executor ex,
int keyBufferSize,
boolean start)
Created an service that only generates keys for the local address.
|
| Constructor and Description |
|---|
KeyAffinityServiceImpl(Executor executor,
Cache<? extends K,?> cache,
KeyGenerator<? extends K> keyGenerator,
int bufferSize,
Collection<Address> filter,
boolean start) |
| Modifier and Type | Method and Description |
|---|---|
static <MK,K,V> AtomicMap<K,V> |
AtomicMapLookup.getAtomicMap(Cache<MK,?> cache,
MK key)
Retrieves an atomic map from a given cache, stored under a given key.
|
static <MK,K,V> AtomicMap<K,V> |
AtomicMapLookup.getAtomicMap(Cache<MK,?> cache,
MK key,
boolean createIfAbsent)
Retrieves an atomic map from a given cache, stored under a given key.
|
static <MK,K,V> FineGrainedAtomicMap<K,V> |
AtomicMapLookup.getFineGrainedAtomicMap(Cache<MK,?> cache,
MK key)
Retrieves a fine grained atomic map from a given cache, stored under a given key.
|
static <MK,K,V> FineGrainedAtomicMap<K,V> |
AtomicMapLookup.getFineGrainedAtomicMap(Cache<MK,?> cache,
MK key,
boolean createIfAbsent)
Retrieves an atomic map from a given cache, stored under a given key.
|
static <MK,K,V> Map<K,V> |
AtomicMapLookup.getReadOnlyAtomicMap(Cache<MK,?> cache,
MK key)
Retrieves an atomic map from a given cache, stored under a given key, for reading only.
|
static <K,V> AtomicHashMap<K,V> |
AtomicHashMap.newInstance(Cache<Object,Object> cache,
Object cacheKey)
Construction only allowed through this factory method.
|
static <MK> void |
AtomicMapLookup.removeAtomicMap(Cache<MK,?> cache,
MK key)
Removes the atomic map associated with the given key from the underlying cache.
|
| Modifier and Type | Method and Description |
|---|---|
static <K,V> Cache<K,V> |
ContextInputCache.get() |
| Modifier and Type | Method and Description |
|---|---|
<T,K,V> void |
CDIDistributedTaskLifecycle.onPreExecute(Callable<T> task,
Cache<K,V> inputCache) |
<KIn,VIn,KOut,VOut> |
CDIMapReduceTaskLifecycle.onPreExecute(Mapper<KIn,VIn,KOut,VOut> mapper,
Cache<KIn,VIn> inputCache) |
<KOut,VOut> |
CDIMapReduceTaskLifecycle.onPreExecute(Reducer<KOut,VOut> reducer,
Cache<?,?> cache) |
static <K,V> void |
ContextInputCache.set(Cache<K,V> input) |
| Modifier and Type | Method and Description |
|---|---|
<K,V> Cache<K,V> |
Session.getCache(String cacheName)
Returns a named cache.
|
<K,V> Cache<K,V> |
SessionImpl.getCache(String cacheName) |
<K,V> Cache<K,V> |
Session.getCurrentCache()
Obtains the currently selected cache.
|
<K,V> Cache<K,V> |
SessionImpl.getCurrentCache() |
| Constructor and Description |
|---|
CLInterfaceSourceMigrator(Cache<?,?> cache) |
| Modifier and Type | Method and Description |
|---|---|
void |
CommandsFactoryImpl.setupDependencies(DataContainer container,
CacheNotifier notifier,
Cache<Object,Object> cache,
InterceptorChain interceptorChain,
DistributionManager distributionManager,
InvocationContextFactory icf,
TransactionTable txTable,
Configuration configuration,
Map<Byte,ModuleCommandInitializer> moduleCommandInitializers,
RecoveryManager recoveryManager,
StateProvider stateProvider,
StateConsumer stateConsumer,
LockManager lockManager,
InternalEntryFactory entryFactory,
MapReduceManager mapReduceManager,
StateTransferManager stm,
BackupSender backupSender,
CancellationService cancellationService,
TimeService timeService) |
| Modifier and Type | Method and Description |
|---|---|
void |
DistributedExecuteCommand.init(Cache<Object,Object> cache) |
| Modifier and Type | Method and Description |
|---|---|
void |
Custom52xCacheStore.init(CacheLoaderConfig config,
Cache<?,?> cache,
StreamingMarshaller m) |
| Modifier and Type | Method and Description |
|---|---|
void |
SimpleClusteredVersionGenerator.init(Cache<?,?> cache) |
void |
NumericVersionGenerator.init(Cache<?,?> cache) |
| Modifier and Type | Method and Description |
|---|---|
protected Cache<String,String> |
Demo.startCache() |
| Modifier and Type | Method and Description |
|---|---|
void |
DistributedCallable.setEnvironment(Cache<K,V> cache,
Set<K> inputKeys)
Invoked by execution environment after DistributedCallable has been migrated for execution to
a specific Infinispan node.
|
| Constructor and Description |
|---|
DefaultExecutorService(Cache<?,?> masterCacheNode)
Creates a new DefaultExecutorService given a master cache node for local task execution.
|
DefaultExecutorService(Cache<?,?> masterCacheNode,
ExecutorService localExecutorService)
Creates a new DefaultExecutorService given a master cache node and an ExecutorService for
parallel execution of tasks ran on this node.
|
DefaultExecutorService(Cache<?,?> masterCacheNode,
ExecutorService localExecutorService,
boolean takeExecutorOwnership)
Creates a new DefaultExecutorService given a master cache node and an ExecutorService for
parallel execution of task ran on this node.
|
| Constructor and Description |
|---|
MapReduceTask(Cache<KIn,VIn> masterCacheNode)
Create a new MapReduceTask given a master cache node.
|
MapReduceTask(Cache<KIn,VIn> masterCacheNode,
boolean distributeReducePhase)
Create a new MapReduceTask given a master cache node.
|
MapReduceTask(Cache<KIn,VIn> masterCacheNode,
boolean distributeReducePhase,
boolean useIntermediateSharedCache)
Create a new MapReduceTask given a master cache node.
|
| Modifier and Type | Method and Description |
|---|---|
<KIn,VIn,KOut,VOut> |
DefaultMapReduceTaskLifecycle.onPreExecute(Mapper<KIn,VIn,KOut,VOut> mapper,
Cache<KIn,VIn> inputCache) |
<KIn,VIn,KOut,VOut> |
MapReduceTaskLifecycleService.onPreExecute(Mapper<KIn,VIn,KOut,VOut> mapper,
Cache<KIn,VIn> inputCache) |
<KIn,VIn,KOut,VOut> |
MapReduceTaskLifecycle.onPreExecute(Mapper<KIn,VIn,KOut,VOut> mapper,
Cache<KIn,VIn> inputCache) |
<KOut,VOut> |
DefaultMapReduceTaskLifecycle.onPreExecute(Reducer<KOut,VOut> reducer,
Cache<?,?> inputCache) |
<KOut,VOut> |
MapReduceTaskLifecycleService.onPreExecute(Reducer<KOut,VOut> reducer,
Cache<?,?> inputCache) |
<KOut,VOut> |
MapReduceTaskLifecycle.onPreExecute(Reducer<KOut,VOut> reducer,
Cache<?,?> inputCache) |
| Modifier and Type | Method and Description |
|---|---|
<T,K,V> void |
DefaultDistributedTaskLifecycle.onPreExecute(Callable<T> task,
Cache<K,V> inputCache) |
<T,K,V> void |
DistributedTaskLifecycle.onPreExecute(Callable<T> task,
Cache<K,V> inputDataCache) |
<T,K,V> void |
DistributedTaskLifecycleService.onPreExecute(Callable<T> task,
Cache<K,V> inputCache) |
| Modifier and Type | Method and Description |
|---|---|
Cache<String,Influenza_N_P_CR_Element> |
InfluenzaVirusCache.getCache() |
Cache<String,Nucleotide_Protein_Element> |
ProteinCache.getCache() |
Cache<String,Nucleotide_Protein_Element> |
NucleotideCache.getCache() |
| Modifier and Type | Method and Description |
|---|---|
void |
EvictionManagerImpl.initialize(ScheduledExecutorService executor,
Cache cache,
Configuration cfg,
DataContainer dataContainer,
PersistenceManager persistenceManager,
CacheNotifier cacheNotifier,
TimeService timeService) |
| Modifier and Type | Method and Description |
|---|---|
Cache<K,V> |
InternalCacheFactory.createCache(Configuration configuration,
GlobalComponentRegistry globalComponentRegistry,
String cacheName)
This implementation clones the configuration passed in before using it.
|
| Modifier and Type | Field and Description |
|---|---|
protected Cache<?,?> |
BaseCustomInterceptor.cache |
| Modifier and Type | Field and Description |
|---|---|
protected Cache<String,byte[]> |
GridFilesystem.data |
protected Cache<String,GridFile.Metadata> |
GridFilesystem.metadata |
| Constructor and Description |
|---|
GridFilesystem(Cache<String,byte[]> data,
Cache<String,GridFile.Metadata> metadata) |
GridFilesystem(Cache<String,byte[]> data,
Cache<String,GridFile.Metadata> metadata) |
GridFilesystem(Cache<String,byte[]> data,
Cache<String,GridFile.Metadata> metadata,
int defaultChunkSize)
Creates an instance.
|
GridFilesystem(Cache<String,byte[]> data,
Cache<String,GridFile.Metadata> metadata,
int defaultChunkSize)
Creates an instance.
|
| Modifier and Type | Method and Description |
|---|---|
void |
CacheJmxRegistration.initialize(Cache<?,?> cache,
GlobalConfiguration globalConfig) |
| Modifier and Type | Field and Description |
|---|---|
protected Cache<Object,Object> |
AbstractCacheLoader.cache |
| Modifier and Type | Method and Description |
|---|---|
void |
CacheLoader.init(CacheLoaderConfig config,
Cache<?,?> cache,
StreamingMarshaller m)
Used to initialize a cache loader.
|
void |
AbstractCacheStore.init(CacheLoaderConfig config,
Cache<?,?> cache,
StreamingMarshaller m) |
void |
AbstractCacheLoader.init(CacheLoaderConfig config,
Cache<?,?> cache,
StreamingMarshaller m) |
void |
LockSupportCacheStore.init(CacheLoaderConfig config,
Cache<?,?> cache,
StreamingMarshaller m) |
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractDelegatingStore.init(CacheLoaderConfig config,
Cache<?,?> cache,
StreamingMarshaller m) |
void |
ChainingCacheStore.init(CacheLoaderConfig config,
Cache<?,?> cache,
StreamingMarshaller m) |
void |
AsyncStore.init(CacheLoaderConfig config,
Cache<?,?> cache,
StreamingMarshaller m) |
protected void |
SingletonStore.pushState(Cache<Object,Object> cache)
Pushes the state of a specific cache by reading the cache's data and putting in the cache store.
|
| Constructor and Description |
|---|
SingletonStore(CacheStore delegate,
Cache<Object,Object> cache,
SingletonStoreConfig config) |
| Constructor and Description |
|---|
InfinispanDirectory(Cache<?,?> cache)
Deprecated.
|
InfinispanDirectory(Cache<?,?> metadataCache,
Cache<?,?> chunksCache,
Cache<?,?> distLocksCache,
String indexName,
int chunkSize)
Deprecated.
This constructor assumes that three different caches are being used with specialized configurations for each
cache usage
|
InfinispanDirectory(Cache<?,?> metadataCache,
Cache<?,?> chunksCache,
Cache<?,?> distLocksCache,
String indexName,
int chunkSize)
Deprecated.
This constructor assumes that three different caches are being used with specialized configurations for each
cache usage
|
InfinispanDirectory(Cache<?,?> metadataCache,
Cache<?,?> chunksCache,
Cache<?,?> distLocksCache,
String indexName,
int chunkSize)
Deprecated.
This constructor assumes that three different caches are being used with specialized configurations for each
cache usage
|
InfinispanDirectory(Cache<?,?> metadataCache,
Cache<?,?> chunksCache,
String indexName,
org.apache.lucene.store.LockFactory lf,
int chunkSize,
SegmentReadLocker readLocker)
Deprecated.
|
InfinispanDirectory(Cache<?,?> metadataCache,
Cache<?,?> chunksCache,
String indexName,
org.apache.lucene.store.LockFactory lf,
int chunkSize,
SegmentReadLocker readLocker)
Deprecated.
|
InfinispanDirectory(Cache<?,?> cache,
String indexName)
Deprecated.
|
InfinispanDirectory(Cache<?,?> cache,
String indexName,
int chunkSize,
SegmentReadLocker readLocker)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
static BuildContext |
DirectoryBuilder.newDirectoryInstance(Cache<?,?> metadataCache,
Cache<?,?> chunksCache,
Cache<?,?> distLocksCache,
String indexName)
Starting point to create a Directory instance.
|
static BuildContext |
DirectoryBuilder.newDirectoryInstance(Cache<?,?> metadataCache,
Cache<?,?> chunksCache,
Cache<?,?> distLocksCache,
String indexName)
Starting point to create a Directory instance.
|
static BuildContext |
DirectoryBuilder.newDirectoryInstance(Cache<?,?> metadataCache,
Cache<?,?> chunksCache,
Cache<?,?> distLocksCache,
String indexName)
Starting point to create a Directory instance.
|
| Constructor and Description |
|---|
DirectoryBuilderImpl(Cache<?,?> metadataCache,
Cache<?,?> chunksCache,
Cache<?,?> distLocksCache,
String indexName) |
DirectoryBuilderImpl(Cache<?,?> metadataCache,
Cache<?,?> chunksCache,
Cache<?,?> distLocksCache,
String indexName) |
DirectoryBuilderImpl(Cache<?,?> metadataCache,
Cache<?,?> chunksCache,
Cache<?,?> distLocksCache,
String indexName) |
| Constructor and Description |
|---|
BaseLockFactory(Cache<?,?> cache,
String indexName) |
TransactionalLockFactory(Cache<?,?> cache,
String indexName) |
| Constructor and Description |
|---|
DistributedSegmentReadLocker(Cache<?,?> cache,
String indexName) |
DistributedSegmentReadLocker(Cache<Object,Integer> locksCache,
Cache<?,?> chunksCache,
Cache<?,?> metadataCache,
String indexName) |
DistributedSegmentReadLocker(Cache<Object,Integer> locksCache,
Cache<?,?> chunksCache,
Cache<?,?> metadataCache,
String indexName) |
DistributedSegmentReadLocker(Cache<Object,Integer> locksCache,
Cache<?,?> chunksCache,
Cache<?,?> metadataCache,
String indexName) |
LocalLockMergingSegmentReadLocker(Cache<?,?> locksCache,
Cache<?,?> chunksCache,
Cache<?,?> metadataCache,
String indexName)
Create a new LocalLockMergingSegmentReadLocker with special purpose caches
|
LocalLockMergingSegmentReadLocker(Cache<?,?> locksCache,
Cache<?,?> chunksCache,
Cache<?,?> metadataCache,
String indexName)
Create a new LocalLockMergingSegmentReadLocker with special purpose caches
|
LocalLockMergingSegmentReadLocker(Cache<?,?> locksCache,
Cache<?,?> chunksCache,
Cache<?,?> metadataCache,
String indexName)
Create a new LocalLockMergingSegmentReadLocker with special purpose caches
|
LocalLockMergingSegmentReadLocker(Cache<?,?> cache,
String indexName)
Create a new LocalLockMergingSegmentReadLocker for specified cache and index name.
|
| Constructor and Description |
|---|
DemoActions(InfinispanDirectory index,
Cache<?,?> cache) |
DemoDriver(InfinispanDirectory infinispanDirectory,
Cache<?,?> cache) |
| Modifier and Type | Method and Description |
|---|---|
<K,V> Cache<K,V> |
DefaultCacheManager.getCache()
Retrieves the default cache associated with this cache manager.
|
<K,V> Cache<K,V> |
CacheContainer.getCache()
This method overrides the underlying
CacheContainer.getCache(),
to return a Cache instead of a BasicCache |
<K,V> Cache<K,V> |
AbstractDelegatingEmbeddedCacheManager.getCache() |
<K,V> Cache<K,V> |
DefaultCacheManager.getCache(String cacheName)
Retrieves a named cache from the system.
|
<K,V> Cache<K,V> |
CacheContainer.getCache(String cacheName)
This method overrides the underlying
CacheContainer.getCache(String),
to return a Cache instead of a BasicCache |
<K,V> Cache<K,V> |
AbstractDelegatingEmbeddedCacheManager.getCache(String cacheName) |
<K,V> Cache<K,V> |
DefaultCacheManager.getCache(String cacheName,
boolean createIfAbsent) |
<K,V> Cache<K,V> |
EmbeddedCacheManager.getCache(String cacheName,
boolean createIfAbsent)
Retrieves a named cache from the system in the same way that
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. |
<K,V> Cache<K,V> |
AbstractDelegatingEmbeddedCacheManager.getCache(String cacheName,
boolean createIfAbsent) |
| Modifier and Type | Method and Description |
|---|---|
void |
CacheMarshaller.inject(Cache cache,
Configuration cfg,
InvocationContextContainer icc,
ExternalizerTable extTable,
GlobalConfiguration globalCfg) |
void |
VersionAwareMarshaller.inject(Cache cache,
Configuration cfg,
InvocationContextContainer icc,
ExternalizerTable extTable,
GlobalConfiguration globalCfg) |
| Constructor and Description |
|---|
RemoteEventListener(Cache<Object,Object> cache,
StreamingMarshaller marshaller) |
| Modifier and Type | Method and Description |
|---|---|
Cache<K,V> |
EventImpl.getCache() |
Cache<K,V> |
Event.getCache() |
| Modifier and Type | Method and Description |
|---|---|
static <K,V> EventImpl<K,V> |
EventImpl.createEvent(Cache<K,V> cache,
Event.Type type) |
| Modifier and Type | Method and Description |
|---|---|
Cache |
InitializationContextImpl.getCache() |
| Constructor and Description |
|---|
InitializationContextImpl(StoreConfiguration configuration,
Cache cache,
StreamingMarshaller marshaller,
TimeService timeService,
ByteBufferFactory byteBufferFactory,
MarshalledEntryFactory mef) |
| Modifier and Type | Method and Description |
|---|---|
void |
CLInterfaceTargetMigrator.disconnectSource(Cache<Object,Object> cache) |
long |
CLInterfaceTargetMigrator.synchronizeData(Cache<Object,Object> cache) |
| Modifier and Type | Method and Description |
|---|---|
Cache |
InitialisationContextDelegate.getCache() |
| Modifier and Type | Method and Description |
|---|---|
void |
HotRodTargetMigrator.disconnectSource(Cache<Object,Object> cache) |
long |
HotRodTargetMigrator.synchronizeData(Cache<Object,Object> cache) |
| Modifier and Type | Method and Description |
|---|---|
void |
RestTargetMigrator.disconnectSource(Cache<Object,Object> cache) |
long |
RestTargetMigrator.synchronizeData(Cache<Object,Object> cache) |
| Modifier and Type | Method and Description |
|---|---|
Cache |
InitializationContext.getCache() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
SingletonCacheWriter.pushState(Cache cache)
Pushes the state of a specific cache by reading the cache's data and putting in the cache store.
|
| Modifier and Type | Method and Description |
|---|---|
static SearchManager |
Search.getSearchManager(Cache<?,?> cache) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
QueryInterceptor.injectDependencies(TransactionManager transactionManager,
TransactionSynchronizationRegistry transactionSynchronizationRegistry,
Cache cache,
ClusterRegistry<String,Class<?>,Boolean> clusterRegistry,
DataContainer dataContainer,
ExecutorService e) |
| Modifier and Type | Method and Description |
|---|---|
static ClusteredQueryCommand |
ClusteredQueryCommand.createEagerIterator(org.hibernate.search.query.engine.spi.HSQuery query,
Cache<?,?> cache) |
static ClusteredQueryCommand |
ClusteredQueryCommand.createLazyIterator(org.hibernate.search.query.engine.spi.HSQuery query,
Cache<?,?> cache,
UUID id) |
static ClusteredQueryCommand |
ClusteredQueryCommand.destroyLazyQuery(Cache<?,?> cache,
UUID id) |
ClusteredQueryCommandWorker |
ClusteredQueryCommandType.getCommand(Cache<?,?> cache,
org.hibernate.search.query.engine.spi.HSQuery query,
UUID lazyQueryId,
int docIndex) |
static ClusteredQueryCommand |
ClusteredQueryCommand.getResultSize(org.hibernate.search.query.engine.spi.HSQuery query,
Cache<?,?> cache) |
void |
ClusteredQueryCommand.initialize(Cache<?,?> localInstance) |
QueryResponse |
ClusteredQueryCommand.perform(Cache<?,?> cache) |
static ClusteredQueryCommand |
ClusteredQueryCommand.retrieveKeyFromLazyQuery(Cache<?,?> cache,
UUID id,
int docIndex) |
void |
ClusteredQueryCommand.setCache(Cache<?,?> cache) |
| Modifier and Type | Field and Description |
|---|---|
protected Cache<?,?> |
ClusteredQueryCommandWorker.cache |
| Modifier and Type | Method and Description |
|---|---|
static Object |
QueryExtractorUtil.extractKey(org.hibernate.search.query.engine.spi.DocumentExtractor extractor,
Cache<?,?> cache,
KeyTransformationHandler keyTransformationHandler,
int docIndex) |
void |
ClusteredQueryCommandWorker.init(Cache<?,?> cache,
org.hibernate.search.query.engine.spi.HSQuery query,
UUID lazyQueryId,
int docIndex) |
| Modifier and Type | Method and Description |
|---|---|
static <T> T |
ComponentRegistryUtils.getComponent(Cache<?,?> cache,
Class<T> class1) |
static <T> T |
ComponentRegistryUtils.getComponent(Cache<?,?> cache,
Class<T> class1,
String name) |
static QueryInterceptor |
ComponentRegistryUtils.getQueryInterceptor(Cache<?,?> cache) |
| Modifier and Type | Method and Description |
|---|---|
void |
IndexingMapper.initialize(Cache inputCache) |
void |
IndexingReducer.initialize(Cache<?,?> inputCache) |
<KIn,VIn,KOut,VOut> |
MapReduceInitializer.onPreExecute(Mapper<KIn,VIn,KOut,VOut> mapper,
Cache<KIn,VIn> inputCache) |
<KOut,VOut> |
MapReduceInitializer.onPreExecute(Reducer<KOut,VOut> reducer,
Cache<?,?> inputCache) |
| Modifier and Type | Method and Description |
|---|---|
void |
ProgrammaticSearchMappingProviderImpl.defineMappings(Cache cache,
org.hibernate.search.cfg.SearchMapping searchMapping) |
| Constructor and Description |
|---|
ProtobufValueWrapperFieldBridge(Cache cache) |
| Modifier and Type | Method and Description |
|---|---|
void |
ProgrammaticSearchMappingProvider.defineMappings(Cache cache,
org.hibernate.search.cfg.SearchMapping searchMapping) |
| Modifier and Type | Method and Description |
|---|---|
void |
ReplicationQueueImpl.injectDependencies(ScheduledExecutorService executor,
RpcManager rpcManager,
Configuration configuration,
CommandsFactory commandsFactory,
Cache cache) |
| Modifier and Type | Method and Description |
|---|---|
void |
RpcManagerImpl.injectDependencies(Transport t,
Cache cache,
Configuration cfg,
ReplicationQueue replicationQueue,
CommandsFactory cf,
ExecutorService e,
LocalTopologyManager localTopologyManager,
StateTransferManager stateTransferManager,
TimeService timeService) |
| Modifier and Type | Method and Description |
|---|---|
void |
ManagerInstance.tryRegisterMigrationManager(Cache<String,byte[]> cache) |
| Modifier and Type | Method and Description |
|---|---|
protected abstract Cache<K,V> |
AbstractProtocolDecoder.getCache() |
Cache<Object,Object> |
AbstractProtocolServer.startDefaultCache() |
| Modifier and Type | Method and Description |
|---|---|
protected EntryVersion |
AbstractProtocolDecoder.generateVersion(Cache<K,V> cache) |
| Modifier and Type | Method and Description |
|---|---|
Cache<Object,Object> |
ConnectionAdderTask.cache() |
| Modifier and Type | Method and Description |
|---|---|
void |
ConnectionAdderTask.setEnvironment(Cache<Object,Object> cache,
Set<Object> inputKeys) |
| Modifier and Type | Method and Description |
|---|---|
Cache<byte[],byte[]> |
HotRodDecoder.getCache() |
Cache<byte[],byte[]> |
HotRodServer.getCacheInstance(String cacheName,
EmbeddedCacheManager cacheManager,
boolean skipCacheCheck) |
Cache<Object,Object> |
HotRodServer.startDefaultCache() |
| Modifier and Type | Method and Description |
|---|---|
AbstractTopologyResponse |
AbstractEncoder1x.getTopologyResponse(Response r,
Cache<Address,ServerAddress> addressCache,
HotRodServer server) |
void |
HotRodServer.tryRegisterMigrationManager(String cacheName,
Cache<byte[],byte[]> cache) |
abstract void |
AbstractVersionedEncoder.writeHeader(Response r,
org.jboss.netty.buffer.ChannelBuffer buf,
Cache<Address,ServerAddress> addressCache,
HotRodServer server)
Write the header to the given channel buffer
|
void |
AbstractEncoder1x.writeHeader(Response r,
org.jboss.netty.buffer.ChannelBuffer buf,
Cache<Address,ServerAddress> addressCache,
HotRodServer server) |
| Constructor and Description |
|---|
CrashedMemberDetectorListener(Cache<Address,ServerAddress> cache,
HotRodServer server) |
HotRodSourceMigrator(Cache<byte[],byte[]> cache) |
RestSourceMigrator(Cache<String,byte[]> cache) |
| Modifier and Type | Method and Description |
|---|---|
static Set<byte[]> |
BulkUtil.getAllKeys(Cache<byte[],byte[]> cache,
int scope) |
| Modifier and Type | Method and Description |
|---|---|
Cache<String,byte[]> |
MemcachedDecoder.getCache() |
| Modifier and Type | Method and Description |
|---|---|
void |
OpHandler.handleOp(org.json.JSONObject opPayload,
Cache<Object,Object> cache,
org.jboss.netty.channel.ChannelHandlerContext ctx)
Handle a websocket channel operation.
|
static void |
ChannelUtils.pushCacheValue(String key,
Cache<Object,Object> cache,
org.jboss.netty.channel.ChannelHandlerContext ctx)
Push a cache entry value out onto the websocket channel (to the browser).
|
| Constructor and Description |
|---|
WebSocketServerHandler(CacheContainer cacheContainer,
Map<String,OpHandler> operationHandlers,
Map<String,Cache> startedCaches) |
| Modifier and Type | Method and Description |
|---|---|
void |
PutHandler.handleOp(org.json.JSONObject opPayload,
Cache<Object,Object> cache,
org.jboss.netty.channel.ChannelHandlerContext ctx) |
void |
RemoveHandler.handleOp(org.json.JSONObject opPayload,
Cache<Object,Object> cache,
org.jboss.netty.channel.ChannelHandlerContext ctx) |
void |
GetHandler.handleOp(org.json.JSONObject opPayload,
Cache<Object,Object> cache,
org.jboss.netty.channel.ChannelHandlerContext ctx) |
void |
NotifyHandler.handleOp(org.json.JSONObject opPayload,
Cache<Object,Object> cache,
org.jboss.netty.channel.ChannelHandlerContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
Cache<K,V> |
InfinispanDefaultCacheFactoryBean.getObject() |
| Modifier and Type | Method and Description |
|---|---|
Class<? extends Cache> |
InfinispanDefaultCacheFactoryBean.getObjectType() |
| Modifier and Type | Method and Description |
|---|---|
Cache<K,V> |
InfinispanNamedEmbeddedCacheFactoryBean.getObject() |
| Modifier and Type | Method and Description |
|---|---|
Class<? extends Cache> |
InfinispanNamedEmbeddedCacheFactoryBean.getObjectType() |
| Modifier and Type | Method and Description |
|---|---|
void |
StateProviderImpl.init(Cache cache,
ExecutorService executorService,
Configuration configuration,
RpcManager rpcManager,
CommandsFactory commandsFactory,
CacheNotifier cacheNotifier,
PersistenceManager persistenceManager,
DataContainer dataContainer,
TransactionTable transactionTable,
StateTransferLock stateTransferLock,
StateConsumer stateConsumer,
InternalEntryFactory entryFactory) |
void |
StateConsumerImpl.init(Cache cache,
ExecutorService executorService,
StateTransferManager stateTransferManager,
InterceptorChain interceptorChain,
InvocationContextFactory icf,
Configuration configuration,
RpcManager rpcManager,
TransactionManager transactionManager,
CommandsFactory commandsFactory,
PersistenceManager persistenceManager,
DataContainer dataContainer,
TransactionTable transactionTable,
StateTransferLock stateTransferLock,
CacheNotifier cacheNotifier,
TotalOrderManager totalOrderManager,
BlockingTaskAwareExecutorService remoteCommandsExecutor,
L1Manager l1Manager) |
void |
StateTransferManagerImpl.init(StateConsumer stateConsumer,
StateProvider stateProvider,
Cache cache,
CacheNotifier cacheNotifier,
Configuration configuration,
GlobalConfiguration globalConfiguration,
RpcManager rpcManager,
GroupManager groupManager,
LocalTopologyManager localTopologyManager) |
| Modifier and Type | Method and Description |
|---|---|
static StreamSummaryContainer |
StreamSummaryContainer.getOrCreateStreamLibContainer(Cache cache) |
| Modifier and Type | Method and Description |
|---|---|
static <K,V> Set<K> |
GlobalKeySetTask.getGlobalKeySet(Cache<K,V> cache) |
void |
GlobalKeySetTask.setEnvironment(Cache<K,V> cache,
Set<K> inputKeys) |
| Modifier and Type | Method and Description |
|---|---|
void |
TransactionTable.initialize(RpcManager rpcManager,
Configuration configuration,
InvocationContextFactory icf,
InterceptorChain invoker,
CacheNotifier notifier,
TransactionFactory gtf,
TransactionCoordinator txCoordinator,
TransactionSynchronizationRegistry transactionSynchronizationRegistry,
CommandsFactory commandsFactory,
ClusteringDependentLogic clusteringDependentLogic,
Cache cache,
TimeService timeService) |
| Modifier and Type | Method and Description |
|---|---|
void |
XaTransactionTable.init(RecoveryManager recoveryManager,
Cache cache) |
| Modifier and Type | Method and Description |
|---|---|
Cache<?,?> |
TreeCacheImpl.getCache() |
Cache<?,?> |
TreeCache.getCache() |
| Modifier and Type | Method and Description |
|---|---|
<K,V> TreeCache<K,V> |
TreeCacheFactory.createTreeCache(Cache<K,V> cache)
Creates a TreeCache instance by taking in a
Cache as a parameter |
| Constructor and Description |
|---|
TreeCacheImpl(Cache<?,?> cache) |
| Modifier and Type | Method and Description |
|---|---|
void |
TargetMigrator.disconnectSource(Cache<Object,Object> cache)
Disconnects the target from the source.
|
void |
RollingUpgradeManager.initialize(Cache<Object,Object> cache,
TimeService timeService) |
long |
TargetMigrator.synchronizeData(Cache<Object,Object> cache)
Performs the synchronization of data between source and target by retrieving the set of known keys and fetching each key in turn
|
| Modifier and Type | Field and Description |
|---|---|
protected Cache<K,V> |
AbstractCustomFailurePolicy.cache |
| Modifier and Type | Method and Description |
|---|---|
Cache |
BackupReceiverImpl.getCache() |
Cache |
BackupReceiver.getCache() |
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractCustomFailurePolicy.init(Cache cache) |
void |
CustomFailurePolicy.init(Cache<K,V> cache)
Invoked during the initialization phase.
|
void |
BackupSenderImpl.init(Cache cache,
Transport transport,
TransactionTable txTable,
GlobalConfiguration gc,
TimeService timeService) |
void |
XSiteAdminOperations.init(RpcManager rpcManager,
BackupSender backupSender,
Cache cache) |
| Constructor and Description |
|---|
BackupReceiverImpl(Cache cache) |
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.