Package org.infinispan.interceptors.distribution

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 entries

V - 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

Modifier and Type	Method	Description
Object	visitEntrySetCommand(InvocationContext ctx, org.infinispan.commands.read.EntrySetCommand command)
Object	visitKeySetCommand(InvocationContext ctx, org.infinispan.commands.read.KeySetCommand command)

Methods inherited from class org.infinispan.interceptors.DDAsyncInterceptor

handleDefault, visitClearCommand, visitCommand, visitCommitCommand, visitComputeCommand, visitComputeIfAbsentCommand, visitDistributedExecuteCommand, 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, delayedValue, delayedValue, invokeNext, invokeNextAndExceptionally, invokeNextAndFinally, invokeNextAndHandle, invokeNextThenAccept, invokeNextThenApply, isSuccessfullyDone, makeStage, setNextInterceptor, valueOrException

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.infinispan.commands.Visitor

visitApplyDeltaCommand, visitRemoveExpiredCommand

Constructor Detail

DistributionBulkInterceptor

public DistributionBulkInterceptor()

Method Detail

visitEntrySetCommand

public Object visitEntrySetCommand(InvocationContext ctx,
                                   org.infinispan.commands.read.EntrySetCommand command)
                            throws Throwable

Specified by:

visitEntrySetCommand in interface org.infinispan.commands.Visitor

Overrides:

visitEntrySetCommand in class DDAsyncInterceptor

Throws:

Throwable

visitKeySetCommand

public Object visitKeySetCommand(InvocationContext ctx,
                                 org.infinispan.commands.read.KeySetCommand command)
                          throws Throwable

Specified by:

visitKeySetCommand in interface org.infinispan.commands.Visitor

Overrides:

visitKeySetCommand in class DDAsyncInterceptor

Throws:

Throwable