org.infinispan.stream.impl

Interface LocalStreamManager<K>

Type Parameters:

K - the key type for the operations

All Known Implementing Classes:

LocalStreamManagerImpl

public interface LocalStreamManager<K>

Stream manager that is invoked on a local node. This is normally called due to a ClusterStreamManager from another node requiring some operation to be performed

Method Summary

Modifier 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.

Method Detail

streamOperation

<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.

Type Parameters:

R - the type of value from the operation

Parameters:

requestId - the originating request id

origin - the node this request came from

parallelStream - whether this stream is parallel or not

segments - the segments to include in this operation

keysToInclude - which keys to include

keysToExclude - which keys to exclude

includeLoader - whether or not a cache loader should be utilized

operation - the operation to perform

streamOperationRehashAware

<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.

Type Parameters:

R - the type of value from the operation

Parameters:

requestId - the originating request id

origin - the node this request came from

parallelStream - whether this stream is parallel or not

segments - the segments to include in this operation

keysToInclude - which keys to include

keysToExclude - which keys to exclude

includeLoader - whether or not a cache loader should be utilized

operation - the operation to perform

streamOperation

<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

Type Parameters:

R - the type of value from the operation

Parameters:

requestId - the originating request id

origin - the node this request came from

parallelStream - whether this stream is parallel or not

segments - the segments to include in this operation

keysToInclude - which keys to include

keysToExclude - which keys to exclude

includeLoader - whether or not a cache loader should be utilized

operation - the operation to perform

streamOperationRehashAware

<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

Type Parameters:

R2 - the type of response

Parameters:

requestId - the originating request id

origin - the node this request came from

parallelStream - whether this stream is parallel or not

segments - the segments to include in this operation

keysToInclude - which keys to include

keysToExclude - which keys to exclude

includeLoader - whether or not a cache loader should be utilized

operation - the operation to perform