Package | Description |
---|---|
org.infinispan.stream.impl | |
org.infinispan.stream.impl.termop | |
org.infinispan.stream.impl.tx |
Modifier and Type | Method and Description |
---|---|
<R> Object |
PartitionAwareClusterStreamManager.remoteStreamOperation(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
TerminalOperation<R> operation,
ClusterStreamManager.ResultsCallback<R> callback,
Predicate<? super R> earlyTerminatePredicate) |
<R> Object |
ClusterStreamManager.remoteStreamOperation(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
TerminalOperation<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,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
TerminalOperation<R> operation,
ClusterStreamManager.ResultsCallback<R> callback,
Predicate<? super R> earlyTerminatePredicate) |
<R> Object |
PartitionAwareClusterStreamManager.remoteStreamOperationRehashAware(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
TerminalOperation<R> operation,
ClusterStreamManager.ResultsCallback<R> callback,
Predicate<? super R> earlyTerminatePredicate) |
<R> Object |
ClusterStreamManager.remoteStreamOperationRehashAware(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
TerminalOperation<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,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
TerminalOperation<R> operation,
ClusterStreamManager.ResultsCallback<R> callback,
Predicate<? super R> earlyTerminatePredicate) |
<R> void |
LocalStreamManager.streamOperation(Object requestId,
Address origin,
boolean parallelStream,
Set<Integer> segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
TerminalOperation<R> operation)
Stream operation for a non key aware operation without rehash enabled.
|
<R> void |
LocalStreamManagerImpl.streamOperation(Object requestId,
Address origin,
boolean parallelStream,
Set<Integer> segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
TerminalOperation<R> operation) |
<R> void |
LocalStreamManager.streamOperationRehashAware(Object requestId,
Address origin,
boolean parallelStream,
Set<Integer> segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
TerminalOperation<R> operation)
Stream operation for a non key aware operation with rehash enabled.
|
<R> void |
LocalStreamManagerImpl.streamOperationRehashAware(Object requestId,
Address origin,
boolean parallelStream,
Set<Integer> segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
TerminalOperation<R> operation) |
Modifier and Type | Class and Description |
---|---|
class |
SegmentRetryingOperation<E,T,S extends BaseStream<T,S>>
A terminal based operation that runs the provided function to evaluate the operation.
|
class |
SingleRunOperation<E,R,S extends BaseStream<R,S>>
Runs the provided function once only and returns the result.
|
Modifier and Type | Method and Description |
---|---|
<R> Object |
TxClusterStreamManager.remoteStreamOperation(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
TerminalOperation<R> operation,
ClusterStreamManager.ResultsCallback<R> callback,
Predicate<? super R> earlyTerminatePredicate) |
<R> Object |
TxClusterStreamManager.remoteStreamOperationRehashAware(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
TerminalOperation<R> operation,
ClusterStreamManager.ResultsCallback<R> callback,
Predicate<? super R> earlyTerminatePredicate) |
Copyright © 2017 JBoss, a division of Red Hat. All rights reserved.