Package | Description |
---|---|
org.infinispan.stream.impl.termop | |
org.infinispan.stream.impl.termop.object | |
org.infinispan.stream.impl.termop.primitive |
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 | Method and Description |
---|---|
BaseTerminalOperation |
TerminalOperationExternalizer.readObject(ObjectInput input) |
Modifier and Type | Method and Description |
---|---|
Set<Class<? extends BaseTerminalOperation>> |
TerminalOperationExternalizer.getTypeClasses() |
Modifier and Type | Method and Description |
---|---|
void |
TerminalOperationExternalizer.writeObject(ObjectOutput output,
BaseTerminalOperation object) |
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.