Uses of Interface
org.infinispan.IntCacheStream
-
Packages that use IntCacheStream Package Description org.infinispan This is the core of Infinispan, a distributed, transactional, highly scalable data grid platform.org.infinispan.stream.impl org.infinispan.stream.impl.local org.infinispan.stream.impl.tx org.infinispan.util General utilities that are not specific to Infinispan, including string parsing helpers, reflection tools and collections and containers designed to supplement the JDK-provided containers. -
-
Uses of IntCacheStream in org.infinispan
Methods in org.infinispan that return IntCacheStream Modifier and Type Method Description IntCacheStream
IntCacheStream. disableRehashAware()
Disables tracking of rehash events that could occur to the underlying cache.IntCacheStream
IntCacheStream. distinct()
IntCacheStream
IntCacheStream. distributedBatchSize(int batchSize)
Controls how many keys are returned from a remote node when using a stream terminal operation with a distributed cache to back this stream.IntCacheStream
IntCacheStream. filter(IntPredicate predicate)
default IntCacheStream
IntCacheStream. filter(SerializableIntPredicate predicate)
Same asfilter(IntPredicate)
except that the IntPredicate must also implementSerializable
IntCacheStream
IntCacheStream. filterKeys(Set<?> keys)
Filters which entries are returned by only returning ones that map to the given key.IntCacheStream
IntCacheStream. filterKeySegments(Set<Integer> segments)
Filters which entries are returned by what segment they are present in.IntCacheStream
IntCacheStream. flatMap(IntFunction<? extends IntStream> mapper)
default IntCacheStream
IntCacheStream. flatMap(SerializableIntFunction<? extends IntStream> mapper)
Same asflatMap(IntFunction)
except that the IntFunction must also implementSerializable
IntCacheStream
CacheStream. flatMapToInt(Function<? super R,? extends IntStream> mapper)
default IntCacheStream
CacheStream. flatMapToInt(SerializableFunction<? super R,? extends IntStream> mapper)
Same asCacheStream.flatMapToInt(Function)
except that the Function must also implementSerializable
IntCacheStream
IntCacheStream. limit(long maxSize)
IntCacheStream
IntCacheStream. map(IntUnaryOperator mapper)
default IntCacheStream
IntCacheStream. map(SerializableIntUnaryOperator mapper)
Same asmap(IntUnaryOperator)
except that the IntUnaryOperator must also implementSerializable
IntCacheStream
CacheStream. mapToInt(ToIntFunction<? super R> mapper)
default IntCacheStream
CacheStream. mapToInt(SerializableToIntFunction<? super R> mapper)
Same asCacheStream.mapToInt(ToIntFunction)
except that the ToIntFunction must also implementSerializable
IntCacheStream
DoubleCacheStream. mapToInt(DoubleToIntFunction mapper)
default IntCacheStream
DoubleCacheStream. mapToInt(SerializableDoubleToIntFunction mapper)
Same asDoubleCacheStream.mapToInt(DoubleToIntFunction)
except that the DoubleToIntFunction must also implementSerializable
IntCacheStream
LongCacheStream. mapToInt(LongToIntFunction mapper)
default IntCacheStream
LongCacheStream. mapToInt(SerializableLongToIntFunction mapper)
Same asLongCacheStream.mapToInt(LongToIntFunction)
except that the LongToIntFunction must also implement Serializable.IntCacheStream
IntCacheStream. onClose(Runnable closeHandler)
IntCacheStream
IntCacheStream. parallel()
IntCacheStream
IntCacheStream. parallelDistribution()
IntCacheStream
IntCacheStream. peek(IntConsumer action)
default IntCacheStream
IntCacheStream. peek(SerializableIntConsumer action)
Same asflatMap(IntFunction)
except that the IntFunction must also implementSerializable
IntCacheStream
IntCacheStream. segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener)
Allows registration of a segment completion listener that is notified when a segment has completed processing.IntCacheStream
IntCacheStream. sequential()
IntCacheStream
IntCacheStream. sequentialDistribution()
This would disable sending requests to all other remote nodes compared to one at a time.IntCacheStream
IntCacheStream. skip(long n)
IntCacheStream
IntCacheStream. sorted()
IntCacheStream
IntCacheStream. timeout(long timeout, TimeUnit unit)
Sets a given time to wait for a remote operation to respond by.IntCacheStream
IntCacheStream. unordered()
-
Uses of IntCacheStream in org.infinispan.stream.impl
Classes in org.infinispan.stream.impl that implement IntCacheStream Modifier and Type Class Description class
DistributedIntCacheStream<Original>
Implementation ofIntStream
that utilizes a lazily evaluated distributed back end execution.class
IntermediateIntCacheStream
An intermediate int cache stream used when an intermediate operation that requires both a remote and local portionMethods in org.infinispan.stream.impl that return IntCacheStream Modifier and Type Method Description IntCacheStream
DistributedIntCacheStream. disableRehashAware()
IntCacheStream
IntermediateIntCacheStream. disableRehashAware()
IntCacheStream
DistributedIntCacheStream. distinct()
IntCacheStream
IntermediateIntCacheStream. distinct()
IntCacheStream
DistributedIntCacheStream. distributedBatchSize(int batchSize)
IntCacheStream
IntermediateIntCacheStream. distributedBatchSize(int batchSize)
IntCacheStream
DistributedIntCacheStream. filter(IntPredicate predicate)
IntCacheStream
DistributedIntCacheStream. filter(SerializableIntPredicate predicate)
IntCacheStream
IntermediateIntCacheStream. filter(IntPredicate predicate)
IntCacheStream
DistributedIntCacheStream. filterKeys(Set<?> keys)
IntCacheStream
IntermediateIntCacheStream. filterKeys(Set<?> keys)
IntCacheStream
DistributedIntCacheStream. filterKeySegments(Set<Integer> segments)
IntCacheStream
DistributedIntCacheStream. filterKeySegments(org.infinispan.commons.util.IntSet segments)
IntCacheStream
IntermediateIntCacheStream. filterKeySegments(Set<Integer> segments)
IntCacheStream
IntermediateIntCacheStream. filterKeySegments(org.infinispan.commons.util.IntSet segments)
IntCacheStream
DistributedIntCacheStream. flatMap(IntFunction<? extends IntStream> mapper)
IntCacheStream
DistributedIntCacheStream. flatMap(SerializableIntFunction<? extends IntStream> mapper)
IntCacheStream
IntermediateIntCacheStream. flatMap(IntFunction<? extends IntStream> mapper)
IntCacheStream
DistributedCacheStream. flatMapToInt(Function<? super R,? extends IntStream> mapper)
IntCacheStream
IntermediateCacheStream. flatMapToInt(Function<? super R,? extends IntStream> mapper)
IntCacheStream
DistributedIntCacheStream. limit(long maxSize)
IntCacheStream
IntermediateIntCacheStream. limit(long maxSize)
IntCacheStream
DistributedIntCacheStream. map(IntUnaryOperator mapper)
IntCacheStream
DistributedIntCacheStream. map(SerializableIntUnaryOperator mapper)
IntCacheStream
IntermediateIntCacheStream. map(IntUnaryOperator mapper)
IntCacheStream
DistributedCacheStream. mapToInt(ToIntFunction<? super R> mapper)
IntCacheStream
DistributedDoubleCacheStream. mapToInt(DoubleToIntFunction mapper)
IntCacheStream
DistributedDoubleCacheStream. mapToInt(SerializableDoubleToIntFunction mapper)
IntCacheStream
DistributedLongCacheStream. mapToInt(LongToIntFunction mapper)
IntCacheStream
DistributedLongCacheStream. mapToInt(SerializableLongToIntFunction mapper)
IntCacheStream
IntermediateCacheStream. mapToInt(ToIntFunction<? super R> mapper)
IntCacheStream
IntermediateDoubleCacheStream. mapToInt(DoubleToIntFunction mapper)
IntCacheStream
IntermediateLongCacheStream. mapToInt(LongToIntFunction mapper)
IntCacheStream
IntermediateIntCacheStream. onClose(Runnable closeHandler)
IntCacheStream
IntermediateIntCacheStream. parallel()
IntCacheStream
DistributedIntCacheStream. parallelDistribution()
IntCacheStream
IntermediateIntCacheStream. parallelDistribution()
IntCacheStream
DistributedIntCacheStream. peek(IntConsumer action)
IntCacheStream
DistributedIntCacheStream. peek(SerializableIntConsumer action)
IntCacheStream
IntermediateIntCacheStream. peek(IntConsumer action)
IntCacheStream
DistributedIntCacheStream. segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener)
IntCacheStream
IntermediateIntCacheStream. segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener)
IntCacheStream
IntermediateIntCacheStream. sequential()
IntCacheStream
DistributedIntCacheStream. sequentialDistribution()
IntCacheStream
IntermediateIntCacheStream. sequentialDistribution()
IntCacheStream
DistributedIntCacheStream. skip(long n)
IntCacheStream
IntermediateIntCacheStream. skip(long n)
IntCacheStream
DistributedIntCacheStream. sorted()
IntCacheStream
IntermediateIntCacheStream. sorted()
IntCacheStream
DistributedIntCacheStream. timeout(long timeout, TimeUnit unit)
IntCacheStream
IntermediateIntCacheStream. timeout(long timeout, TimeUnit unit)
IntCacheStream
IntermediateIntCacheStream. unordered()
-
Uses of IntCacheStream in org.infinispan.stream.impl.local
Classes in org.infinispan.stream.impl.local that implement IntCacheStream Modifier and Type Class Description class
LocalIntCacheStream
IntStream that wraps a given stream to allow for additional functionality such as injection of values into various operations -
Uses of IntCacheStream in org.infinispan.stream.impl.tx
Classes in org.infinispan.stream.impl.tx that implement IntCacheStream Modifier and Type Class Description class
TxDistributedIntCacheStream<Original,K,V>
Int variant of tx cache stream -
Uses of IntCacheStream in org.infinispan.util
Methods in org.infinispan.util that return IntCacheStream Modifier and Type Method Description IntCacheStream
AbstractDelegatingCacheStream. flatMapToInt(Function<? super R,? extends IntStream> mapper)
IntCacheStream
AbstractDelegatingCacheStream. mapToInt(ToIntFunction<? super R> mapper)
-