java.lang.Object
- org.infinispan.stream.impl.ClusterStreamManagerImpl<Original,K>
- - org.infinispan.stream.impl.PartitionAwareClusterStreamManager<Original,K>

All Implemented Interfaces:

ClusterStreamManager<Original,K>
```
public class PartitionAwareClusterStreamManager<Original,K>
extends ClusterStreamManagerImpl<Original,K>
```
Cluster stream manager that also pays attention to partition status and properly closes iterators and throws exceptions when the availability mode changes.

Nested Class Summary
- Nested classes/interfaces inherited from interface org.infinispan.stream.impl.ClusterStreamManager
  ClusterStreamManager.RemoteIteratorPublisher<K>, ClusterStreamManager.ResultsCallback<R>

Field Summary

Fields
Modifier and Type	Field	Description
`protected Cache<?,?>`	`cache`
`protected Configuration`	`configuration`
`protected org.infinispan.stream.impl.PartitionAwareClusterStreamManager.PartitionListener`	`listener`

Fields inherited from class org.infinispan.stream.impl.ClusterStreamManagerImpl
currentlyRunning, factory, iteratorsRunning, localAddress, log, requestId, rpc, rpcOptions, trace

Constructor Summary

Constructors
Constructor Description

PartitionAwareClusterStreamManager()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`boolean`	`awaitCompletion(Object id, long time, TimeUnit unit)`	Awaits completion of the given request.
`<E> ClusterStreamManager.RemoteIteratorPublisher<E>`	`remoteIterationPublisher(boolean parallelStream, Supplier<Map.Entry<Address,org.infinispan.commons.util.IntSet>> targets, Set<K> keysToInclude, IntFunction<Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, Iterable<org.infinispan.stream.impl.intops.IntermediateOperation> intermediateOperations)`
`<R> Object`	`remoteStreamOperation(boolean parallelDistribution, boolean parallelStream, ConsistentHash ch, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Map<Integer,Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, KeyTrackingTerminalOperation<Original,K,R> operation, ClusterStreamManager.ResultsCallback<Collection<R>> callback)`	Key tracking remote operation that doesn't have rehash enabled.
`<R> Object`	`remoteStreamOperation(boolean parallelDistribution, boolean parallelStream, ConsistentHash ch, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Map<Integer,Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, TerminalOperation<Original,R> operation, ClusterStreamManager.ResultsCallback<R> callback, Predicate<? super R> earlyTerminatePredicate)`	Performs the remote stream operation without rehash awareness.
`Object`	`remoteStreamOperationRehashAware(boolean parallelDistribution, boolean parallelStream, ConsistentHash ch, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Map<Integer,Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, KeyTrackingTerminalOperation<Original,K,?> operation, ClusterStreamManager.ResultsCallback<Collection<K>> callback)`	Key tracking remote operation that has rehash enabled
`<R> Object`	`remoteStreamOperationRehashAware(boolean parallelDistribution, boolean parallelStream, ConsistentHash ch, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Map<Integer,Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, TerminalOperation<Original,R> operation, ClusterStreamManager.ResultsCallback<R> callback, Predicate<? super R> earlyTerminatePredicate)`	Performs the remote stream operation with rehash awareness.
`void`	`start()`

Methods inherited from class org.infinispan.stream.impl.ClusterStreamManagerImpl
forgetOperation, isComplete, markTrackerWithException, receiveResponse

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

listener

protected final org.infinispan.stream.impl.PartitionAwareClusterStreamManager.PartitionListener listener

cache
```
protected Cache<?,?> cache
```

configuration
```
protected Configuration configuration
```

Constructor Detail
- PartitionAwareClusterStreamManager
```
public PartitionAwareClusterStreamManager()
```

Method Detail

start
```
public void start()
```
Overrides:

start in class ClusterStreamManagerImpl<Original,K>

awaitCompletion
```
public boolean awaitCompletion(Object id,
                               long time,
                               TimeUnit unit)
                        throws InterruptedException
```
Description copied from interface: ClusterStreamManager

