Uses of Interface
org.infinispan.stream.impl.ClusterStreamManager
-
Packages that use ClusterStreamManager Package Description org.infinispan.stream.impl org.infinispan.stream.impl.tx -
-
Uses of ClusterStreamManager in org.infinispan.stream.impl
Classes in org.infinispan.stream.impl that implement ClusterStreamManager Modifier and Type Class Description class
ClusterStreamManagerImpl<Original,K>
Cluster stream manager that sends all requests using theRpcManager
to do the underlying communications.class
PartitionAwareClusterStreamManager<Original,K>
Cluster stream manager that also pays attention to partition status and properly closes iterators and throws exceptions when the availability mode changes.Fields in org.infinispan.stream.impl declared as ClusterStreamManager Modifier and Type Field Description protected ClusterStreamManager
AbstractCacheStream. csm
protected ClusterStreamManager
StreamResponseCommand. csm
Methods in org.infinispan.stream.impl with parameters of type ClusterStreamManager Modifier and Type Method Description void
StreamResponseCommand. inject(ClusterStreamManager csm)
Constructors in org.infinispan.stream.impl with parameters of type ClusterStreamManager Constructor Description AbstractCacheStream(Address localAddress, boolean parallel, DistributionManager dm, Supplier<CacheStream<Original>> supplier, ClusterStreamManager<Original,Object> csm, boolean includeLoader, int distributedBatchSize, Executor executor, ComponentRegistry registry, Function<? super Original,?> toKeyFunction)
DistributedCacheStream(Address localAddress, boolean parallel, DistributionManager dm, Supplier<CacheStream<R>> supplier, ClusterStreamManager csm, boolean includeLoader, int distributedBatchSize, Executor executor, ComponentRegistry registry, Function<? super Original,?> toKeyFunction)
Standard constructor requiring all pertinent information to properly utilize a distributed cache stream -
Uses of ClusterStreamManager in org.infinispan.stream.impl.tx
Classes in org.infinispan.stream.impl.tx that implement ClusterStreamManager Modifier and Type Class Description class
TxClusterStreamManager<Original,K>
This is a delegating cluster stream manager that sends all calls to the underlying cluster stream manager.Constructors in org.infinispan.stream.impl.tx with parameters of type ClusterStreamManager Constructor Description TxClusterStreamManager(ClusterStreamManager<Original,K> manager, LocalTxInvocationContext ctx, int maxSegments, ToIntFunction<Object> intFunction)
-