Package org.infinispan.cache.impl

Class AbstractCacheBackedSet<K,V,E>

java.lang.Object

org.infinispan.cache.impl.AbstractCacheBackedSet<K,V,E>

All Implemented Interfaces:

Iterable<E>, Collection<E>, Set<E>, CacheCollection<E>, CacheSet<E>, CloseableIteratorCollection<E>, CloseableIteratorSet<E>

Direct Known Subclasses:

CacheBackedEntrySet, CacheBackedKeySet

public abstract class AbstractCacheBackedSet<K,V,E>
extends Object
implements CacheSet<E>

Entry or key set backed by a cache.

Since:

13.0

Field Summary

Fields

Modifier and Type	Field	Description
protected final CacheImpl<K,V>	cache
protected final long	explicitFlags
protected final Object	lockOwner

Constructor Summary

Constructors

Constructor	Description
AbstractCacheBackedSet(CacheImpl<K,V> cache, Object lockOwner, long explicitFlags)

Method Summary

Modifier and Type	Method	Description
boolean	add(E e)	Adding new cache entries via a set is not allowed.
boolean	addAll(Collection<? extends E> c)	Adding new cache entries via a set is not allowed.
void	clear()
abstract boolean	contains(Object o)
boolean	containsAll(Collection<?> c)
protected ContextBuilder	decoratedWriteContextBuilder()
protected abstract Function<Map.Entry<K,V>,?>	entryToKeyFunction()
protected abstract Object	extractKey(Object e)	Extract the key from a set element.
void	forEach(Consumer<? super E> action)
boolean	isEmpty()
CloseableIterator<E>	iterator()
CacheStream<E>	parallelStream()
boolean	remove(Object o)
boolean	removeAll(Collection<?> c)
boolean	removeIf(Predicate<? super E> filter)
boolean	retainAll(Collection<?> c)
int	size()
CloseableSpliterator<E>	spliterator()
CacheStream<E>	stream()
Object[]	toArray()
<T> T[]	toArray(T[] a)
String	toString()
protected abstract E	wrapElement(E e)	Wrap the element if needed

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.Collection

toArray

Methods inherited from interface java.util.Set

equals, hashCode

Field Details

cache

protected final CacheImpl<K,V> cache

lockOwner

protected final Object lockOwner

explicitFlags

protected final long explicitFlags

Constructor Details

AbstractCacheBackedSet

public AbstractCacheBackedSet(CacheImpl<K,V> cache,
 Object lockOwner,
 long explicitFlags)

Method Details

size

public int size()

Specified by:

size in interface Collection<K>

Specified by:

size in interface Set<K>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface Collection<K>

Specified by:

isEmpty in interface Set<K>

contains

public abstract boolean contains(Object o)

Specified by:

contains in interface Collection<K>

Specified by:

contains in interface Set<K>

iterator

public CloseableIterator<E> iterator()

Description copied from interface: 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 interface CloseableIteratorCollection<K>

Specified by:

iterator in interface Collection<K>

Specified by:

iterator in interface Iterable<K>

Specified by:

iterator in interface Set<K>

forEach

public void forEach(Consumer<? super E> action)

Specified by:

forEach in interface Iterable<K>

toArray

public Object[] toArray()

Specified by:

toArray in interface Collection<K>

Specified by:

toArray in interface Set<K>

toArray

public <T> T[] toArray(T[] a)

Specified by:

toArray in interface Collection<K>

Specified by:

toArray in interface Set<K>

add

public boolean add(E e)

Adding new cache entries via a set is not allowed.

Please use BasicCache.put(Object, Object) etc.

Specified by:

add in interface Collection<K>

Specified by:

add in interface Set<K>

remove

public boolean remove(Object o)

Specified by:

remove in interface Collection<K>

Specified by:

remove in interface Set<K>

containsAll

public boolean containsAll(Collection<?> c)

Specified by:

containsAll in interface Collection<K>

Specified by:

containsAll in interface Set<K>

addAll

public boolean addAll(Collection<? extends E> c)

Adding new cache entries via a set is not allowed.

Please use BasicCache.put(Object, Object) etc.

Specified by:

addAll in interface Collection<K>

Specified by:

addAll in interface Set<K>

removeAll

public boolean removeAll(Collection<?> c)

Specified by:

removeAll in interface Collection<K>

Specified by:

removeAll in interface Set<K>

removeIf

public boolean removeIf(Predicate<? super E> filter)

Specified by:

removeIf in interface Collection<K>

retainAll

public boolean retainAll(Collection<?> c)

Specified by:

retainAll in interface Collection<K>

Specified by:

retainAll in interface Set<K>

clear

public void clear()

Specified by:

clear in interface Collection<K>

Specified by:

clear in interface Set<K>

spliterator

public CloseableSpliterator<E> spliterator()

Description copied from interface: 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 interface CloseableIteratorCollection<K>

Specified by:

spliterator in interface CloseableIteratorSet<K>

Specified by:

spliterator in interface Collection<K>

Specified by:

spliterator in interface Iterable<K>

Specified by:

spliterator in interface Set<K>

stream

public 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 CacheCollection<K>

Specified by:

stream in interface CloseableIteratorCollection<K>

Specified by:

stream in interface Collection<K>

parallelStream

public 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 CacheCollection<K>

Specified by:

parallelStream in interface CloseableIteratorCollection<K>

Specified by:

parallelStream in interface Collection<K>

toString

public String toString()

Overrides:

toString in class Object

decoratedWriteContextBuilder

protected ContextBuilder decoratedWriteContextBuilder()

entryToKeyFunction

protected abstract Function<Map.Entry<K,V>,?> entryToKeyFunction()

extractKey

protected abstract Object extractKey(Object e)

Extract the key from a set element.

wrapElement

protected abstract E wrapElement(E e)

Wrap the element if needed