Package | Description |
---|---|
org.infinispan |
This is the core of Infinispan, a distributed, transactional, highly scalable data grid
platform.
|
org.infinispan.cache.impl | |
org.infinispan.commands |
Commands that operate on the cache, either locally or remotely.
|
org.infinispan.container |
Data containers which store cache entries.
|
org.infinispan.filter |
Provides capabilities around filtering and converting entries that are found in the cache or cache store/loader.
|
org.infinispan.iteration.impl |
Provides Infinispan-specific implementation details iterating over entries in the cache, specifically optimized for
distributed caches.
|
org.infinispan.notifications.cachelistener.filter |
Cache -specific notifications and eventing filtering classes. |
org.infinispan.security.impl |
Modifier and Type | Method and Description |
---|---|
EntryIterable<K,V> |
AdvancedCache.filterEntries(KeyValueFilter<? super K,? super V> filter)
Deprecated.
Please use
Collection.stream() method on either Cache.entrySet() ,
Cache.keySet() or Cache.values() . The CacheFilters can be used to
bridge between filter/converters and proper stream types |
Modifier and Type | Method and Description |
---|---|
EntryIterable<K,V> |
CacheImpl.filterEntries(KeyValueFilter<? super K,? super V> filter) |
EntryIterable<K,V> |
AbstractDelegatingAdvancedCache.filterEntries(KeyValueFilter<? super K,? super V> filter) |
EntryIterable<K,V> |
DecoratedCache.filterEntries(KeyValueFilter<? super K,? super V> filter) |
EntryIterable<K,V> |
SimpleCacheImpl.filterEntries(KeyValueFilter<? super K,? super V> filter) |
protected EntryIterable<K,V> |
CacheImpl.filterEntries(KeyValueFilter<? super K,? super V> filter,
EnumSet<Flag> explicitFlags,
ClassLoader explicitClassLoader) |
Constructor and Description |
---|
FilteredEntryIterable(KeyValueFilter<? super K,? super V> filter) |
Modifier and Type | Method and Description |
---|---|
<K,V,C> EntryRequestCommand<K,V,C> |
CommandsFactory.buildEntryRequestCommand(UUID identifier,
Set<Integer> segments,
Set<K> keysToFilter,
KeyValueFilter<? super K,? super V> filter,
Converter<? super K,? super V,C> converter,
Set<Flag> flags)
Builds
EntryRequestCommand used to request entries from a remote node for
given segments |
<K,V,C> EntryRequestCommand<K,V,C> |
CommandsFactoryImpl.buildEntryRequestCommand(UUID identifier,
Set<Integer> segments,
Set<K> keysToFilter,
KeyValueFilter<? super K,? super V> filter,
Converter<? super K,? super V,C> converter,
Set<Flag> flags) |
Modifier and Type | Method and Description |
---|---|
void |
DataContainer.executeTask(KeyValueFilter<? super K,? super V> filter,
BiConsumer<? super K,InternalCacheEntry<K,V>> action)
Executes task specified by the given action on the container key/values filtered using the specified keyvalue filter.
|
void |
DefaultDataContainer.executeTask(KeyValueFilter<? super K,? super V> filter,
BiConsumer<? super K,InternalCacheEntry<K,V>> action) |
Modifier and Type | Interface and Description |
---|---|
interface |
KeyValueFilterConverter<K,V,C>
This interface is an optimization that can be used when a filter and converter are most efficiently used as the same
object composing the filtering and conversion in the same method invocation.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractKeyValueFilterConverter<K,V,C>
This is a base class that should be used when implementing a KeyValueFilterConverter that provides default
implementations for the
accept(Object, Object, org.infinispan.metadata.Metadata)
and Converter.convert(Object, Object, org.infinispan.metadata.Metadata) methods so they just call the
KeyValueFilterConverter.filterAndConvert(Object, Object, org.infinispan.metadata.Metadata)
method and then do the right thing. |
class |
AcceptAllKeyValueFilter
A key value filter that accepts all entries found.
|
class |
CompositeKeyValueFilter<K,V>
Allows AND-composing several key/value filters.
|
class |
KeyFilterAsKeyValueFilter<K,V>
KeyValueFilter that implements it's filtering solely on the use of the provided KeyFilter
|
Modifier and Type | Method and Description |
---|---|
static <K,V> Predicate<CacheEntry<K,V>> |
CacheFilters.predicate(KeyValueFilter<? super K,? super V> filter)
Creates a new
Predicate using the provided key value filter as a basis for the operation. |
Constructor and Description |
---|
CompositeKeyValueFilter(KeyValueFilter<? super K,? super V>... filters) |
KeyValueFilterAsKeyFilter(KeyValueFilter<? super K,?> filter) |
Modifier and Type | Field and Description |
---|---|
protected KeyValueFilter<? super K,? super V> |
TrackingEntryIterableFromStream.filter |
protected KeyValueFilter<? super K,? super V> |
TransactionAwareCloseableIterable.filter |
Modifier and Type | Method and Description |
---|---|
<C> CloseableIterator<CacheEntry<K,C>> |
EntryRetriever.retrieveEntries(KeyValueFilter<? super K,? super V> filter,
Converter<? super K,? super V,? extends C> converter,
Set<Flag> flags,
EntryRetriever.SegmentListener listener)
Deprecated.
This is invoked locally on the node that requested the iteration process.
|
<C> CloseableIterator<CacheEntry<K,C>> |
LocalEntryRetriever.retrieveEntries(KeyValueFilter<? super K,? super V> filter,
Converter<? super K,? super V,? extends C> converter,
Set<Flag> flags,
EntryRetriever.SegmentListener listener) |
<C> CloseableIterator<CacheEntry<K,C>> |
DistributedEntryRetriever.retrieveEntries(KeyValueFilter<? super K,? super V> filter,
Converter<? super K,? super V,? extends C> converter,
Set<Flag> flags,
EntryRetriever.SegmentListener listener) |
<C> void |
EntryRetriever.startRetrievingValues(UUID identifier,
Address origin,
Set<Integer> segments,
Set<K> keysToFilter,
KeyValueFilter<? super K,? super V> filter,
Converter<? super K,? super V,C> converter,
Set<Flag> flagss)
Deprecated.
This method is intended to be ran remotely on a node who has segments that the values have been requested.
|
<C> void |
LocalEntryRetriever.startRetrievingValues(UUID identifier,
Address origin,
Set<Integer> segments,
Set<K> keysToFilter,
KeyValueFilter<? super K,? super V> filter,
Converter<? super K,? super V,C> converter,
Set<Flag> flags) |
<C> void |
DistributedEntryRetriever.startRetrievingValues(UUID identifier,
Address origin,
Set<Integer> segments,
Set<K> keysToFilter,
KeyValueFilter<? super K,? super V> filter,
Converter<? super K,? super V,C> converter,
Set<Flag> flags) |
protected <C> void |
LocalEntryRetriever.wireFilterAndConverterDependencies(KeyValueFilter<? super K,? super V> filter,
Converter<? super K,? super V,C> converter) |
Constructor and Description |
---|
DataContainerIterator(Iterator<InternalCacheEntry<K,V>> iterator,
KeyValueFilter<? super K,? super V> filter,
Converter<? super K,? super V,? extends C> converter,
boolean filterAndConvert) |
EntryIterableFromStreamImpl(KeyValueFilter<? super K,? super V> filter,
EnumSet<Flag> flags,
Cache<K,V> cache) |
EntryRequestCommand(String cacheName,
UUID identifier,
Address origin,
Set<Integer> segments,
Set<K> keysToFilter,
KeyValueFilter<? super K,? super V> filter,
Converter<? super K,? super V,C> converter,
Set<Flag> flags) |
TrackingEntryIterableFromStream(KeyValueFilter<? super K,? super V> filter,
Converter<? super K,? super V,C> converter,
EnumSet<Flag> flags,
Cache<K,V> cache) |
TransactionAwareCloseableIterable(CloseableIterable<CacheEntry<K,C>> iterable,
KeyValueFilter<? super K,? super V> filter,
Converter<? super K,? super V,? extends C> converter,
TxInvocationContext<LocalTransaction> ctx,
Cache<K,?> cache) |
TransactionAwareCloseableIterator(CloseableIterator<CacheEntry<K,V>> realIterator,
KeyValueFilter<? super K,? super V> filter,
Converter<? super K,? super V,? extends C> converter,
TxInvocationContext<LocalTransaction> ctx,
Cache<K,V> cache) |
TransactionAwareEntryIterable(EntryIterable<K,V> entryIterable,
KeyValueFilter<? super K,? super V> filter,
TxInvocationContext<LocalTransaction> ctx,
Cache<K,V> cache) |
Modifier and Type | Class and Description |
---|---|
class |
CacheEventFilterAsKeyValueFilter<K,V>
KeyValueFilter that is implemented by using the provided CacheEventFilter.
|
class |
CacheEventFilterConverterAsKeyValueFilterConverter<K,V,C> |
Constructor and Description |
---|
KeyValueFilterAsCacheEventFilter(KeyValueFilter<? super K,? super V> filter) |
Modifier and Type | Method and Description |
---|---|
EntryIterable<K,V> |
SecureCacheImpl.filterEntries(KeyValueFilter<? super K,? super V> filter) |
Copyright © 2024 JBoss, a division of Red Hat. All rights reserved.