org.infinispan

Interface CacheCollection<E>

Type Parameters:

E - The type of the collection

All Superinterfaces:

CloseableIteratorCollection<E>, Collection<E>, Iterable<E>

All Known Subinterfaces:

CacheSet<E>

All Known Implementing Classes:

AbstractDelegatingCacheCollection, AbstractDelegatingCacheSet, AbstractDelegatingEntryCacheSet, AbstractDelegatingKeyCacheSet, CacheSetMapper, DistributionBulkInterceptor.BackingEntrySet, DistributionBulkInterceptor.BackingKeySet, DistributionBulkInterceptor.TxBackingEntrySet, SimpleCacheImpl.CacheEntrySet, SimpleCacheImpl.EntrySet, SimpleCacheImpl.EntrySetBase, SimpleCacheImpl.KeySet, SimpleCacheImpl.Values, ValueCacheCollection, WriteableCacheCollectionMapper, WriteableCacheSetMapper

public interface CacheCollection<E>
extends CloseableIteratorCollection<E>

A collection type that returns special Cache based streams that have additional options to tweak behavior.

Since:

8.0

Method Summary

Modifier and Type	Method and Description
default org.reactivestreams.Publisher<E>	localPublisher(int segment) Returns a publisher that will publish all elements that map to the given segment.
default org.reactivestreams.Publisher<E>	localPublisher(IntSet segments) Returns a publisher that will publish all elements that map to the given segment.
CacheStream<E>	parallelStream()
CacheStream<E>	stream()

Methods inherited from interface org.infinispan.commons.util.CloseableIteratorCollection

iterator, spliterator

Methods inherited from interface java.util.Collection

add, addAll, clear, contains, containsAll, equals, hashCode, isEmpty, remove, removeAll, removeIf, retainAll, size, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

Method Detail

stream

CacheStream<E> stream()

Description copied from interface: CloseableIteratorCollection

This stream should be explicitly closed after it has been used. Failure to do so could cause resources to not be freed properly

Specified by:

stream in interface CloseableIteratorCollection<E>

Specified by:

stream in interface Collection<E>

parallelStream

CacheStream<E> parallelStream()

Description copied from interface: CloseableIteratorCollection

This stream should be explicitly closed after it has been used. Failure to do so could cause resources to not be freed properly

Specified by:

parallelStream in interface CloseableIteratorCollection<E>

Specified by:

parallelStream in interface Collection<E>

localPublisher

@Experimental
default org.reactivestreams.Publisher<E> localPublisher(int segment)

Returns a publisher that will publish all elements that map to the given segment. Note this publisher may require going remotely to retrieve elements depending on the underlying configuration and flags applied to the original Cache used to create this CacheCollection.

Parameters:

segment - the segment that all published elements belong to

Returns:

Publisher that will publish the elements for the given segment

localPublisher

@Experimental
default org.reactivestreams.Publisher<E> localPublisher(IntSet segments)

Returns a publisher that will publish all elements that map to the given segment. Note this publisher may require going remotely to retrieve elements depending on the underlying configuration and flags applied to the original Cache used to create this CacheCollection.

Parameters:

segments - the segments that all published elements belong to

Returns:

Publisher that will publish the elements for the given segments