Awaits completion of the given request. Returns true when the request completes otherwise returns false after the time elapses

Specified by:

awaitCompletion in interface ClusterStreamManager<Original,K>

Overrides:

awaitCompletion in class ClusterStreamManagerImpl<Original,K>

Parameters:

id - the ide of the operation that was returned from the invocation - must be non null

time - how long to wait before returning false - must be greater than 0

unit - controls how long the time wait is

Returns:

whether or not the request is complete

Throws:

InterruptedException

remoteStreamOperation

public <R> Object remoteStreamOperation(boolean parallelDistribution,
                                        boolean parallelStream,
                                        ConsistentHash ch,
                                        org.infinispan.commons.util.IntSet segments,
                                        Set<K> keysToInclude,
                                        Map<Integer,Set<K>> keysToExclude,
                                        boolean includeLoader,
                                        boolean entryStream,
                                        TerminalOperation<Original,R> operation,
                                        ClusterStreamManager.ResultsCallback<R> callback,
                                        Predicate<? super R> earlyTerminatePredicate)

Description copied from interface: ClusterStreamManager

Performs the remote stream operation without rehash awareness.

Specified by:: remoteStreamOperation in interface ClusterStreamManager<Original,K>
Overrides:: remoteStreamOperation in class ClusterStreamManagerImpl<Original,K>
Type Parameters:: R - the type of response
Parameters:: parallelDistribution - whether or not parallel distribution is enabled; parallelStream - whether or not the stream is paralllel; ch - the consistent hash to use when determining segment ownership; segments - the segments that this request should utilize; keysToInclude - which keys to include in the request; keysToExclude - which keys to exclude in the request; includeLoader - whether or not to use a loader; entryStream - whether the remote stream should be an entry or key stream; operation - the actual operation to perform; callback - the callback to collect individual node results; earlyTerminatePredicate - a predicate to determine if this operation should stop based on intermediate results
Returns:: the operation id to be used for further calls

remoteStreamOperation

public <R> Object remoteStreamOperation(boolean parallelDistribution,
                                        boolean parallelStream,
                                        ConsistentHash ch,
                                        org.infinispan.commons.util.IntSet segments,
                                        Set<K> keysToInclude,
                                        Map<Integer,Set<K>> keysToExclude,
                                        boolean includeLoader,
                                        boolean entryStream,
                                        KeyTrackingTerminalOperation<Original,K,R> operation,
                                        ClusterStreamManager.ResultsCallback<Collection<R>> callback)

Description copied from interface: ClusterStreamManager

Key tracking remote operation that doesn't have rehash enabled.

Specified by:: remoteStreamOperation in interface ClusterStreamManager<Original,K>
Overrides:: remoteStreamOperation in class ClusterStreamManagerImpl<Original,K>
Type Parameters:: R - the type of response
Parameters:: parallelDistribution - whether or not parallel distribution is enabled; parallelStream - whether or not the stream is paralllel; ch - the consistent hash to use when determining segment ownership; segments - the segments that this request should utilize; keysToInclude - which keys to include in the request; keysToExclude - which keys to exclude in the request; includeLoader - whether or not to use a loader; entryStream - whether the remote stream should be an entry or key stream; operation - the actual operation to perform; callback - the callback to collect individual node results
Returns:: the operation id to be used for further calls

remoteStreamOperationRehashAware

public <R> Object remoteStreamOperationRehashAware(boolean parallelDistribution,
                                                   boolean parallelStream,
                                                   ConsistentHash ch,
                                                   org.infinispan.commons.util.IntSet segments,
                                                   Set<K> keysToInclude,
                                                   Map<Integer,Set<K>> keysToExclude,
                                                   boolean includeLoader,
                                                   boolean entryStream,
                                                   TerminalOperation<Original,R> operation,
                                                   ClusterStreamManager.ResultsCallback<R> callback,
                                                   Predicate<? super R> earlyTerminatePredicate)

