org.infinispan.stream.impl.tx

Class TxDistributedCacheStream<R>

java.lang.Object

org.infinispan.stream.impl.AbstractCacheStream<R,Stream<R>,Consumer<? super R>>

org.infinispan.stream.impl.DistributedCacheStream<R>

org.infinispan.stream.impl.tx.TxDistributedCacheStream<R>

Type Parameters:

R - the type of stream

All Implemented Interfaces:

AutoCloseable, BaseStream<R,Stream<R>>, Stream<R>, CacheStream<R>

public class TxDistributedCacheStream<R>
extends DistributedCacheStream<R>

A distributed cache stream that also utilizes transactional awareness. Basically this adds functionality to take items from the local tx context and add them to the local stream that is produced to enable our stream to operate upon entries in the context that don't map to our segments that are normally ignored in a distributed stream.

Nested Class Summary

Nested classes/interfaces inherited from interface org.infinispan.CacheStream

CacheStream.SegmentCompletionListener

Nested classes/interfaces inherited from interface java.util.stream.Stream

Stream.Builder<T>

Field Summary

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

closeRunnable, csm, distinct, distributedBatchSize, dm, executor, includeLoader, intermediateOperations, intermediateType, iteratorOperation, keyEquivalence, keysToFilter, localIntermediateOperations, log, parallel, parallelDistribution, partition, registry, rehashAware, segmentCompletionListener, segmentsToFilter, sorted, supplier, timeout, timeoutUnit

Constructor Summary

Constructors

Constructor and Description
TxDistributedCacheStream(Address localAddress, boolean parallel, DistributionManager dm, Supplier<CacheStream<CacheEntry<K,V>>> supplier, TxClusterStreamManager<?> csm, boolean includeLoader, int distributedBatchSize, Executor executor, ComponentRegistry registry, Function<? super CacheEntry<K,V>,R> function, LocalTxInvocationContext ctx)
TxDistributedCacheStream(Address localAddress, boolean parallel, DistributionManager dm, Supplier<CacheStream<CacheEntry<K,V>>> supplier, TxClusterStreamManager<?> csm, boolean includeLoader, int distributedBatchSize, Executor executor, ComponentRegistry registry, LocalTxInvocationContext ctx)

Method Summary

Modifier and Type	Method and Description
protected DistributedDoubleCacheStream	doubleCacheStream()
protected DistributedIntCacheStream	intCacheStream()
protected DistributedLongCacheStream	longCacheStream()
protected Supplier<Stream<CacheEntry>>	supplierForSegments(ConsistentHash ch, Set<Integer> targetSegments, Set<Object> excludedKeys, boolean primaryOnly) If usePrimary is true the segments are the primary segments but only those that exist in targetSegments.

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

allMatch, anyMatch, collect, collect, composeWithExceptions, count, disableRehashAware, distinct, distributedBatchSize, filter, filterKeys, filterKeySegments, findAny, findFirst, flatMap, flatMapToDouble, flatMapToInt, flatMapToLong, forEach, forEachOrdered, iterator, limit, map, mapToDouble, mapToInt, mapToLong, max, min, noneMatch, parallelDistribution, peek, reduce, reduce, reduce, segmentCompletionListener, sequentialDistribution, skip, sorted, sorted, spliterator, supplierStreamCast, timeout, toArray, toArray, unwrap

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

addIntermediateOperation, addIntermediateOperationMap, addIntermediateOperationMap, close, isParallel, markDistinct, markSkip, markSorted, onClose, parallel, sequential, supplierForSegments, unordered

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.stream.Stream

builder, concat, empty, generate, iterate, of, of

Methods inherited from interface java.util.stream.BaseStream

close, isParallel, onClose, parallel, sequential, unordered

Constructor Detail

TxDistributedCacheStream

public TxDistributedCacheStream(Address localAddress,
                                boolean parallel,
                                DistributionManager dm,
                                Supplier<CacheStream<CacheEntry<K,V>>> supplier,
                                TxClusterStreamManager<?> csm,
                                boolean includeLoader,
                                int distributedBatchSize,
                                Executor executor,
                                ComponentRegistry registry,
                                LocalTxInvocationContext ctx)

TxDistributedCacheStream

public TxDistributedCacheStream(Address localAddress,
                                boolean parallel,
                                DistributionManager dm,
                                Supplier<CacheStream<CacheEntry<K,V>>> supplier,
                                TxClusterStreamManager<?> csm,
                                boolean includeLoader,
                                int distributedBatchSize,
                                Executor executor,
                                ComponentRegistry registry,
                                Function<? super CacheEntry<K,V>,R> function,
                                LocalTxInvocationContext ctx)

Method Detail

supplierForSegments

protected Supplier<Stream<CacheEntry>> supplierForSegments(ConsistentHash ch,
                                                           Set<Integer> targetSegments,
                                                           Set<Object> excludedKeys,
                                                           boolean primaryOnly)

Description copied from class: AbstractCacheStream

If usePrimary is true the segments are the primary segments but only those that exist in targetSegments. However if usePrimary is false then targetSegments must be provided and non null and this will be used specifically.

Overrides:

supplierForSegments in class AbstractCacheStream<R,Stream<R>,Consumer<? super R>>

primaryOnly - determines whether we should utilize the primary segments or not.

Returns:

doubleCacheStream

protected DistributedDoubleCacheStream doubleCacheStream()

Overrides:

doubleCacheStream in class DistributedCacheStream<R>

longCacheStream

protected DistributedLongCacheStream longCacheStream()

Overrides:

longCacheStream in class DistributedCacheStream<R>

intCacheStream

protected DistributedIntCacheStream intCacheStream()

Overrides:

intCacheStream in class DistributedCacheStream<R>