Package | Description |
---|---|
org.infinispan.stream.impl | |
org.infinispan.stream.impl.termop | |
org.infinispan.stream.impl.termop.object | |
org.infinispan.stream.impl.termop.primitive |
Modifier and Type | Interface and Description |
---|---|
interface |
KeyTrackingTerminalOperation<K,R,R2>
A terminal operation for a
CacheStream that allows tracking keys during a rehash event. |
interface |
TerminalOperation<R>
Interface describing an operation that is a terminal one that doesn't track keys.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractForEachOperation<K,V,S extends BaseStream<V,S>>
This is a base operation class for the use of the for each terminal operator.
|
class |
SegmentRetryingOperation<E,T,S extends BaseStream<T,S>>
A terminal based operation that runs the provided function to evaluate the operation.
|
class |
SingleRunOperation<E,R,S extends BaseStream<R,S>>
Runs the provided function once only and returns the result.
|
Modifier and Type | Class and Description |
---|---|
class |
FlatMapIteratorOperation<K,V>
Terminal rehash aware operation that handles an iterator when a flat map intermediate operation was performed on
the stream.
|
class |
ForEachOperation<K,V>
Terminal operation that handles for each where no map operations are defined
|
class |
MapIteratorOperation<K,V,V2>
Terminal rehash aware operation that handles an iterator when a map intermediate operation was performed on
the stream.
|
class |
NoMapIteratorOperation<K,V>
Terminal rehash aware operation that handles an iterator when no flat map or map intermediate operation was performed
on the stream.
|
Modifier and Type | Class and Description |
---|---|
class |
ForEachDoubleOperation<K>
Terminal rehash aware operation that handles for each where no flat map operations are defined on a
DoubleStream . |
class |
ForEachFlatMapDoubleOperation<K>
Terminal rehash aware operation that handles for each where flat map operation is performed on a
DoubleStream . |
class |
ForEachFlatMapIntOperation<K>
Terminal rehash aware operation that handles for each where flat map operation is performed on a
IntStream . |
class |
ForEachFlatMapLongOperation<K>
Terminal rehash aware operation that handles for each where flat map operation is performed on a
LongStream . |
class |
ForEachIntOperation<K>
Terminal rehash aware operation that handles for each where no flat map operations are defined on a
IntStream . |
class |
ForEachLongOperation<K>
Terminal rehash aware operation that handles for each where no flat map operations are defined on a
LongStream . |
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.