Class DistributionBulkInterceptor.BackingKeySet<K,V>
- java.lang.Object
-
- java.util.AbstractCollection<O>
-
- org.infinispan.commands.read.AbstractCloseableIteratorCollection<K,K,V>
-
- org.infinispan.interceptors.distribution.DistributionBulkInterceptor.BackingKeySet<K,V>
-
- All Implemented Interfaces:
Iterable<K>
,Collection<K>
,Set<K>
,CacheCollection<K>
,CacheSet<K>
,org.infinispan.commons.util.CloseableIteratorCollection<K>
,org.infinispan.commons.util.CloseableIteratorSet<K>
- Enclosing class:
- DistributionBulkInterceptor<K,V>
protected static class DistributionBulkInterceptor.BackingKeySet<K,V> extends org.infinispan.commands.read.AbstractCloseableIteratorCollection<K,K,V> implements CacheSet<K>
-
-
Field Summary
Fields Modifier and Type Field Description protected FlagAffectedCommand
command
protected CacheSet<K>
keySet
-
Constructor Summary
Constructors Constructor Description BackingKeySet(Cache<K,V> cache, CacheSet<K> keySet, FlagAffectedCommand command)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
contains(Object o)
org.infinispan.commons.util.CloseableIterator<K>
iterator()
CacheStream<K>
parallelStream()
boolean
remove(Object o)
org.infinispan.commons.util.CloseableSpliterator<K>
spliterator()
CacheStream<K>
stream()
-
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
-
-
-
-
Field Detail
-
command
protected final FlagAffectedCommand command
-
-
Method Detail
-
iterator
public org.infinispan.commons.util.CloseableIterator<K> iterator()
Description copied from interface:org.infinispan.commons.util.CloseableIteratorCollection
This iterator should be explicitly closed when iteration upon it is completed. Failure to do so could cause resources to not be freed properly
- Specified by:
iterator
in interfaceorg.infinispan.commons.util.CloseableIteratorCollection<K>
- Specified by:
iterator
in interfaceCollection<K>
- Specified by:
iterator
in interfaceIterable<K>
- Specified by:
iterator
in interfaceSet<K>
- Specified by:
iterator
in classorg.infinispan.commands.read.AbstractCloseableIteratorCollection<K,K,V>
-
contains
public boolean contains(Object o)
-
remove
public boolean remove(Object o)
-
spliterator
public org.infinispan.commons.util.CloseableSpliterator<K> spliterator()
Description copied from interface:org.infinispan.commons.util.CloseableIteratorCollection
This spliterator should be explicitly closed after it has been used. Failure to do so could cause resources to not be freed properly
- Specified by:
spliterator
in interfaceorg.infinispan.commons.util.CloseableIteratorCollection<K>
- Specified by:
spliterator
in interfaceorg.infinispan.commons.util.CloseableIteratorSet<K>
- Specified by:
spliterator
in interfaceCollection<K>
- Specified by:
spliterator
in interfaceIterable<K>
- Specified by:
spliterator
in interfaceSet<K>
- Specified by:
spliterator
in classorg.infinispan.commands.read.AbstractCloseableIteratorCollection<K,K,V>
-
stream
public CacheStream<K> 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>
-
parallelStream
public CacheStream<K> 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>
-
-