Package org.infinispan.container.impl

Class InternalDataContainerAdapter<K,V>

java.lang.Object

org.infinispan.container.impl.AbstractDelegatingDataContainer<K,V>

org.infinispan.container.impl.InternalDataContainerAdapter<K,V>

All Implemented Interfaces:

Iterable<InternalCacheEntry<K,V>>, DataContainer<K,V>, InternalDataContainer<K,V>

public class InternalDataContainerAdapter<K,V>
extends AbstractDelegatingDataContainer<K,V>
implements InternalDataContainer<K,V>

Wrapper around a DataContainer to provide operations for use with a InternalDataContainer. Single key operations have the same performance semantics. However bulk operations that operate on a subset of segments, such as iterator(IntSet) and spliterator(IntSet) require filtering out entries via segment using the provided KeyPartitioner to determine the segments the key belongs to.

Since:

9.3

Author:

wburns

Nested Class Summary

Nested classes/interfaces inherited from interface org.infinispan.container.DataContainer

DataContainer.ComputeAction<K,V>

Field Summary

Fields

Modifier and Type	Field	Description
protected List<Consumer<Iterable<InternalCacheEntry<K,V>>>>	listeners

Constructor Summary

Constructors

Constructor	Description
InternalDataContainerAdapter(DataContainer<K,V> container)

Method Summary

Modifier and Type	Method	Description
void	addRemovalListener(Consumer<Iterable<InternalCacheEntry<K,V>>> listener)	Adds a listener that is invoked whenever InternalDataContainer.removeSegments(IntSet) is invoked providing a way for the listener to see what actual entries were removed from the container.
void	addSegments(org.infinispan.commons.util.IntSet segments)	Sets what segments this data container should be using.
void	clear(org.infinispan.commons.util.IntSet segments)	Removes entries from the container whose key maps to one of the provided segments
InternalCacheEntry<K,V>	compute(int segment, K key, DataContainer.ComputeAction<K,V> action)	Same as DataContainer.compute(Object, ComputeAction) except that the segment of the key can provided to update entries without calculating the segment for the given key.
boolean	containsKey(int segment, Object k)	Same as DataContainer.containsKey(Object) except that the segment of the key can provided to lookup if the entry exists without calculating the segment for the given key.
DataContainer<K,V>	delegate()
void	evict(int segment, K key)	Same as DataContainer.evict(Object) except that the segment of the key can provided to remove the entry without calculating the segment for the given key.
InternalCacheEntry<K,V>	get(int segment, Object k)	Same as DataContainer.get(Object) except that the segment of the key can provided to lookup entries without calculating the segment for the given key
Iterator<InternalCacheEntry<K,V>>	iterator(org.infinispan.commons.util.IntSet segments)	Same as DataContainer.iterator() except that only entries that map to the provided segments are returned via the iterator.
Iterator<InternalCacheEntry<K,V>>	iteratorIncludingExpired(org.infinispan.commons.util.IntSet segments)	Same as DataContainer.iteratorIncludingExpired() except that only entries that map to the provided segments are returned via the iterator.
InternalCacheEntry<K,V>	peek(int segment, Object k)	Same as DataContainer.peek(Object) except that the segment of the key can provided to lookup entries without calculating the segment for the given key
void	put(int segment, K k, V v, Metadata metadata, long createdTimestamp, long lastUseTimestamp)	Same as DataContainer.put(Object, Object, Metadata) except that the segment of the key can provided to write/lookup entries without calculating the segment for the given key.
InternalCacheEntry<K,V>	remove(int segment, Object k)	Same as DataContainer.remove(Object) except that the segment of the key can provided to remove the entry without calculating the segment for the given key.
void	removeRemovalListener(Object listener)	Removes a previously registered listener via InternalDataContainer.addRemovalListener(Consumer).
static <K,V> void	removeSegmentEntries(DataContainer<K,V> dataContainer, org.infinispan.commons.util.IntSet segments, List<Consumer<Iterable<InternalCacheEntry<K,V>>>> listeners, KeyPartitioner keyPartitioner)
void	removeSegments(org.infinispan.commons.util.IntSet segments)	Removes and un-associates the given segments.
Spliterator<InternalCacheEntry<K,V>>	spliterator(org.infinispan.commons.util.IntSet segments)	Same as DataContainer.spliterator() except that only entries that map to the provided segments are returned via this spliterator.
Spliterator<InternalCacheEntry<K,V>>	spliteratorIncludingExpired(org.infinispan.commons.util.IntSet segments)	Same as DataContainer.spliteratorIncludingExpired() except that only entries that map to the provided segments are returned via this spliterator.
boolean	touch(int segment, Object k, long currentTimeMillis)	Touches an entry in the data container.

