Class 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.
    • Constructor Detail

      • DistributionBulkInterceptor

        public DistributionBulkInterceptor()
    • Method Detail

      • visitEntrySetCommand

        public java.lang.Object visitEntrySetCommand​(InvocationContext ctx,
                                                     org.infinispan.commands.read.EntrySetCommand command)
                                              throws java.lang.Throwable
        Specified by:
        visitEntrySetCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitEntrySetCommand in class DDAsyncInterceptor
        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 interface org.infinispan.commands.Visitor
        Overrides:
        visitKeySetCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable