Package | Description |
---|---|
org.infinispan.cache.impl | |
org.infinispan.commands |
Commands that operate on the cache, either locally or remotely.
|
org.infinispan.filter |
Provides capabilities around filtering and converting entries that are found in the cache or cache store/loader.
|
org.infinispan.iteration |
Provides Infinispan-specific utilities for iterating over entries in the cache, specifically optimized for
distributed caches.
|
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. |
Modifier and Type | Method and Description |
---|---|
<C> CloseableIterable<CacheEntry<K,C>> |
SimpleCacheImpl.FilteredEntryIterable.converter(Converter<? super K,? super V,C> converter) |
Constructor and Description |
---|
ConvertedIterable(Iterator<CacheEntry<K,V>> iterator,
Converter<? super K,? super V,? extends C> converter) |
Modifier and Type | Method and Description |
---|---|
<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) |
<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 |
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
KeyValueFilter.accept(Object, Object, org.infinispan.metadata.Metadata)
and 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 |
NullValueConverter
Converter that returns null for the value.
|
Modifier and Type | Method and Description |
---|---|
static <K,V,C> Function<CacheEntry<K,V>,CacheEntry<K,C>> |
CacheFilters.function(Converter<? super K,? super V,C> converter)
Creates a new
Function using the provided converter as a basis for the operation. |
Modifier and Type | Method and Description |
---|---|
<C> CloseableIterable<CacheEntry<K,C>> |
EntryIterable.converter(Converter<? super K,? super V,C> converter)
This returns a
CloseableIterable that will change the type of the returned
value for the entry using the already provided filter in addition to the converter. |
Modifier and Type | Field and Description |
---|---|
protected Converter<? super K,? super V,C> |
TrackingEntryIterableFromStream.converter |
protected Converter<? super K,? super V,? extends C> |
TransactionAwareCloseableIterable.converter |
Modifier and Type | Method and Description |
---|---|
<C> CloseableIterable<CacheEntry<K,C>> |
EntryIterableFromStreamImpl.converter(Converter<? super K,? super V,C> converter) |
<C> CloseableIterable<CacheEntry<K,C>> |
TransactionAwareEntryIterable.converter(Converter<? super K,? super V,C> converter) |
<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> 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>> |
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> 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) |
<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 |
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.
|
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) |
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) |
Modifier and Type | Class and Description |
---|---|
class |
CacheEventConverterAsConverter<K,V,C>
Converter that is implemented by using the provided CacheEventConverter.
|
class |
CacheEventFilterConverterAsKeyValueFilterConverter<K,V,C> |
Constructor and Description |
---|
ConverterAsCacheEventConverter(Converter<K,V,C> converter) |
Copyright © 2021 JBoss, a division of Red Hat. All rights reserved.