Uses of Interface
org.infinispan.stream.impl.KeyTrackingTerminalOperation
-
-
Uses of KeyTrackingTerminalOperation in org.infinispan.stream.impl
Methods in org.infinispan.stream.impl with parameters of type KeyTrackingTerminalOperation Modifier and Type Method Description <R> Object
ClusterStreamManager. remoteStreamOperation(boolean parallelDistribution, boolean parallelStream, ConsistentHash ch, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Map<Integer,Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, KeyTrackingTerminalOperation<Original,K,R> operation, ClusterStreamManager.ResultsCallback<Collection<R>> callback)
Key tracking remote operation that doesn't have rehash enabled.<R> Object
ClusterStreamManagerImpl. remoteStreamOperation(boolean parallelDistribution, boolean parallelStream, ConsistentHash ch, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Map<Integer,Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, KeyTrackingTerminalOperation<Original,K,R> operation, ClusterStreamManager.ResultsCallback<Collection<R>> callback)
<R> Object
PartitionAwareClusterStreamManager. remoteStreamOperation(boolean parallelDistribution, boolean parallelStream, ConsistentHash ch, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Map<Integer,Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, KeyTrackingTerminalOperation<Original,K,R> operation, ClusterStreamManager.ResultsCallback<Collection<R>> callback)
Object
ClusterStreamManager. remoteStreamOperationRehashAware(boolean parallelDistribution, boolean parallelStream, ConsistentHash ch, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Map<Integer,Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, KeyTrackingTerminalOperation<Original,K,?> operation, ClusterStreamManager.ResultsCallback<Collection<K>> callback)
Key tracking remote operation that has rehash enabledObject
ClusterStreamManagerImpl. remoteStreamOperationRehashAware(boolean parallelDistribution, boolean parallelStream, ConsistentHash ch, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Map<Integer,Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, KeyTrackingTerminalOperation<Original,K,?> operation, ClusterStreamManager.ResultsCallback<Collection<K>> callback)
Object
PartitionAwareClusterStreamManager. remoteStreamOperationRehashAware(boolean parallelDistribution, boolean parallelStream, ConsistentHash ch, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Map<Integer,Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, KeyTrackingTerminalOperation<Original,K,?> operation, ClusterStreamManager.ResultsCallback<Collection<K>> callback)
<R> void
LocalStreamManager. streamOperation(Object requestId, Address origin, boolean parallelStream, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, boolean entryStream, KeyTrackingTerminalOperation<Original,K,R> operation)
Stream operation for a key aware operation without rehash enabled<R> void
LocalStreamManagerImpl. streamOperation(Object requestId, Address origin, boolean parallelStream, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, boolean entryStream, KeyTrackingTerminalOperation<Original,K,R> operation)
void
LocalStreamManager. streamOperationRehashAware(Object requestId, Address origin, boolean parallelStream, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, boolean entryStream, KeyTrackingTerminalOperation<Original,K,?> operation)
Stream operation for a key aware operation with rehash enabledvoid
LocalStreamManagerImpl. streamOperationRehashAware(Object requestId, Address origin, boolean parallelStream, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, boolean entryStream, KeyTrackingTerminalOperation<Original,K,?> operation)
-
Uses of KeyTrackingTerminalOperation in org.infinispan.stream.impl.termop
Classes in org.infinispan.stream.impl.termop that implement KeyTrackingTerminalOperation Modifier and Type Class Description class
AbstractForEachOperation<Original,K,V,S extends BaseStream<V,S>>
This is a base operation class for the use of the for each terminal operator. -
Uses of KeyTrackingTerminalOperation in org.infinispan.stream.impl.termop.object
Classes in org.infinispan.stream.impl.termop.object that implement KeyTrackingTerminalOperation Modifier and Type Class Description class
ForEachBiOperation<Original,K,V>
Terminal operation that handles for each where no map operations are definedclass
ForEachOperation<Original,K,V>
Terminal operation that handles for each where no map operations are defined -
Uses of KeyTrackingTerminalOperation in org.infinispan.stream.impl.termop.primitive
Classes in org.infinispan.stream.impl.termop.primitive that implement KeyTrackingTerminalOperation Modifier and Type Class Description class
AbstractForEachDoubleOperation<Original,K>
Terminal rehash aware operation that handles for each where no flat map operations are defined on aDoubleStream
.class
AbstractForEachIntOperation<Original,K>
Terminal rehash aware operation that handles for each where no flat map operations are defined on aIntStream
.class
AbstractForEachLongOperation<Original,K>
Terminal rehash aware operation that handles for each where no flat map operations are defined on aLongStream
.class
ForEachDoubleOperation<Original,K>
Terminal rehash aware operation that handles for each where no flat map operations are defined on aDoubleStream
.class
ForEachFlatMapDoubleOperation<Original,K>
Terminal rehash aware operation that handles for each where flat map operation is performed on aDoubleStream
.class
ForEachFlatMapIntOperation<Original,K>
Terminal rehash aware operation that handles for each where flat map operation is performed on aIntStream
.class
ForEachFlatMapLongOperation<Original,K>
Terminal rehash aware operation that handles for each where flat map operation is performed on aLongStream
.class
ForEachFlatMapObjDoubleOperation<Original,K>
Terminal rehash aware operation that handles for each where flat map operation is performed on aDoubleStream
.class
ForEachFlatMapObjIntOperation<Original,K>
Terminal rehash aware operation that handles for each where flat map operation is performed on aIntStream
.class
ForEachFlatMapObjLongOperation<Original,K>
Terminal rehash aware operation that handles for each where flat map operation is performed on aLongStream
.class
ForEachIntOperation<Original,K>
Terminal rehash aware operation that handles for each where no flat map operations are defined on aIntStream
.class
ForEachLongOperation<Original,K>
Terminal rehash aware operation that handles for each where no flat map operations are defined on aLongStream
.class
ForEachObjDoubleOperation<Original,K>
Terminal rehash aware operation that handles for each where no flat map operations are defined on aDoubleStream
.class
ForEachObjIntOperation<Original,K>
Terminal rehash aware operation that handles for each where no flat map operations are defined on aIntStream
.class
ForEachObjLongOperation<Original,K>
Terminal rehash aware operation that handles for each where no flat map operations are defined on aLongStream
. -
Uses of KeyTrackingTerminalOperation in org.infinispan.stream.impl.tx
Methods in org.infinispan.stream.impl.tx with parameters of type KeyTrackingTerminalOperation Modifier and Type Method Description <R> Object
TxClusterStreamManager. remoteStreamOperation(boolean parallelDistribution, boolean parallelStream, ConsistentHash ch, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Map<Integer,Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, KeyTrackingTerminalOperation<Original,K,R> operation, ClusterStreamManager.ResultsCallback<Collection<R>> callback)
Object
TxClusterStreamManager. remoteStreamOperationRehashAware(boolean parallelDistribution, boolean parallelStream, ConsistentHash ch, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Map<Integer,Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, KeyTrackingTerminalOperation<Original,K,?> operation, ClusterStreamManager.ResultsCallback<Collection<K>> callback)
-