Uses of Interface
org.infinispan.stream.impl.TerminalOperation
-
Packages that use TerminalOperation Package Description org.infinispan.stream.impl org.infinispan.stream.impl.termop org.infinispan.stream.impl.tx -
-
Uses of TerminalOperation in org.infinispan.stream.impl
Methods in org.infinispan.stream.impl with parameters of type TerminalOperation 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, TerminalOperation<Original,R> operation, ClusterStreamManager.ResultsCallback<R> callback, Predicate<? super R> earlyTerminatePredicate)
Performs the remote stream operation without rehash awareness.<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, TerminalOperation<Original,R> operation, ClusterStreamManager.ResultsCallback<R> callback, Predicate<? super R> earlyTerminatePredicate)
<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, TerminalOperation<Original,R> operation, ClusterStreamManager.ResultsCallback<R> callback, Predicate<? super R> earlyTerminatePredicate)
<R> 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, TerminalOperation<Original,R> operation, ClusterStreamManager.ResultsCallback<R> callback, Predicate<? super R> earlyTerminatePredicate)
Performs the remote stream operation with rehash awareness.<R> Object
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, TerminalOperation<Original,R> operation, ClusterStreamManager.ResultsCallback<R> callback, Predicate<? super R> earlyTerminatePredicate)
<R> 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, TerminalOperation<Original,R> operation, ClusterStreamManager.ResultsCallback<R> callback, Predicate<? super R> earlyTerminatePredicate)
<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, TerminalOperation<Original,R> operation)
Stream operation for a non 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, TerminalOperation<Original,R> operation)
<R> 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, TerminalOperation<Original,R> operation)
Stream operation for a non key aware operation with rehash enabled.<R> void
LocalStreamManagerImpl. streamOperationRehashAware(Object requestId, Address origin, boolean parallelStream, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, boolean entryStream, TerminalOperation<Original,R> operation)
-
Uses of TerminalOperation in org.infinispan.stream.impl.termop
Classes in org.infinispan.stream.impl.termop that implement TerminalOperation Modifier and Type Class Description class
SegmentRetryingOperation<Original,E,T,S extends BaseStream<T,S>,S2 extends S>
A terminal based operation that runs the provided function to evaluate the operation.class
SingleRunOperation<Original,E,R,S extends BaseStream<R,S>,S2 extends S>
Runs the provided function once only and returns the result. -
Uses of TerminalOperation in org.infinispan.stream.impl.tx
Methods in org.infinispan.stream.impl.tx with parameters of type TerminalOperation 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, TerminalOperation<Original,R> operation, ClusterStreamManager.ResultsCallback<R> callback, Predicate<? super R> earlyTerminatePredicate)
<R> 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, TerminalOperation<Original,R> operation, ClusterStreamManager.ResultsCallback<R> callback, Predicate<? super R> earlyTerminatePredicate)
-