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 and 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 org.infinispan.CacheCollection

localPublisher, localPublisher

Methods inherited from interface java.util.Set

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

Methods inherited from interface java.util.Collection

removeIf

Methods inherited from interface java.lang.Iterable

forEach

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

Specified by:

stream in interface CacheCollection<CacheEntry<K,V>>

Specified by:

stream in interface CloseableIteratorCollection<CacheEntry<K,V>>

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

Specified by:

parallelStream in interface CacheCollection<CacheEntry<K,V>>

Specified by:

parallelStream in interface CloseableIteratorCollection<CacheEntry<K,V>>

Overrides:

parallelStream in class DistributionBulkInterceptor.BackingEntrySet<K,V>