Package org.infinispan.interceptors.distribution

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>>, CloseableIteratorCollection<CacheEntry<K,V>>, 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

Fields inherited from class org.infinispan.commands.read.AbstractCloseableIteratorCollection

cache

Method Summary

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

Methods inherited from interface java.lang.Iterable

forEach

Methods inherited from interface java.util.Set

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

Method Detail

stream

public CacheStream<CacheEntry<K,V>> 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 CacheCollection<K>

Specified by:

stream in interface CloseableIteratorCollection<K>

Specified by:

stream in interface Collection<K>

Overrides:

stream in class DistributionBulkInterceptor.BackingEntrySet<K,V>

parallelStream

public CacheStream<CacheEntry<K,V>> 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 CacheCollection<K>

Specified by:

parallelStream in interface CloseableIteratorCollection<K>

Specified by:

parallelStream in interface Collection<K>

Overrides:

parallelStream in class DistributionBulkInterceptor.BackingEntrySet<K,V>