Modifier and Type | Field and Description |
---|---|
protected Queue<IntermediateOperation> |
AbstractCacheStream.intermediateOperations |
protected Queue<IntermediateOperation> |
AbstractCacheStream.localIntermediateOperations |
Modifier and Type | Method and Description |
---|---|
protected S |
AbstractCacheStream.addIntermediateOperation(IntermediateOperation<T,S,T,S> intermediateOperation) |
protected void |
AbstractCacheStream.addIntermediateOperationMap(IntermediateOperation<T,S,?,?> intermediateOperation) |
protected <T2,S2 extends BaseStream<T2,S2>,S3 extends S2> |
AbstractCacheStream.addIntermediateOperationMap(IntermediateOperation<T,S,T2,S2> intermediateOperation,
S3 stream) |
protected void |
AbstractCacheStream.markDistinct(IntermediateOperation<T,S,T,S> intermediateOperation,
org.infinispan.stream.impl.AbstractCacheStream.IntermediateType type) |
Modifier and Type | Class and Description |
---|---|
class |
UnorderedOperation<Type,Stream extends BaseStream<Type,Stream>>
Performs unordered operation on a
BaseStream |
Modifier and Type | Method and Description |
---|---|
IntermediateOperation |
IntermediateOperationExternalizer.readObject(ObjectInput input) |
Modifier and Type | Method and Description |
---|---|
Set<Class<? extends IntermediateOperation>> |
IntermediateOperationExternalizer.getTypeClasses() |
Modifier and Type | Method and Description |
---|---|
void |
IntermediateOperationExternalizer.writeObject(ObjectOutput output,
IntermediateOperation object) |
Modifier and Type | Class and Description |
---|---|
class |
DistinctOperation<S>
Performs distinct operation on a regular
Stream |
class |
FilterOperation<S>
Performs filter operation on a regular
Stream |
class |
FlatMapOperation<I,O>
Performs flat map operation on a regular
Stream |
class |
FlatMapToDoubleOperation<I>
Performs flat map to double operation on a regular
Stream |
class |
FlatMapToIntOperation<I>
Performs flat map to int operation on a regular
Stream |
class |
FlatMapToLongOperation<I>
Performs flat map to long operation on a regular
Stream |
class |
LimitOperation<S>
Performs limit operation on a regular
Stream |
class |
MapOperation<I,O>
Performs map to operation on a regular
Stream |
class |
MapToDoubleOperation<I>
Performs map to double operation on a regular
Stream |
class |
MapToIntOperation<I>
Performs map to int operation on a regular
Stream |
class |
MapToLongOperation<I>
Performs map to long operation on a regular
Stream |
class |
PeekOperation<S>
Performs peek operation on a regular
Stream |
class |
SkipOperation<S>
Performs skip operation on a regular
Stream |
class |
SortedComparatorOperation<S>
Performs sorted operation with a comparator on a regular
Stream |
class |
SortedOperation<S>
Performs sorted operation on a regular
Stream |
Modifier and Type | Class and Description |
---|---|
class |
BoxedDoubleOperation
Performs boxed operation on a
DoubleStream |
class |
DistinctDoubleOperation
Performs distinct operation on a
DoubleStream |
class |
FilterDoubleOperation
Performs filter operation on a
DoubleStream |
class |
FlatMapDoubleOperation
Performs flat map operation on a
DoubleStream |
class |
LimitDoubleOperation
Performs limit operation on a
DoubleStream |
class |
MapDoubleOperation
Performs map operation on a
DoubleStream |
class |
MapToIntDoubleOperation
Performs map to int operation on a
DoubleStream |
class |
MapToLongDoubleOperation
Performs map to long operation on a
DoubleStream |
class |
MapToObjDoubleOperation<R>
Performs boxed operation on a
DoubleStream |
class |
PeekDoubleOperation
Performs peek operation on a
DoubleStream |
class |
SkipDoubleOperation
Performs skip operation on a
DoubleStream |
class |
SortedDoubleOperation
Performs sorted operation on a
DoubleStream |
Modifier and Type | Class and Description |
---|---|
class |
AsDoubleIntOperation
Performs as double operation on a
IntStream |
class |
AsLongIntOperation
Performs as long operation on a
IntStream |
class |
BoxedIntOperation
Performs boxed operation on a
IntStream |
class |
DistinctIntOperation
Performs distinct operation on a
IntStream |
class |
FilterIntOperation<S>
Performs filter operation on a
IntStream |
class |
FlatMapIntOperation
Performs flat map operation on a
IntStream |
class |
LimitIntOperation
Performs limit operation on a
IntStream |
class |
MapIntOperation
Performs map operation on a
IntStream |
class |
MapToDoubleIntOperation
Performs map to double operation on a
IntStream |
class |
MapToLongIntOperation
Performs map to long operation on a
IntStream |
class |
MapToObjIntOperation<R>
Performs map to object operation on a
IntStream |
class |
PeekIntOperation
Performs peek operation on a
IntStream |
class |
SkipIntOperation
Performs skip operation on a
IntStream |
class |
SortedIntOperation
Performs sorted operation on a
IntStream |
Modifier and Type | Class and Description |
---|---|
class |
AsDoubleLongOperation
Performs as double operation on a
LongStream |
class |
BoxedLongOperation
Performs boxed operation on a
LongStream |
class |
DistinctLongOperation
Performs distinct operation on a
LongStream |
class |
FilterLongOperation<S>
Performs filter operation on a
LongStream |
class |
FlatMapLongOperation
Performs flat map operation on a
LongStream |
class |
LimitLongOperation
Performs limit operation on a
LongStream |
class |
MapLongOperation
Performs map operation on a
LongStream |
class |
MapToDoubleLongOperation
Performs map to double operation on a
LongStream |
class |
MapToIntLongOperation
Performs map to int operation on a
LongStream |
class |
MapToObjLongOperation<R>
Performs map to object operation on a
LongStream |
class |
PeekLongOperation
Performs peek operation on a
LongStream |
class |
SkipLongOperation
Performs skip operation on a
LongStream |
class |
SortedLongOperation
Performs sorted operation on a
LongStream |
Modifier and Type | Field and Description |
---|---|
protected Queue<IntermediateOperation> |
AbstractLocalCacheStream.intermediateOperations |
Modifier and Type | Field and Description |
---|---|
protected Iterable<IntermediateOperation> |
BaseTerminalOperation.intermediateOperations |
Modifier and Type | Method and Description |
---|---|
Iterable<IntermediateOperation> |
BaseTerminalOperation.getIntermediateOperations() |
Constructor and Description |
---|
AbstractForEachOperation(Iterable<IntermediateOperation> intermediateOperations,
Supplier<Stream<CacheEntry>> supplier,
int batchSize) |
BaseTerminalOperation(Iterable<IntermediateOperation> intermediateOperations,
Supplier<? extends BaseStream<?,?>> supplier) |
SegmentRetryingOperation(Iterable<IntermediateOperation> intermediateOperations,
Supplier<? extends Stream<?>> supplier,
Function<S,? extends E> function) |
SingleRunOperation(Iterable<IntermediateOperation> intermediateOperations,
Supplier<? extends BaseStream<?,?>> supplier,
Function<S,? extends E> function) |
Constructor and Description |
---|
FlatMapIteratorOperation(Iterable<IntermediateOperation> intermediateOperations,
Supplier<Stream<CacheEntry>> supplier,
int batchSize) |
ForEachOperation(Iterable<IntermediateOperation> intermediateOperations,
Supplier<Stream<CacheEntry>> supplier,
int batchSize,
Consumer<? super V> consumer) |
MapIteratorOperation(Iterable<IntermediateOperation> intermediateOperations,
Supplier<Stream<CacheEntry>> supplier,
int batchSize) |
NoMapIteratorOperation(Iterable<IntermediateOperation> intermediateOperations,
Supplier<Stream<CacheEntry>> supplier,
int batchSize) |
Copyright © 2022 JBoss, a division of Red Hat. All rights reserved.