org.infinispan.interceptors.distribution.WriteManyCommandHelper<C, Container, Item>

public abstract class WriteManyCommandHelper<C extends WriteCommand, Container, Item> extends Object

Field Details
- remoteCallback
  
  protected final InvocationSuccessFunction<C extends WriteCommand> remoteCallback
Constructor Details
- WriteManyCommandHelper
  
  protected WriteManyCommandHelper(Function<WriteManyCommandHelper<C,?,?>, InvocationSuccessFunction<C>> createRemoteCallback)
Method Details
- getRemoteCallback
  
  public InvocationSuccessFunction<C> getRemoteCallback()
- copyForLocal
  
  public abstract C copyForLocal(C cmd, Container container)
- copyForPrimary
  
  public abstract C copyForPrimary(C cmd, LocalizedCacheTopology topology, org.infinispan.commons.util.IntSet segments)
- copyForBackup
  
  public abstract C copyForBackup(C cmd, LocalizedCacheTopology topology, Address target, org.infinispan.commons.util.IntSet segments)
- getItems
  
  public abstract Collection<Item> getItems(C cmd)
- item2key
  
  public abstract Object item2key(Item item)
- newContainer
  
  public abstract Container newContainer()
- accumulate
  
  public abstract void accumulate(Container container, Item item)
- containerSize
  
  public abstract int containerSize(Container container)
- toKeys
  
  public abstract Iterable<Object> toKeys(Container container)
- shouldRegisterRemoteCallback
  
  public abstract boolean shouldRegisterRemoteCallback(C cmd)
- transformResult
  
  public abstract Object transformResult(Object[] results)

Class WriteManyCommandHelper<C extends WriteCommand, Container, Item>

Field Summary