Class DistributionBulkInterceptor.TxBackingEntrySet<K,V>
- java.lang.Object
-
- java.util.AbstractCollection<O>
-
- org.infinispan.commands.read.AbstractCloseableIteratorCollection<CacheEntry<K,V>,K,V>
-
- org.infinispan.interceptors.distribution.DistributionBulkInterceptor.BackingEntrySet<K,V>
-
- org.infinispan.interceptors.distribution.DistributionBulkInterceptor.TxBackingEntrySet<K,V>
-
- All Implemented Interfaces:
Iterable<CacheEntry<K,V>>
,Collection<CacheEntry<K,V>>
,Set<CacheEntry<K,V>>
,CacheCollection<CacheEntry<K,V>>
,CacheSet<CacheEntry<K,V>>
,org.infinispan.commons.util.CloseableIteratorCollection<CacheEntry<K,V>>
,org.infinispan.commons.util.CloseableIteratorSet<CacheEntry<K,V>>
- Enclosing class:
- DistributionBulkInterceptor<K,V>
protected static class DistributionBulkInterceptor.TxBackingEntrySet<K,V> extends DistributionBulkInterceptor.BackingEntrySet<K,V>
-
-
Field Summary
-
Fields inherited from class org.infinispan.interceptors.distribution.DistributionBulkInterceptor.BackingEntrySet
command, entrySet
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description CacheStream<CacheEntry<K,V>>
parallelStream()
CacheStream<CacheEntry<K,V>>
stream()
-
Methods inherited from class org.infinispan.interceptors.distribution.DistributionBulkInterceptor.BackingEntrySet
contains, iterator, remove, spliterator
-
Methods inherited from class org.infinispan.commands.read.AbstractCloseableIteratorCollection
clear, isEmpty, removeAll, retainAll, size, toArray, toArray
-
Methods inherited from class java.util.AbstractCollection
add, addAll, containsAll, toString
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface java.util.Collection
removeIf, toArray
-
-
-
-
Method Detail
-
stream
public CacheStream<CacheEntry<K,V>> stream()
Description copied from interface:org.infinispan.commons.util.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 interfaceCacheCollection<K>
- Specified by:
stream
in interfaceorg.infinispan.commons.util.CloseableIteratorCollection<K>
- Specified by:
stream
in interfaceCollection<K>
- Overrides:
stream
in classDistributionBulkInterceptor.BackingEntrySet<K,V>
-
parallelStream
public CacheStream<CacheEntry<K,V>> parallelStream()
Description copied from interface:org.infinispan.commons.util.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 interfaceCacheCollection<K>
- Specified by:
parallelStream
in interfaceorg.infinispan.commons.util.CloseableIteratorCollection<K>
- Specified by:
parallelStream
in interfaceCollection<K>
- Overrides:
parallelStream
in classDistributionBulkInterceptor.BackingEntrySet<K,V>
-
-