Uses of Interface
org.infinispan.LongCacheStream
-
Packages that use LongCacheStream 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 LongCacheStream in org.infinispan
Methods in org.infinispan that return LongCacheStream Modifier and Type Method Description LongCacheStream
IntCacheStream. asLongStream()
LongCacheStream
LongCacheStream. disableRehashAware()
Disables tracking of rehash events that could occur to the underlying cache.LongCacheStream
LongCacheStream. distinct()
LongCacheStream
LongCacheStream. 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.LongCacheStream
LongCacheStream. filter(LongPredicate predicate)
default LongCacheStream
LongCacheStream. filter(SerializableLongPredicate predicate)
Same asfilter(LongPredicate)
except that the LongPredicate must also implement Serializable.LongCacheStream
LongCacheStream. filterKeys(Set<?> keys)
Filters which entries are returned by only returning ones that map to the given key.LongCacheStream
LongCacheStream. filterKeySegments(Set<Integer> segments)
Filters which entries are returned by what segment they are present in.LongCacheStream
LongCacheStream. flatMap(LongFunction<? extends LongStream> mapper)
default LongCacheStream
LongCacheStream. flatMap(SerializableLongFunction<? extends LongStream> mapper)
Same asflatMap(LongFunction)
except that the LongFunction must also implement Serializable.LongCacheStream
CacheStream. flatMapToLong(Function<? super R,? extends LongStream> mapper)
default LongCacheStream
CacheStream. flatMapToLong(SerializableFunction<? super R,? extends LongStream> mapper)
Same asCacheStream.flatMapToLong(Function)
except that the Function must also implementSerializable
LongCacheStream
LongCacheStream. limit(long maxSize)
LongCacheStream
LongCacheStream. map(LongUnaryOperator mapper)
default LongCacheStream
LongCacheStream. map(SerializableLongUnaryOperator mapper)
Same asmap(LongUnaryOperator)
except that the LongUnaryOperator must also implement Serializable.LongCacheStream
CacheStream. mapToLong(ToLongFunction<? super R> mapper)
default LongCacheStream
CacheStream. mapToLong(SerializableToLongFunction<? super R> mapper)
Same asCacheStream.mapToLong(ToLongFunction)
except that the ToLongFunction must also implementSerializable
LongCacheStream
DoubleCacheStream. mapToLong(DoubleToLongFunction mapper)
default LongCacheStream
DoubleCacheStream. mapToLong(SerializableDoubleToLongFunction mapper)
Same asDoubleCacheStream.mapToLong(DoubleToLongFunction)
except that the DoubleToLongFunction must also implementSerializable
LongCacheStream
IntCacheStream. mapToLong(IntToLongFunction mapper)
default LongCacheStream
IntCacheStream. mapToLong(SerializableIntToLongFunction mapper)
Same asIntCacheStream.mapToLong(IntToLongFunction)
except that the IntToLongFunction must also implementSerializable
LongCacheStream
LongCacheStream. onClose(Runnable closeHandler)
LongCacheStream
LongCacheStream. parallel()
LongCacheStream
LongCacheStream. parallelDistribution()
LongCacheStream
LongCacheStream. peek(LongConsumer action)
default LongCacheStream
LongCacheStream. peek(SerializableLongConsumer action)
Same asflatMap(LongFunction)
except that the LongFunction must also implement Serializable.LongCacheStream
LongCacheStream. segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener)
Allows registration of a segment completion listener that is notified when a segment has completed processing.LongCacheStream
LongCacheStream. sequential()
LongCacheStream
LongCacheStream. sequentialDistribution()
This would disable sending requests to all other remote nodes compared to one at a time.LongCacheStream
LongCacheStream. skip(long n)
LongCacheStream
LongCacheStream. sorted()
LongCacheStream
LongCacheStream. timeout(long timeout, TimeUnit unit)
Sets a given time to wait for a remote operation to respond by.LongCacheStream
LongCacheStream. unordered()
-
Uses of LongCacheStream in org.infinispan.stream.impl
Classes in org.infinispan.stream.impl that implement LongCacheStream Modifier and Type Class Description class
DistributedLongCacheStream<Original>
Implementation ofLongStream
that utilizes a lazily evaluated distributed back end execution.class
IntermediateLongCacheStream
An intermediate long cache stream used when an intermediate operation that requires both a remote and local portionMethods in org.infinispan.stream.impl that return LongCacheStream Modifier and Type Method Description LongCacheStream
DistributedIntCacheStream. asLongStream()
LongCacheStream
IntermediateIntCacheStream. asLongStream()
LongCacheStream
DistributedLongCacheStream. disableRehashAware()
LongCacheStream
IntermediateLongCacheStream. disableRehashAware()
LongCacheStream
DistributedLongCacheStream. distinct()
LongCacheStream
IntermediateLongCacheStream. distinct()
LongCacheStream
DistributedLongCacheStream. distributedBatchSize(int batchSize)
LongCacheStream
IntermediateLongCacheStream. distributedBatchSize(int batchSize)
LongCacheStream
DistributedLongCacheStream. filter(LongPredicate predicate)
LongCacheStream
DistributedLongCacheStream. filter(SerializableLongPredicate predicate)
LongCacheStream
IntermediateLongCacheStream. filter(LongPredicate predicate)
LongCacheStream
DistributedLongCacheStream. filterKeys(Set<?> keys)
LongCacheStream
IntermediateLongCacheStream. filterKeys(Set<?> keys)
LongCacheStream
DistributedLongCacheStream. filterKeySegments(Set<Integer> segments)
LongCacheStream
DistributedLongCacheStream. filterKeySegments(org.infinispan.commons.util.IntSet segments)
LongCacheStream
IntermediateLongCacheStream. filterKeySegments(Set<Integer> segments)
LongCacheStream
IntermediateLongCacheStream. filterKeySegments(org.infinispan.commons.util.IntSet segments)
LongCacheStream
DistributedLongCacheStream. flatMap(LongFunction<? extends LongStream> mapper)
LongCacheStream
DistributedLongCacheStream. flatMap(SerializableLongFunction<? extends LongStream> mapper)
LongCacheStream
IntermediateLongCacheStream. flatMap(LongFunction<? extends LongStream> mapper)
LongCacheStream
DistributedCacheStream. flatMapToLong(Function<? super R,? extends LongStream> mapper)
LongCacheStream
IntermediateCacheStream. flatMapToLong(Function<? super R,? extends LongStream> mapper)
LongCacheStream
DistributedLongCacheStream. limit(long maxSize)
LongCacheStream
IntermediateLongCacheStream. limit(long maxSize)
LongCacheStream
DistributedLongCacheStream. map(LongUnaryOperator mapper)
LongCacheStream
DistributedLongCacheStream. map(SerializableLongUnaryOperator mapper)
LongCacheStream
IntermediateLongCacheStream. map(LongUnaryOperator mapper)
LongCacheStream
DistributedCacheStream. mapToLong(ToLongFunction<? super R> mapper)
LongCacheStream
DistributedDoubleCacheStream. mapToLong(DoubleToLongFunction mapper)
LongCacheStream
DistributedDoubleCacheStream. mapToLong(SerializableDoubleToLongFunction mapper)
LongCacheStream
DistributedIntCacheStream. mapToLong(IntToLongFunction mapper)
LongCacheStream
DistributedIntCacheStream. mapToLong(SerializableIntToLongFunction mapper)
LongCacheStream
IntermediateCacheStream. mapToLong(ToLongFunction<? super R> mapper)
LongCacheStream
IntermediateDoubleCacheStream. mapToLong(DoubleToLongFunction mapper)
LongCacheStream
IntermediateIntCacheStream. mapToLong(IntToLongFunction mapper)
LongCacheStream
IntermediateLongCacheStream. onClose(Runnable closeHandler)
LongCacheStream
IntermediateLongCacheStream. parallel()
LongCacheStream
DistributedLongCacheStream. parallelDistribution()
LongCacheStream
IntermediateLongCacheStream. parallelDistribution()
LongCacheStream
DistributedLongCacheStream. peek(LongConsumer action)
LongCacheStream
DistributedLongCacheStream. peek(SerializableLongConsumer action)
LongCacheStream
IntermediateLongCacheStream. peek(LongConsumer action)
LongCacheStream
DistributedLongCacheStream. segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener)
LongCacheStream
IntermediateLongCacheStream. segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener)
LongCacheStream
IntermediateLongCacheStream. sequential()
LongCacheStream
DistributedLongCacheStream. sequentialDistribution()
LongCacheStream
IntermediateLongCacheStream. sequentialDistribution()
LongCacheStream
DistributedLongCacheStream. skip(long n)
LongCacheStream
IntermediateLongCacheStream. skip(long n)
LongCacheStream
DistributedLongCacheStream. sorted()
LongCacheStream
IntermediateLongCacheStream. sorted()
LongCacheStream
DistributedLongCacheStream. timeout(long timeout, TimeUnit unit)
LongCacheStream
IntermediateLongCacheStream. timeout(long timeout, TimeUnit unit)
LongCacheStream
IntermediateLongCacheStream. unordered()
protected LongCacheStream
DistributedLongCacheStream. unwrap()
-
Uses of LongCacheStream in org.infinispan.stream.impl.local
Classes in org.infinispan.stream.impl.local that implement LongCacheStream Modifier and Type Class Description class
LocalLongCacheStream
LongStream that wraps a given stream to allow for additional functionality such as injection of values into various operationsMethods in org.infinispan.stream.impl.local that return LongCacheStream Modifier and Type Method Description LongCacheStream
LocalIntCacheStream. asLongStream()
-
Uses of LongCacheStream in org.infinispan.stream.impl.tx
Classes in org.infinispan.stream.impl.tx that implement LongCacheStream Modifier and Type Class Description class
TxDistributedLongCacheStream<Original,K,V>
Long variant of tx cache stream -
Uses of LongCacheStream in org.infinispan.util
Methods in org.infinispan.util that return LongCacheStream Modifier and Type Method Description LongCacheStream
AbstractDelegatingCacheStream. flatMapToLong(Function<? super R,? extends LongStream> mapper)
LongCacheStream
AbstractDelegatingCacheStream. mapToLong(ToLongFunction<? super R> mapper)
-