Description copied from interface: ClusterStreamManager

Performs the remote stream operation with rehash awareness.

Specified by:: remoteStreamOperationRehashAware in interface ClusterStreamManager<Original,K>
Overrides:: remoteStreamOperationRehashAware in class ClusterStreamManagerImpl<Original,K>
Type Parameters:: R - the type of response
Parameters:: parallelDistribution - whether or not parallel distribution is enabled; parallelStream - whether or not the stream is paralllel; ch - the consistent hash to use when determining segment ownership; segments - the segments that this request should utilize; keysToInclude - which keys to include in the request; keysToExclude - which keys to exclude in the request; includeLoader - whether or not to use a loader; entryStream - whether the remote stream should be an entry or key stream; operation - the actual operation to perform; callback - the callback to collect individual node results; earlyTerminatePredicate - a predicate to determine if this operation should stop based on intermediate results
Returns:: the operation id to be used for further calls

remoteStreamOperationRehashAware

public Object remoteStreamOperationRehashAware(boolean parallelDistribution,
                                               boolean parallelStream,
                                               ConsistentHash ch,
                                               org.infinispan.commons.util.IntSet segments,
                                               Set<K> keysToInclude,
                                               Map<Integer,Set<K>> keysToExclude,
                                               boolean includeLoader,
                                               boolean entryStream,
                                               KeyTrackingTerminalOperation<Original,K,?> operation,
                                               ClusterStreamManager.ResultsCallback<Collection<K>> callback)

Description copied from interface: ClusterStreamManager

Key tracking remote operation that has rehash enabled

Specified by:: remoteStreamOperationRehashAware in interface ClusterStreamManager<Original,K>
Overrides:: remoteStreamOperationRehashAware in class ClusterStreamManagerImpl<Original,K>
Parameters:: parallelDistribution - whether or not parallel distribution is enabled; parallelStream - whether or not the stream is paralllel; ch - the consistent hash to use when determining segment ownership; segments - the segments that this request should utilize; keysToInclude - which keys to include in the request; keysToExclude - which keys to exclude in the request; includeLoader - whether or not to use a loader; entryStream - whether the remote stream should be an entry or key stream; operation - the actual operation to perform; callback - the callback to collect individual node results
Returns:: the operation id to be used for further calls

remoteIterationPublisher

public <E> ClusterStreamManager.RemoteIteratorPublisher<E> remoteIterationPublisher(boolean parallelStream,
                                                                                    Supplier<Map.Entry<Address,org.infinispan.commons.util.IntSet>> targets,
                                                                                    Set<K> keysToInclude,
                                                                                    IntFunction<Set<K>> keysToExclude,
                                                                                    boolean includeLoader,
                                                                                    boolean entryStream,
                                                                                    Iterable<org.infinispan.stream.impl.intops.IntermediateOperation> intermediateOperations)

Specified by:: remoteIterationPublisher in interface ClusterStreamManager<Original,K>
Overrides:: remoteIterationPublisher in class ClusterStreamManagerImpl<Original,K>; entryStream - whether the remote stream should be an entry or key stream
Returns:

Class PartitionAwareClusterStreamManager<Original,​K>

Nested Class Summary

Nested classes/interfaces inherited from interface org.infinispan.stream.impl.ClusterStreamManager

Field Summary

Fields inherited from class org.infinispan.stream.impl.ClusterStreamManagerImpl

Constructor Summary

Method Summary

Methods inherited from class org.infinispan.stream.impl.ClusterStreamManagerImpl

Methods inherited from class java.lang.Object

Field Detail

listener

cache

configuration

Constructor Detail

PartitionAwareClusterStreamManager

Method Detail

start

awaitCompletion

remoteStreamOperation

remoteStreamOperation

remoteStreamOperationRehashAware

remoteStreamOperationRehashAware

remoteIterationPublisher

Class PartitionAwareClusterStreamManager<Original,K>