Methods inherited from class org.infinispan.container.impl.AbstractDelegatingDataContainer

capacity, clear, compute, containsKey, entrySet, evict, evictionSize, executeTask, executeTask, forEach, get, iterator, iteratorIncludingExpired, keySet, peek, put, remove, resize, size, sizeIncludingExpired, spliterator, spliteratorIncludingExpired, values

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.infinispan.container.DataContainer

capacity, clear, compute, containsKey, entrySet, evict, evictionSize, executeTask, executeTask, iterator, iteratorIncludingExpired, keySet, peek, put, remove, resize, size, sizeIncludingExpired, spliterator, spliteratorIncludingExpired, values

Methods inherited from interface org.infinispan.container.impl.InternalDataContainer

forEach, get, size, sizeIncludingExpired

Methods inherited from interface java.lang.Iterable

forEach

Field Detail

listeners

protected final List<Consumer<Iterable<InternalCacheEntry<K,V>>>> listeners

Constructor Detail

InternalDataContainerAdapter

public InternalDataContainerAdapter(DataContainer<K,V> container)

Method Detail

delegate

public DataContainer<K,V> delegate()

get

public InternalCacheEntry<K,V> get(int segment,
                                         Object k)

Description copied from interface: InternalDataContainer

Same as DataContainer.get(Object) except that the segment of the key can provided to lookup entries without calculating the segment for the given key

Specified by:

get in interface InternalDataContainer<K,V>

Parameters:

segment - segment for the key

k - key under which entry is stored

Returns:

entry, if it exists and has not expired, or null if not

peek

public InternalCacheEntry<K,V> peek(int segment,
                                          Object k)

Description copied from interface: InternalDataContainer

Same as DataContainer.peek(Object) except that the segment of the key can provided to lookup entries without calculating the segment for the given key

Specified by:

peek in interface InternalDataContainer<K,V>

Parameters:

segment - segment for the key

k - key under which entry is stored

Returns:

entry, if it exists, or null if not

touch

public boolean touch(int segment,
                     Object k,
                     long currentTimeMillis)

Description copied from interface: InternalDataContainer

Touches an entry in the data container. This will update the last access time of the entry as well as count this as a access for eviction based recency.

Specified by:

touch in interface InternalDataContainer<K,V>

Parameters:

segment - segment for the key

k - key under which entry is stored

currentTimeMillis - the current time in milliseconds to touch the entry with

Returns:

true if the entry timestamp was touched

put

public void put(int segment,
                K k,
                V v,
                Metadata metadata,
                long createdTimestamp,
                long lastUseTimestamp)

Description copied from interface: InternalDataContainer

Same as DataContainer.put(Object, Object, Metadata) except that the segment of the key can provided to write/lookup entries without calculating the segment for the given key.

Note: The timestamps ignored if the entry already exists in the data container.

Specified by:

put in interface InternalDataContainer<K,V>

Parameters:

segment - segment for the key

k - key under which to store entry

v - value to store

metadata - metadata of the entry

createdTimestamp - creation timestamp, or -1 to use the current time

lastUseTimestamp - last use timestamp, or -1 to use the current time

containsKey

public boolean containsKey(int segment,
                           Object k)

Description copied from interface: InternalDataContainer

Same as DataContainer.containsKey(Object) except that the segment of the key can provided to lookup if the entry exists without calculating the segment for the given key.

Specified by:

containsKey in interface InternalDataContainer<K,V>

Parameters:

segment - segment for the key

k - key under which entry is stored

Returns:

true if entry exists and has not expired; false otherwise

remove

public InternalCacheEntry<K,V> remove(int segment,
                                            Object k)

Description copied from interface: InternalDataContainer

Same as DataContainer.remove(Object) except that the segment of the key can provided to remove the entry without calculating the segment for the given key.

Specified by:

remove in interface InternalDataContainer<K,V>

Parameters:

segment - segment for the key

k - key to remove

Returns:

entry removed, or null if it didn't exist or had expired

evict

public void evict(int segment,
                  K key)

Description copied from interface: InternalDataContainer

Same as DataContainer.evict(Object) except that the segment of the key can provided to remove the entry without calculating the segment for the given key.

Specified by:

evict in interface InternalDataContainer<K,V>

Parameters:

segment - segment for the key

key - The key to evict.

compute

public InternalCacheEntry<K,V> compute(int segment,
                                             K key,
                                             DataContainer.ComputeAction<K,V> action)

Description copied from interface: InternalDataContainer

Same as DataContainer.compute(Object, ComputeAction) except that the segment of the key can provided to update entries without calculating the segment for the given key.

