Uses of Interface
org.infinispan.stream.impl.intops.IntermediateOperation
-
Packages that use IntermediateOperation Package Description org.infinispan.commands Commands that operate on the cache, either locally or remotely.org.infinispan.stream.impl org.infinispan.stream.impl.intops org.infinispan.stream.impl.intops.object org.infinispan.stream.impl.intops.primitive.d org.infinispan.stream.impl.intops.primitive.i org.infinispan.stream.impl.intops.primitive.l org.infinispan.stream.impl.local org.infinispan.stream.impl.termop org.infinispan.stream.impl.termop.object org.infinispan.stream.impl.termop.primitive org.infinispan.stream.impl.tx -
-
Uses of IntermediateOperation in org.infinispan.commands
Method parameters in org.infinispan.commands with type arguments of type IntermediateOperation Modifier and Type Method Description <K> StreamIteratorRequestCommand<K>
CommandsFactory. buildStreamIteratorRequestCommand(Object id, boolean parallelStream, org.infinispan.commons.util.IntSet segments, Set<K> keys, Set<K> excludedKeys, boolean includeLoader, boolean entryStream, Iterable<IntermediateOperation> intOps, long batchSize)
<K> StreamIteratorRequestCommand<K>
CommandsFactoryImpl. buildStreamIteratorRequestCommand(Object id, boolean parallelStream, org.infinispan.commons.util.IntSet segments, Set<K> keys, Set<K> excludedKeys, boolean includeLoader, boolean entryStream, Iterable<IntermediateOperation> intOps, long batchSize)
-
Uses of IntermediateOperation in org.infinispan.stream.impl
Fields in org.infinispan.stream.impl with type parameters of type IntermediateOperation Modifier and Type Field Description protected Queue<IntermediateOperation>
AbstractCacheStream. intermediateOperations
Methods in org.infinispan.stream.impl that return IntermediateOperation Modifier and Type Method Description IntermediateOperation
AbstractCacheStream.MapOpsExternalizer. readObject(ObjectInput input)
Methods in org.infinispan.stream.impl that return types with arguments of type IntermediateOperation Modifier and Type Method Description Set<Class<? extends IntermediateOperation>>
AbstractCacheStream.MapOpsExternalizer. getTypeClasses()
Methods in org.infinispan.stream.impl with parameters of type IntermediateOperation Modifier and Type Method Description protected void
AbstractCacheStream. addIntermediateOperation(Queue<IntermediateOperation> intermediateOperations, IntermediateOperation<T,S,?,?> intermediateOperation)
protected S2
AbstractCacheStream. addIntermediateOperation(IntermediateOperation<T,S,T,S> intermediateOperation)
protected void
AbstractCacheStream. addIntermediateOperationMap(IntermediateOperation<T,S,?,?> intermediateOperation)
void
AbstractCacheStream.MapOpsExternalizer. writeObject(ObjectOutput output, IntermediateOperation object)
Method parameters in org.infinispan.stream.impl with type arguments of type IntermediateOperation Modifier and Type Method Description protected void
AbstractCacheStream. addIntermediateOperation(Queue<IntermediateOperation> intermediateOperations, IntermediateOperation<T,S,?,?> intermediateOperation)
<E> ClusterStreamManager.RemoteIteratorPublisher<E>
ClusterStreamManager. remoteIterationPublisher(boolean parallelStream, Supplier<Map.Entry<Address,org.infinispan.commons.util.IntSet>> segments, Set<K> keysToInclude, IntFunction<Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, Iterable<IntermediateOperation> intermediateOperations)
<E> ClusterStreamManager.RemoteIteratorPublisher<E>
ClusterStreamManagerImpl. 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<IntermediateOperation> intermediateOperations)
<E> ClusterStreamManager.RemoteIteratorPublisher<E>
PartitionAwareClusterStreamManager. 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<IntermediateOperation> intermediateOperations)
<Original,E>
IteratorHandler.OnCloseIterator<E>IteratorHandler. start(Address origin, Supplier<Stream<Original>> streamSupplier, Iterable<IntermediateOperation> intOps, Object requestId)
Starts an iteration process from the given stream that converts the stream to a subsequent stream using the given intermediate operations and then creates a managed iterator for the caller to subsequently retrieve.IteratorResponse
LocalStreamManager. startIterator(Object requestId, Address origin, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, boolean entryStream, Iterable<IntermediateOperation> intermediateOperations, long batchSize)
Signals that a new iterator is created using the given arguments.IteratorResponse
LocalStreamManagerImpl. startIterator(Object requestId, Address origin, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, boolean entryStream, Iterable<IntermediateOperation> intermediateOperations, long batchSize)
Constructor parameters in org.infinispan.stream.impl with type arguments of type IntermediateOperation Constructor Description StreamIteratorRequestCommand(ByteString cacheName, Address origin, Object id, boolean parallelStream, org.infinispan.commons.util.IntSet segments, Set<K> keys, Set<K> excludedKeys, boolean includeLoader, boolean entryStream, Iterable<IntermediateOperation> intOps, long batchSize)
-
Uses of IntermediateOperation in org.infinispan.stream.impl.intops
Subinterfaces of IntermediateOperation in org.infinispan.stream.impl.intops Modifier and Type Interface Description interface
FlatMappingOperation<InputType,InputStream extends BaseStream<InputType,InputStream>,OutputType,OutputStream extends BaseStream<OutputType,OutputStream>>
Interface to signify that anIntermediateOperation
is a flat map operation.interface
MappingOperation<InputType,InputStream extends BaseStream<InputType,InputStream>,OutputType,OutputStream extends BaseStream<OutputType,OutputStream>>
Marker interface to signify that anIntermediateOperation
is a map operation.Classes in org.infinispan.stream.impl.intops that implement IntermediateOperation Modifier and Type Class Description class
UnorderedOperation<Type,Stream extends BaseStream<Type,Stream>>
Performs unordered operation on aBaseStream
Methods in org.infinispan.stream.impl.intops that return IntermediateOperation Modifier and Type Method Description IntermediateOperation
IntermediateOperationExternalizer. readObject(ObjectInput input)
Methods in org.infinispan.stream.impl.intops that return types with arguments of type IntermediateOperation Modifier and Type Method Description Set<Class<? extends IntermediateOperation>>
IntermediateOperationExternalizer. getTypeClasses()
Methods in org.infinispan.stream.impl.intops with parameters of type IntermediateOperation Modifier and Type Method Description void
IntermediateOperationExternalizer. writeObject(ObjectOutput output, IntermediateOperation object)
-
Uses of IntermediateOperation in org.infinispan.stream.impl.intops.object
Classes in org.infinispan.stream.impl.intops.object that implement IntermediateOperation Modifier and Type Class Description class
DistinctOperation<S>
Performs distinct operation on a regularStream
class
FilterOperation<S>
Performs filter operation on a regularStream
class
FlatMapOperation<I,O>
Performs flat map operation on a regularStream
class
FlatMapToDoubleOperation<I>
Performs flat map to double operation on a regularStream
class
FlatMapToIntOperation<I>
Performs flat map to int operation on a regularStream
class
FlatMapToLongOperation<I>
Performs flat map to long operation on a regularStream
class
LimitOperation<S>
Performs limit operation on a regularStream
class
MapOperation<I,O>
Performs map to operation on a regularStream
class
MapToDoubleOperation<I>
Performs map to double operation on a regularStream
class
MapToIntOperation<I>
Performs map to int operation on a regularStream
class
MapToLongOperation<I>
Performs map to long operation on a regularStream
class
PeekOperation<S>
Performs peek operation on a regularStream
class
SkipOperation<S>
Performs skip operation on a regularStream
class
SortedComparatorOperation<S>
Performs sorted operation with a comparator on a regularStream
class
SortedOperation<S>
Performs sorted operation on a regularStream
-
Uses of IntermediateOperation in org.infinispan.stream.impl.intops.primitive.d
Classes in org.infinispan.stream.impl.intops.primitive.d that implement IntermediateOperation Modifier and Type Class Description class
BoxedDoubleOperation
Performs boxed operation on aDoubleStream
class
DistinctDoubleOperation
Performs distinct operation on aDoubleStream
class
FilterDoubleOperation
Performs filter operation on aDoubleStream
class
FlatMapDoubleOperation
Performs flat map operation on aDoubleStream
class
LimitDoubleOperation
Performs limit operation on aDoubleStream
class
MapDoubleOperation
Performs map operation on aDoubleStream
class
MapToIntDoubleOperation
Performs map to int operation on aDoubleStream
class
MapToLongDoubleOperation
Performs map to long operation on aDoubleStream
class
MapToObjDoubleOperation<R>
Performs boxed operation on aDoubleStream
class
PeekDoubleOperation
Performs peek operation on aDoubleStream
class
SkipDoubleOperation
Performs skip operation on aDoubleStream
class
SortedDoubleOperation
Performs sorted operation on aDoubleStream
-
Uses of IntermediateOperation in org.infinispan.stream.impl.intops.primitive.i
Classes in org.infinispan.stream.impl.intops.primitive.i that implement IntermediateOperation Modifier and Type Class Description class
AsDoubleIntOperation
Performs as double operation on aIntStream
class
AsLongIntOperation
Performs as long operation on aIntStream
class
BoxedIntOperation
Performs boxed operation on aIntStream
class
DistinctIntOperation
Performs distinct operation on aIntStream
class
FilterIntOperation<S>
Performs filter operation on aIntStream
class
FlatMapIntOperation
Performs flat map operation on aIntStream
class
LimitIntOperation
Performs limit operation on aIntStream
class
MapIntOperation
Performs map operation on aIntStream
class
MapToDoubleIntOperation
Performs map to double operation on aIntStream
class
MapToLongIntOperation
Performs map to long operation on aIntStream
class
MapToObjIntOperation<R>
Performs map to object operation on aIntStream
class
PeekIntOperation
Performs peek operation on aIntStream
class
SkipIntOperation
Performs skip operation on aIntStream
class
SortedIntOperation
Performs sorted operation on aIntStream
-
Uses of IntermediateOperation in org.infinispan.stream.impl.intops.primitive.l
Classes in org.infinispan.stream.impl.intops.primitive.l that implement IntermediateOperation Modifier and Type Class Description class
AsDoubleLongOperation
Performs as double operation on aLongStream
class
BoxedLongOperation
Performs boxed operation on aLongStream
class
DistinctLongOperation
Performs distinct operation on aLongStream
class
FilterLongOperation<S>
Performs filter operation on aLongStream
class
FlatMapLongOperation
Performs flat map operation on aLongStream
class
LimitLongOperation
Performs limit operation on aLongStream
class
MapLongOperation
Performs map operation on aLongStream
class
MapToDoubleLongOperation
Performs map to double operation on aLongStream
class
MapToIntLongOperation
Performs map to int operation on aLongStream
class
MapToObjLongOperation<R>
Performs map to object operation on aLongStream
class
PeekLongOperation
Performs peek operation on aLongStream
class
SkipLongOperation
Performs skip operation on aLongStream
class
SortedLongOperation
Performs sorted operation on aLongStream
-
Uses of IntermediateOperation in org.infinispan.stream.impl.local
Fields in org.infinispan.stream.impl.local with type parameters of type IntermediateOperation Modifier and Type Field Description protected Queue<IntermediateOperation>
AbstractLocalCacheStream. intermediateOperations
-
Uses of IntermediateOperation in org.infinispan.stream.impl.termop
Fields in org.infinispan.stream.impl.termop with type parameters of type IntermediateOperation Modifier and Type Field Description protected Iterable<IntermediateOperation>
BaseTerminalOperation. intermediateOperations
Methods in org.infinispan.stream.impl.termop that return types with arguments of type IntermediateOperation Modifier and Type Method Description Iterable<IntermediateOperation>
BaseTerminalOperation. getIntermediateOperations()
Constructor parameters in org.infinispan.stream.impl.termop with type arguments of type IntermediateOperation Constructor Description AbstractForEachOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier, Function<? super Original,? extends K> toKeyFunction, int batchSize)
BaseTerminalOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier)
SegmentRetryingOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier, Function<? super S2,? extends E> function)
SingleRunOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier, Function<? super S2,? extends E> function)
-
Uses of IntermediateOperation in org.infinispan.stream.impl.termop.object
Constructor parameters in org.infinispan.stream.impl.termop.object with type arguments of type IntermediateOperation Constructor Description ForEachBiOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier, Function<? super Original,? extends K> toKeyFunction, int batchSize, BiConsumer<Cache<K,?>,? super V> consumer)
ForEachOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier, Function<? super Original,? extends K> toKeyFunction, int batchSize, Consumer<? super V> consumer)
-
Uses of IntermediateOperation in org.infinispan.stream.impl.termop.primitive
Constructor parameters in org.infinispan.stream.impl.termop.primitive with type arguments of type IntermediateOperation Constructor Description AbstractForEachDoubleOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier, Function<? super Original,? extends K> toKeyFunction, int batchSize)
AbstractForEachIntOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier, Function<? super Original,? extends K> toKeyFunction, int batchSize)
AbstractForEachLongOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier, Function<? super Original,? extends K> toKeyFunction, int batchSize)
ForEachDoubleOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier, Function<? super Original,? extends K> toKeyFunction, int batchSize, DoubleConsumer consumer)
ForEachFlatMapDoubleOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier, Function<? super Original,? extends K> toKeyFunction, int batchSize, DoubleConsumer consumer)
ForEachFlatMapIntOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier, Function<? super Original,? extends K> toKeyFunction, int batchSize, IntConsumer consumer)
ForEachFlatMapLongOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier, Function<? super Original,? extends K> toKeyFunction, int batchSize, LongConsumer consumer)
ForEachFlatMapObjDoubleOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier, Function<? super Original,? extends K> toKeyFunction, int batchSize, ObjDoubleConsumer<Cache<K,?>> consumer)
ForEachFlatMapObjIntOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier, Function<? super Original,? extends K> toKeyFunction, int batchSize, ObjIntConsumer<Cache<K,?>> consumer)
ForEachFlatMapObjLongOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier, Function<? super Original,? extends K> toKeyFunction, int batchSize, ObjLongConsumer<Cache<K,?>> consumer)
ForEachIntOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier, Function<? super Original,? extends K> toKeyFunction, int batchSize, IntConsumer consumer)
ForEachLongOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier, Function<? super Original,? extends K> toKeyFunction, int batchSize, LongConsumer consumer)
ForEachObjDoubleOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier, Function<? super Original,? extends K> toKeyFunction, int batchSize, ObjDoubleConsumer<Cache<K,?>> consumer)
ForEachObjIntOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier, Function<? super Original,? extends K> toKeyFunction, int batchSize, ObjIntConsumer<Cache<K,?>> consumer)
ForEachObjLongOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier, Function<? super Original,? extends K> toKeyFunction, int batchSize, ObjLongConsumer<Cache<K,?>> consumer)
-
Uses of IntermediateOperation in org.infinispan.stream.impl.tx
Method parameters in org.infinispan.stream.impl.tx with type arguments of type IntermediateOperation Modifier and Type Method Description <E> ClusterStreamManager.RemoteIteratorPublisher<E>
TxClusterStreamManager. remoteIterationPublisher(boolean parallelStream, Supplier<Map.Entry<Address,org.infinispan.commons.util.IntSet>> segments, Set<K> keysToInclude, IntFunction<Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, Iterable<IntermediateOperation> intermediateOperations)
-