K
- the key type for the operationspublic interface LocalStreamManager<K>
ClusterStreamManager
from
another node requiring some operation to be performedModifier and Type | Method and Description |
---|---|
<R> void |
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
|
<R> void |
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.
|
<R2> void |
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
|
<R> void |
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 streamOperation(Object requestId, Address origin, boolean parallelStream, Set<Integer> segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, TerminalOperation<R> operation)
R
- the type of value from the operationrequestId
- the originating request idorigin
- the node this request came fromparallelStream
- whether this stream is parallel or notsegments
- the segments to include in this operationkeysToInclude
- which keys to includekeysToExclude
- which keys to excludeincludeLoader
- whether or not a cache loader should be utilizedoperation
- the operation to perform<R> void streamOperationRehashAware(Object requestId, Address origin, boolean parallelStream, Set<Integer> segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, TerminalOperation<R> operation)
R
- the type of value from the operationrequestId
- the originating request idorigin
- the node this request came fromparallelStream
- whether this stream is parallel or notsegments
- the segments to include in this operationkeysToInclude
- which keys to includekeysToExclude
- which keys to excludeincludeLoader
- whether or not a cache loader should be utilizedoperation
- the operation to perform<R> void streamOperation(Object requestId, Address origin, boolean parallelStream, Set<Integer> segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, KeyTrackingTerminalOperation<K,R,?> operation)
R
- the type of value from the operationrequestId
- the originating request idorigin
- the node this request came fromparallelStream
- whether this stream is parallel or notsegments
- the segments to include in this operationkeysToInclude
- which keys to includekeysToExclude
- which keys to excludeincludeLoader
- whether or not a cache loader should be utilizedoperation
- the operation to perform<R2> void streamOperationRehashAware(Object requestId, Address origin, boolean parallelStream, Set<Integer> segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, KeyTrackingTerminalOperation<K,?,R2> operation)
R2
- the type of responserequestId
- the originating request idorigin
- the node this request came fromparallelStream
- whether this stream is parallel or notsegments
- the segments to include in this operationkeysToInclude
- which keys to includekeysToExclude
- which keys to excludeincludeLoader
- whether or not a cache loader should be utilizedoperation
- the operation to performCopyright © 2021 JBoss, a division of Red Hat. All rights reserved.