Specified by:

compute in interface InternalDataContainer<K,V>

Parameters:

segment - segment for the key

key - The key.

action - The action that will compute the new value.

Returns:

The InternalCacheEntry associated to the key.

spliterator

public Spliterator<InternalCacheEntry<K,V>> spliterator(org.infinispan.commons.util.IntSet segments)

Description copied from interface: InternalDataContainer

Same as DataContainer.spliterator() except that only entries that map to the provided segments are returned via this spliterator. The spliterator will not return expired entries.

Specified by:

spliterator in interface InternalDataContainer<K,V>

Parameters:

segments - segments of entries to return

Returns:

spliterator containing entries mapping to those segments that aren't expired

spliteratorIncludingExpired

public Spliterator<InternalCacheEntry<K,V>> spliteratorIncludingExpired(org.infinispan.commons.util.IntSet segments)

Description copied from interface: InternalDataContainer

Same as DataContainer.spliteratorIncludingExpired() except that only entries that map to the provided segments are returned via this spliterator. The spliterator will return expired entries as well.

Specified by:

spliteratorIncludingExpired in interface InternalDataContainer<K,V>

Parameters:

segments - segments of entries to use

Returns:

spliterator containing entries mapping to those segments that could be expired

iterator

public Iterator<InternalCacheEntry<K,V>> iterator(org.infinispan.commons.util.IntSet segments)

Description copied from interface: InternalDataContainer

Same as DataContainer.iterator() except that only entries that map to the provided segments are returned via the iterator. The iterator will not return expired entries.

Specified by:

iterator in interface InternalDataContainer<K,V>

Parameters:

segments - segments of entries to use

Returns:

iterator that returns all entries mapped to the given segments

iteratorIncludingExpired

public Iterator<InternalCacheEntry<K,V>> iteratorIncludingExpired(org.infinispan.commons.util.IntSet segments)

Description copied from interface: InternalDataContainer

Same as DataContainer.iteratorIncludingExpired() except that only entries that map to the provided segments are returned via the iterator. The iterator can return expired entries.

Specified by:

iteratorIncludingExpired in interface InternalDataContainer<K,V>

Parameters:

segments - segments of entries to use

Returns:

iterator that returns all entries mapped to the given segments that could be expired

clear

public void clear(org.infinispan.commons.util.IntSet segments)

Description copied from interface: InternalDataContainer

Removes entries from the container whose key maps to one of the provided segments

Specified by:

clear in interface InternalDataContainer<K,V>

Parameters:

segments - segments of entries to remove

addSegments

public void addSegments(org.infinispan.commons.util.IntSet segments)

Description copied from interface: InternalDataContainer

Sets what segments this data container should be using. Already associated segments are unaffected by this and takes a union of existing and new segments.

Specified by:

addSegments in interface InternalDataContainer<K,V>

Parameters:

segments - segments to associate with this container

removeSegments

public void removeSegments(org.infinispan.commons.util.IntSet segments)

Description copied from interface: InternalDataContainer

Removes and un-associates the given segments. This will notify any listeners registered via InternalDataContainer.addRemovalListener(Consumer) of entries that were removed due to no longer being associated with this container. There is no guarantee if the consumer is invoked once or multiple times for a given group of segments and could be in any order.

When this method is invoked an implementation is free to remove any entries that don't map to segments currently associated with this container. Note that entries that were removed due to their segments never being associated with this container do not notify listeners registered via InternalDataContainer.addRemovalListener(Consumer).

Specified by:

removeSegments in interface InternalDataContainer<K,V>

Parameters:

segments - segments that should no longer be associated with this container

removeSegmentEntries

public static <K,V> void removeSegmentEntries(DataContainer<K,V> dataContainer,
                                                    org.infinispan.commons.util.IntSet segments,
                                                    List<Consumer<Iterable<InternalCacheEntry<K,V>>>> listeners,
                                                    KeyPartitioner keyPartitioner)

addRemovalListener

public void addRemovalListener(Consumer<Iterable<InternalCacheEntry<K,V>>> listener)

Description copied from interface: InternalDataContainer

Adds a listener that is invoked whenever InternalDataContainer.removeSegments(IntSet) is invoked providing a way for the listener to see what actual entries were removed from the container.

Specified by:

addRemovalListener in interface InternalDataContainer<K,V>

Parameters:

listener - listener that invoked of removed entries

removeRemovalListener

public void removeRemovalListener(Object listener)

Description copied from interface: InternalDataContainer

Removes a previously registered listener via InternalDataContainer.addRemovalListener(Consumer).

Specified by:

removeRemovalListener in interface InternalDataContainer<K,V>

Parameters:

listener - the listener to remove