Package | Description |
---|---|
org.infinispan.stream.impl | |
org.infinispan.stream.impl.tx |
Modifier and Type | Method and Description |
---|---|
<R> Object |
ClusterStreamManager.remoteStreamOperation(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
KeyTrackingTerminalOperation<K,R,?> operation,
ClusterStreamManager.ResultsCallback<Collection<R>> callback)
Key tracking remote operation that doesn't have rehash enabled.
|
<R> Object |
PartitionAwareClusterStreamManager.remoteStreamOperation(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
KeyTrackingTerminalOperation<K,R,?> operation,
ClusterStreamManager.ResultsCallback<Collection<R>> callback) |
<R> Object |
ClusterStreamManagerImpl.remoteStreamOperation(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
KeyTrackingTerminalOperation<K,R,?> operation,
ClusterStreamManager.ResultsCallback<Collection<R>> callback) |
<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 |
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 |
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) |
<R2> Object |
ClusterStreamManager.remoteStreamOperationRehashAware(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
KeyTrackingTerminalOperation<K,?,R2> operation,
ClusterStreamManager.ResultsCallback<Map<K,R2>> callback)
Key tracking remote operation that has rehash enabled
|
<R2> Object |
PartitionAwareClusterStreamManager.remoteStreamOperationRehashAware(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
KeyTrackingTerminalOperation<K,?,R2> operation,
ClusterStreamManager.ResultsCallback<Map<K,R2>> callback) |
<R2> Object |
ClusterStreamManagerImpl.remoteStreamOperationRehashAware(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
KeyTrackingTerminalOperation<K,?,R2> operation,
ClusterStreamManager.ResultsCallback<Map<K,R2>> callback) |
<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 |
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 |
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) |
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,
KeyTrackingTerminalOperation<K,R,?> operation,
ClusterStreamManager.ResultsCallback<Collection<R>> callback) |
<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) |
<R2> Object |
TxClusterStreamManager.remoteStreamOperationRehashAware(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
KeyTrackingTerminalOperation<K,?,R2> operation,
ClusterStreamManager.ResultsCallback<Map<K,R2>> callback) |
<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 © 2018 JBoss, a division of Red Hat. All rights reserved.