org.infinispan.stream.impl

Class LocalStreamManagerImpl<K,V>

java.lang.Object

org.infinispan.stream.impl.LocalStreamManagerImpl<K,V>

Type Parameters:

K - key type of underlying cache

V - value type of underlying cache

All Implemented Interfaces:

LocalStreamManager<K>

public class LocalStreamManagerImpl<K,V>
extends Object
implements LocalStreamManager<K>

Local stream manager implementation that handles injection of the stream supplier, invoking the operation and subsequently notifying the operation if a rehash has changed one of its segments.

Constructor Summary

Constructors

Constructor and Description
LocalStreamManagerImpl()

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LocalStreamManagerImpl

public LocalStreamManagerImpl()

Method Detail

inject

public void inject(Cache<K,V> cache,
                   ComponentRegistry registry,
                   StateTransferManager stm,
                   RpcManager rpc,
                   Configuration configuration,
                   CommandsFactory factory)

start

public void start()

dataRehashed

public 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. If a rehash occurs causing this node to lose a segment and there is something iterating over the stream looking for values of that segment, we can't guarantee that the data has all been seen correctly, so we must therefore suspect that node by sending it back to the owner.

Parameters:

event - The data rehash event

streamOperation

public <R> void streamOperation(Object requestId,
                                Address origin,
                                boolean parallelStream,
                                Set<Integer> segments,
                                Set<K> keysToInclude,
                                Set<K> keysToExclude,
                                boolean includeLoader,
                                TerminalOperation<R> operation)

Description copied from interface: LocalStreamManager

Stream operation for a non key aware operation without rehash enabled.

Specified by:

streamOperation in interface LocalStreamManager<K>

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

public <R> void streamOperationRehashAware(Object requestId,
                                           Address origin,
                                           boolean parallelStream,
                                           Set<Integer> segments,
                                           Set<K> keysToInclude,
                                           Set<K> keysToExclude,
                                           boolean includeLoader,
                                           TerminalOperation<R> operation)

Description copied from interface: LocalStreamManager

Stream operation for a non key aware operation with rehash enabled.

Specified by:

streamOperationRehashAware in interface LocalStreamManager<K>

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

public <R> void streamOperation(Object requestId,
                                Address origin,
                                boolean parallelStream,
                                Set<Integer> segments,
                                Set<K> keysToInclude,
                                Set<K> keysToExclude,
                                boolean includeLoader,
                                KeyTrackingTerminalOperation<K,R,?> operation)

Description copied from interface: LocalStreamManager

Stream operation for a key aware operation without rehash enabled

Specified by:

streamOperation in interface LocalStreamManager<K>

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

public <R2> void streamOperationRehashAware(Object requestId,
                                            Address origin,
                                            boolean parallelStream,
                                            Set<Integer> segments,
                                            Set<K> keysToInclude,
                                            Set<K> keysToExclude,
                                            boolean includeLoader,
                                            KeyTrackingTerminalOperation<K,?,R2> operation)

Description copied from interface: LocalStreamManager

Stream operation for a key aware operation with rehash enabled

Specified by:

streamOperationRehashAware in interface LocalStreamManager<K>

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