Modifier and Type | Method and Description |
---|---|
<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,
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) |
<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) |
<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) |
<R> void |
LocalStreamManagerImpl.streamOperation(Object requestId,
Address origin,
boolean parallelStream,
Set<Integer> segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
KeyTrackingTerminalOperation<K,R,?> operation) |
<R> void |
LocalStreamManager.streamOperation(Object requestId,
Address origin,
boolean parallelStream,
Set<Integer> segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
KeyTrackingTerminalOperation<K,R,?> operation)
Stream operation for a key aware operation without rehash enabled
|
<R2> void |
LocalStreamManagerImpl.streamOperationRehashAware(Object requestId,
Address origin,
boolean parallelStream,
Set<Integer> segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
KeyTrackingTerminalOperation<K,?,R2> operation) |
<R2> void |
LocalStreamManager.streamOperationRehashAware(Object requestId,
Address origin,
boolean parallelStream,
Set<Integer> segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
KeyTrackingTerminalOperation<K,?,R2> operation)
Stream operation for a key aware operation with rehash enabled
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractForEachOperation<K,V,S extends BaseStream<V,S>>
This is a base operation class for the use of the for each terminal operator.
|
Modifier and Type | Class and Description |
---|---|
class |
FlatMapIteratorOperation<K,V>
Terminal rehash aware operation that handles an iterator when a flat map intermediate operation was performed on
the stream.
|
class |
ForEachOperation<K,V>
Terminal operation that handles for each where no map operations are defined
|
class |
MapIteratorOperation<K,V,V2>
Terminal rehash aware operation that handles an iterator when a map intermediate operation was performed on
the stream.
|
class |
NoMapIteratorOperation<K,V>
Terminal rehash aware operation that handles an iterator when no flat map or map intermediate operation was performed
on the stream.
|
Modifier and Type | Class and Description |
---|---|
class |
ForEachDoubleOperation<K>
Terminal rehash aware operation that handles for each where no flat map operations are defined on a
DoubleStream . |
class |
ForEachFlatMapDoubleOperation<K>
Terminal rehash aware operation that handles for each where flat map operation is performed on a
DoubleStream . |
class |
ForEachFlatMapIntOperation<K>
Terminal rehash aware operation that handles for each where flat map operation is performed on a
IntStream . |
class |
ForEachFlatMapLongOperation<K>
Terminal rehash aware operation that handles for each where flat map operation is performed on a
LongStream . |
class |
ForEachIntOperation<K>
Terminal rehash aware operation that handles for each where no flat map operations are defined on a
IntStream . |
class |
ForEachLongOperation<K>
Terminal rehash aware operation that handles for each where no flat map operations are defined on a
LongStream . |
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) |
<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) |
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.