Class DistributionBulkInterceptor<K,V>
- java.lang.Object
-
- org.infinispan.interceptors.BaseAsyncInterceptor
-
- org.infinispan.interceptors.DDAsyncInterceptor
-
- org.infinispan.interceptors.distribution.DistributionBulkInterceptor<K,V>
-
- Type Parameters:
K
- The key type of entriesV
- The value type of entries
- All Implemented Interfaces:
org.infinispan.commands.Visitor
,AsyncInterceptor
public class DistributionBulkInterceptor<K,V> extends DDAsyncInterceptor
Interceptor that handles bulk entrySet and keySet commands when using in a distributed/replicated environment. This interceptor produces backing collections for either method and a distributed stream for either which leverages distributed processing through the cluster.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description protected static class
DistributionBulkInterceptor.BackingEntrySet<K,V>
protected static class
DistributionBulkInterceptor.BackingKeySet<K,V>
protected static class
DistributionBulkInterceptor.TxBackingEntrySet<K,V>
-
Field Summary
-
Fields inherited from class org.infinispan.interceptors.BaseAsyncInterceptor
cacheConfiguration
-
-
Constructor Summary
Constructors Constructor Description DistributionBulkInterceptor()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.Object
visitEntrySetCommand(InvocationContext ctx, org.infinispan.commands.read.EntrySetCommand command)
java.lang.Object
visitKeySetCommand(InvocationContext ctx, org.infinispan.commands.read.KeySetCommand command)
-
Methods inherited from class org.infinispan.interceptors.DDAsyncInterceptor
handleDefault, visitClearCommand, visitCommand, visitCommitCommand, visitComputeCommand, visitComputeIfAbsentCommand, visitEvictCommand, visitGetAllCommand, visitGetCacheEntryCommand, visitGetKeysInGroupCommand, visitGetKeyValueCommand, visitInvalidateCommand, visitInvalidateL1Command, visitLockControlCommand, visitPrepareCommand, visitPutKeyValueCommand, visitPutMapCommand, visitReadOnlyKeyCommand, visitReadOnlyManyCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitRemoveCommand, visitReplaceCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand
-
Methods inherited from class org.infinispan.interceptors.BaseAsyncInterceptor
asyncInvokeNext, asyncInvokeNext, asyncInvokeNext, asyncValue, delayedNull, delayedValue, delayedValue, invokeNext, invokeNextAndExceptionally, invokeNextAndFinally, invokeNextAndHandle, invokeNextThenAccept, invokeNextThenApply, isSuccessfullyDone, makeStage, setNextInterceptor, valueOrException
-
-
-
-
Method Detail
-
visitEntrySetCommand
public java.lang.Object visitEntrySetCommand(InvocationContext ctx, org.infinispan.commands.read.EntrySetCommand command) throws java.lang.Throwable
- Specified by:
visitEntrySetCommand
in interfaceorg.infinispan.commands.Visitor
- Overrides:
visitEntrySetCommand
in classDDAsyncInterceptor
- Throws:
java.lang.Throwable
-
visitKeySetCommand
public java.lang.Object visitKeySetCommand(InvocationContext ctx, org.infinispan.commands.read.KeySetCommand command) throws java.lang.Throwable
- Specified by:
visitKeySetCommand
in interfaceorg.infinispan.commands.Visitor
- Overrides:
visitKeySetCommand
in classDDAsyncInterceptor
- Throws:
java.lang.Throwable
-
-