Package | Description |
---|---|
org.infinispan |
This is the core of Infinispan, a distributed, transactional, highly scalable data grid
platform.
|
org.infinispan.commands |
Commands that operate on the cache, either locally or remotely.
|
org.infinispan.commands.remote |
Meta-commands that wrap other commands for remote execution.
|
org.infinispan.commands.write |
Commands that alter the state of the cache.
|
org.infinispan.container |
Data containers which store cache entries.
|
org.infinispan.distexec.mapreduce | |
org.infinispan.distribution |
Classes relating to the distributed cache mode.
|
org.infinispan.interceptors |
Infinispan is designed around a set of interceptors around a data container.
|
org.infinispan.interceptors.distribution | |
org.infinispan.interceptors.locking | |
org.infinispan.remoting.responses |
Abstractions of the different response types allowed during RPC.
|
Modifier and Type | Method and Description |
---|---|
DistributionManager |
AdvancedCache.getDistributionManager()
Retrieves a reference to the
DistributionManager if the cache is configured
to use Distribution. |
DistributionManager |
AbstractDelegatingAdvancedCache.getDistributionManager() |
DistributionManager |
CacheImpl.getDistributionManager() |
Modifier and Type | Method and Description |
---|---|
void |
CacheImpl.injectDependencies(EvictionManager evictionManager,
InvocationContextFactory invocationContextFactory,
InvocationContextContainer icc,
CommandsFactory commandsFactory,
InterceptorChain interceptorChain,
Configuration configuration,
CacheNotifier notifier,
ComponentRegistry componentRegistry,
TransactionManager transactionManager,
BatchContainer batchContainer,
RpcManager rpcManager,
DataContainer dataContainer,
StreamingMarshaller marshaller,
DistributionManager distributionManager,
EmbeddedCacheManager cacheManager,
ExecutorService asyncExecutor,
TransactionTable txTable,
RecoveryManager recoveryManager,
TransactionCoordinator txCoordinator,
LockManager lockManager,
GlobalConfiguration globalCfg) |
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 |
ClusteredGetCommand.initialize(InvocationContextFactory icf,
CommandsFactory commandsFactory,
InternalEntryFactory entryFactory,
InterceptorChain interceptorChain,
DistributionManager distributionManager,
TransactionTable txTable,
Equivalence keyEquivalence) |
Modifier and Type | Method and Description |
---|---|
void |
InvalidateL1Command.init(Configuration config,
DistributionManager dm,
CacheNotifier n,
DataContainer dc) |
Constructor and Description |
---|
InvalidateL1Command(Address writeOrigin,
boolean forRehash,
DataContainer dc,
Configuration config,
DistributionManager dm,
CacheNotifier notifier,
Set<Flag> flags,
Collection<Object> keys) |
InvalidateL1Command(boolean forRehash,
DataContainer dc,
Configuration config,
DistributionManager dm,
CacheNotifier notifier,
Set<Flag> flags,
Collection<Object> keys) |
InvalidateL1Command(boolean forRehash,
DataContainer dc,
Configuration config,
DistributionManager dm,
CacheNotifier notifier,
Set<Flag> flags,
Object... keys) |
Modifier and Type | Method and Description |
---|---|
void |
EntryFactoryImpl.injectDependencies(DataContainer dataContainer,
Configuration configuration,
CacheNotifier notifier,
DistributionManager distributionManager) |
Modifier and Type | Method and Description |
---|---|
protected <KIn> Set<KIn> |
MapReduceManagerImpl.filterLocalPrimaryOwner(Set<KIn> nodeLocalKeys,
DistributionManager dm) |
protected <T> Map<Address,? extends Collection<T>> |
MapReduceTask.mapKeysToNodes(DistributionManager dm,
Collection<T> keysToMap,
boolean useIntermediateCompositeKey) |
<T> Map<Address,List<T>> |
MapReduceManager.mapKeysToNodes(DistributionManager dm,
String taskId,
Collection<T> keysToMap,
boolean useIntermediateCompositeKey)
Maps Map/Reduce task intermediate or input keys to nodes on Infinispan cluster
|
<T> Map<Address,List<T>> |
MapReduceManagerImpl.mapKeysToNodes(DistributionManager dm,
String taskId,
Collection<T> keysToMap,
boolean useIntermediateCompositeKey) |
Modifier and Type | Class and Description |
---|---|
class |
DistributionManagerImpl
The default distribution manager implementation
|
Modifier and Type | Method and Description |
---|---|
void |
DistCacheWriterInterceptor.inject(DistributionManager dm,
Transport transport,
ClusteringDependentLogic cdl) |
protected void |
IsMarshallableInterceptor.injectMarshaller(StreamingMarshaller marshaller,
DistributionManager distManager) |
Modifier and Type | Field and Description |
---|---|
protected DistributionManager |
BaseDistributionInterceptor.dm |
Modifier and Type | Method and Description |
---|---|
void |
BaseDistributionInterceptor.injectDependencies(DistributionManager distributionManager,
ClusteringDependentLogic cdl,
RemoteValueRetrievedListener rvrl) |
Modifier and Type | Method and Description |
---|---|
void |
ClusteringDependentLogic.DistributionLogic.init(DistributionManager dm,
Configuration configuration,
RpcManager rpcManager,
StateTransferLock stateTransferLock) |
Modifier and Type | Method and Description |
---|---|
void |
DistributionResponseGenerator.inject(DistributionManager distributionManager) |
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.