K
- key type of underlying cacheV
- value type of underlying cachepublic class LocalStreamManagerImpl<K,V> extends Object implements LocalStreamManager<K>
Constructor and Description |
---|
LocalStreamManagerImpl() |
Modifier and Type | Method and Description |
---|---|
void |
dataRehashed(DataRehashedEvent<K,V> event)
We need to listen to data rehash events in case if data moves while we are iterating over it.
|
void |
inject(Cache<K,V> cache,
ComponentRegistry registry,
StateTransferManager stm,
RpcManager rpc,
Configuration configuration,
CommandsFactory factory) |
void |
start() |
<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.
|
public void inject(Cache<K,V> cache, ComponentRegistry registry, StateTransferManager stm, RpcManager rpc, Configuration configuration, CommandsFactory factory)
public void start()
public void dataRehashed(DataRehashedEvent<K,V> event)
event
- The data rehash eventpublic <R> void streamOperation(Object requestId, Address origin, boolean parallelStream, Set<Integer> segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, TerminalOperation<R> operation)
LocalStreamManager
streamOperation
in interface LocalStreamManager<K>
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 performpublic <R> void streamOperationRehashAware(Object requestId, Address origin, boolean parallelStream, Set<Integer> segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, TerminalOperation<R> operation)
LocalStreamManager
streamOperationRehashAware
in interface LocalStreamManager<K>
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 performpublic <R> void streamOperation(Object requestId, Address origin, boolean parallelStream, Set<Integer> segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, KeyTrackingTerminalOperation<K,R,?> operation)
LocalStreamManager
streamOperation
in interface LocalStreamManager<K>
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 performpublic <R2> void streamOperationRehashAware(Object requestId, Address origin, boolean parallelStream, Set<Integer> segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, KeyTrackingTerminalOperation<K,?,R2> operation)
LocalStreamManager
streamOperationRehashAware
in interface LocalStreamManager<K>
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 © 2020 JBoss, a division of Red Hat. All rights reserved.