Package | Description |
---|---|
com.tangosol.coherence.config.builder |
Defines the typical runtime configuration builders for the Coherence configuration object model.
|
com.tangosol.coherence.config.xml.processor |
Defines the Xml document Element and Attribute Processors for Coherence Cache Configuration files.
|
com.tangosol.coherence.dslquery | |
com.tangosol.coherence.dslquery.operator |
This package contains implementations of the
com.tangosol.coherence.dslquery.BaseOperator interface. |
com.tangosol.coherence.dslquery.statement |
This package contains
StatementBuilder implementations and com.tangosol.coherence.dslquery.CohQLStatement implementations. |
com.tangosol.coherence.jcache.common |
Common utilities used by Coherence JCache.
|
com.tangosol.coherence.jcache.localcache |
Contains classes related to local cache implementation of Coherence JCache.
|
com.tangosol.coherence.jcache.partitionedcache |
Contains classes related to partitioned cache implementation of Coherence JCache.
|
com.tangosol.coherence.jcache.passthroughcache |
Contains classes related to pass-through cache implementation of Coherence JCache.
|
com.tangosol.coherence.servlet |
Contains classes related to the HTTP Session Replication Module.
|
com.tangosol.coherence.transaction |
Contains classes related to the Coherence Transaction Framework.
|
com.tangosol.net |
Contains basic cluster interfaces and factories.
|
com.tangosol.net.cache |
Contains classes providing various caching strategies.
|
com.tangosol.net.management |
Contains classes related to the Coherence Management Framework.
|
com.tangosol.net.partition |
Contains interfaces and classes related to partitioned services.
|
com.tangosol.util |
Contains various generic utilities.
|
com.tangosol.util.aggregator |
Contains concrete
InvocableMap.EntryAggregator implementations. |
com.tangosol.util.extractor |
Contains
ValueExtractor and ValueUpdater related classes. |
com.tangosol.util.filter |
Contains concrete
Filter implementations and related interfaces. |
com.tangosol.util.processor |
Contains concrete
InvocableMap.EntryProcessor implementations. |
Modifier and Type | Method and Description |
---|---|
Filter |
InetAddressRangeFilterBuilder.realize(com.tangosol.config.expression.ParameterResolver resolver, ClassLoader loader, ParameterList listParameters) |
Modifier and Type | Method and Description |
---|---|
ParameterizedBuilder<Filter> |
AuthorizedHostsProcessor.process(ProcessingContext context, XmlElement xmlElement)
Process an
XmlElement to return a specific type of value. |
Modifier and Type | Method and Description |
---|---|
Filter |
FilterBuilder.makeFilter()
Make a new Filter from the set AST.
|
Filter |
FilterBuilder.makeFilter(Term term)
Make a new Filter from the given AST.
|
Filter |
FilterBuilder.makeFilter(Term term, List listBindVars, com.tangosol.config.expression.ParameterResolver namedBindVars)
Make a new Filter from the given AST using the given bind variables.
|
Filter |
FilterBuilder.makeFilter(Term term, Object[] aoIndexedBindVars)
Make a new Filter from the given AST using given array for Bind vars.
|
Filter |
FilterBuilder.makeFilter(Term term, Object[] aoIndexedBindVars, Map mapNamedBindVars)
Make a new Filter from the given AST using the given bind variables.
|
Filter |
FilterBuilder.makeFilterForCache(String sCacheName, Term term, List indexedBindVars, com.tangosol.config.expression.ParameterResolver namedBindVars)
Make a new Filter from the given AST using given array for Bind vars.
|
Modifier and Type | Class and Description |
---|---|
class |
BaseOperator<F extends Filter>
A base class for CohQL Operator implementations.
|
Modifier and Type | Method and Description |
---|---|
Filter |
InOperator.makeFilter(Object oLeft, Object oRight) |
Filter |
XorOperator.makeFilter(Object oLeft, Object oRight) |
Modifier and Type | Method and Description |
---|---|
protected void |
AndOperator.populateFilterArray(Filter[] aFilterDest, Filter... aFilterSrc)
Populate the specified target
Filter array with the Filters in the source array. |
protected void |
AndOperator.populateFilterArray(Filter[] aFilterDest, Filter... aFilterSrc)
Populate the specified target
Filter array with the Filters in the source array. |
protected void |
OrOperator.populateFilterArray(Filter[] aFilterDest, Filter... aFilterSrc)
Populate the specified target
Filter array with the Filters in the source array. |
protected void |
OrOperator.populateFilterArray(Filter[] aFilterDest, Filter... aFilterSrc)
Populate the specified target
Filter array with the Filters in the source array. |
Modifier and Type | Field and Description |
---|---|
protected Filter |
DeleteStatementBuilder.DeleteStatement.f_filter
The
Filter to be used in the CohQL "delete" command. |
protected Filter |
QueryRecorderStatementBuilder.QueryRecorderStatement.f_filter
The
Filter to be explained or traced. |
protected Filter |
SelectStatementBuilder.SelectStatement.f_filter
The
Filter to use in the query. |
protected Filter |
UpdateStatementBuilder.UpdateStatement.f_filter
The
Filter that will be used to select entries to be updated. |
Modifier and Type | Method and Description |
---|---|
protected static Filter |
AbstractStatementBuilder.ensureFilter(NodeTerm termWhere, String sCacheName, String sAlias, List listBindVars, com.tangosol.config.expression.ParameterResolver namedBindVars, ExecutionContext ctx)
Build a
Filter for the given cache using the given where clause, alias and bind environments. |
Filter |
SelectStatementBuilder.SelectStatement.getFilter()
Return the
Filter to use to execute this query. |
Constructor and Description |
---|
DeleteStatement(String sCacheName, Filter filter)
Create an instance of
DeleteStatementBuilder.DeleteStatement that will delete all entries from the specified cache that match the given Filter . |
QueryRecorderStatement(String sCacheName, Filter filter, QueryRecorder.RecordType type)
Construct a QueryRecorderStatement that produces a plan or trace of the specified filter query against the specified cache.
|
SelectStatement(String sCache, Filter filter, InvocableMap.EntryAggregator aggregator, boolean fReduction)
Construct a SelectStatement that will query the specified cache.
|
UpdateStatement(String sCache, Filter filter, InvocableMap.EntryProcessor processor)
Construct a UpdateStatement that will update the specified cache.
|
Modifier and Type | Class and Description |
---|---|
class |
NonSyntheticEntryFilter<T>
Server side filter to filter out both coherence and jcache synthetic events.
|
Modifier and Type | Class and Description |
---|---|
static class |
LocalCacheAsynchronousMapListener.NonSyntheticEntryFilter
Server side filter to filter out both coherence and jcache synthetic events.
|
Modifier and Type | Class and Description |
---|---|
static class |
PartitionedCacheAsynchronousMapListener.NonSyntheticEntryFilter
NonSyntheticEntryFilter
|
static class |
PartitionedCacheSyntheticDeleteMapListener.JCacheExpiryEntryFilter<T>
Server side filter for JCache ExpiryCacheEvents.
|
Modifier and Type | Class and Description |
---|---|
class |
PassThroughFilterAdapter<K,V>
|
Modifier and Type | Field and Description |
---|---|
static Filter |
SessionHelper.NAME_FILTER
The Filter object that hides init param names for Coherence params.
|
Modifier and Type | Method and Description |
---|---|
Filter |
SessionExpiryFilterFactory.createSessionExpiryFilter(Filter baseFilter)
Creates a new session expiry filter.
|
protected Filter |
AbstractHttpSessionCollection.getSessionExpiryFilter()
Generates a session expiry filter based on the configured factories.
|
Modifier and Type | Method and Description |
---|---|
Filter |
SessionExpiryFilterFactory.createSessionExpiryFilter(Filter baseFilter)
Creates a new session expiry filter.
|
Modifier and Type | Method and Description |
---|---|
void |
OptimisticNamedCache.delete(Object oKey, Filter validator)
Delete an existing value.
|
void |
OptimisticNamedCache.update(Object oKey, Object oValue, Filter validator)
Update an existing value.
|
Modifier and Type | Class and Description |
---|---|
static class |
InetAddressHelper.RoutableFilter
The RoutableFilter evaluates to true for any InetAddress which is externally routable.
|
static class |
InetAddressHelper.SubnetMaskFilter
SubnetMaskFilter evaluates to true for any address with matches the pattern for the masked bits
|
Modifier and Type | Method and Description |
---|---|
Filter |
ClusterDependencies.getAuthorizedHostFilter()
Obtain the filter that is used by the cluster to determine whether to accept a new Cluster member.
|
Modifier and Type | Method and Description |
---|---|
<R> CompletableFuture<R> |
AsyncNamedCache.aggregate(Filter filter, InvocableMap.EntryAggregator<? super K,? super V,R> aggregator)
Perform an aggregating operation asynchronously against the set of entries that are selected by the given Filter.
|
default CompletableFuture<Set<Map.Entry<K,V>>> |
AsyncNamedCache.entrySet(Filter filter)
Return a set view of the entries contained in this map that satisfy the criteria expressed by the filter.
|
default CompletableFuture<Void> |
AsyncNamedCache.entrySet(Filter filter, BiConsumer<? super K,? super V> callback)
Stream the entries that satisfy the specified filter to the provided callback.
|
default CompletableFuture<Set<Map.Entry<K,V>>> |
AsyncNamedCache.entrySet(Filter filter, Comparator comparator)
Return a set view of the entries contained in this map that satisfy the criteria expressed by the filter.
|
default CompletableFuture<Void> |
AsyncNamedCache.entrySet(Filter filter, Consumer<? super Map.Entry<? extends K,? extends V>> callback)
Stream the entries that satisfy the specified filter to the provided callback.
|
default CompletableFuture<Map<K,V>> |
AsyncNamedCache.getAll(Filter filter)
Get all the entries that satisfy the specified filter.
|
static InetAddress |
InetAddressHelper.getLocalAddress(Filter filter)
Obtain the "best" local host address which matches the supplied filter.
|
<R> CompletableFuture<Map<K,R>> |
AsyncNamedCache.invokeAll(Filter filter, InvocableMap.EntryProcessor<K,V,R> processor)
Invoke the passed EntryProcessor against the set of entries that are selected by the given Filter asynchronously, returning a
CompletableFuture that can be used to obtain the result of the invocation for each entry. |
default <R> CompletableFuture<Void> |
AsyncNamedCache.invokeAll(Filter filter, InvocableMap.EntryProcessor<K,V,R> processor, BiConsumer<? super K,? super R> callback)
Invoke the passed EntryProcessor against the set of entries that are selected by the given Filter asynchronously, returning a
CompletableFuture that can be used to determine if the operation completed successfully. |
<R> CompletableFuture<Void> |
AsyncNamedCache.invokeAll(Filter filter, InvocableMap.EntryProcessor<K,V,R> processor, Consumer<? super Map.Entry<? extends K,? extends R>> callback)
Invoke the passed EntryProcessor against the set of entries that are selected by the given Filter asynchronously, returning a
CompletableFuture that can be used to determine if the operation completed successfully. |
default CompletableFuture<Set<K>> |
AsyncNamedCache.keySet(Filter filter)
Return a set view of the keys contained in this map for entries that satisfy the criteria expressed by the filter.
|
default CompletableFuture<Void> |
AsyncNamedCache.keySet(Filter filter, Consumer<? super K> callback)
Stream the keys for the entries that satisfy the specified filter to the provided callback.
|
default CompletableFuture<Void> |
AsyncNamedCache.removeAll(Filter filter)
Removes all of the mappings that satisfy the specified filter from this map.
|
default CompletableFuture<Map<K,Void>> |
AsyncNamedCache.replaceAll(Filter filter, Remote.BiFunction<? super K,? super V,? extends V> function)
Replace each entry's value with the result of invoking the given function on that entry until all entries selected by the specified filter have been processed or the function throws an exception.
|
default CompletableFuture<Collection<V>> |
AsyncNamedCache.values(Filter filter)
Return a collection of the values contained in this map that satisfy the criteria expressed by the filter.
|
default CompletableFuture<Collection<V>> |
AsyncNamedCache.values(Filter filter, Comparator<? super V> comparator)
Return a collection of the values contained in this map that satisfy the criteria expressed by the filter.
|
default CompletableFuture<Void> |
AsyncNamedCache.values(Filter filter, Consumer<? super V> callback)
Stream the values for the entries that satisfy the specified filter to the provided callback.
|
Modifier and Type | Class and Description |
---|---|
protected static class |
SimpleOverflowMap.FrontFilterConverter
A combination Filter and Converter used to iterate through the status map in order to iterate through the front keys.
|
Modifier and Type | Field and Description |
---|---|
protected Filter |
CachingMap.FrontMapListener.m_filter
The filter associated with this listener.
|
protected Filter |
ContinuousQueryCache.m_filter
The filter that represents the subset of information from the underlying NamedCache that this ContinuousQueryCache represents.
|
Modifier and Type | Method and Description |
---|---|
protected Filter |
ContinuousQueryCache.createTransformerFilter(MapEventFilter filterAdd)
Wrap specified MapEventFilter with a MapEventTransformerFilter that will either transform cache value using transformer defined for this ContinuousQueryCache, or remove the old value from the event using SemiLiteEventTransformer, if no transformer is defined for this CQC.
|
Filter |
ContinuousQueryCache.getFilter()
Obtain the Filter that this ContinuousQueryCache is using to query the underlying NamedCache.
|
protected Filter |
ContinuousQueryCache.mergeFilter(Filter filter)
Return a filter which merges the ContinuousQueueCache's filter with the supplied filter.
|
Modifier and Type | Method and Description |
---|---|
void |
ContinuousQueryCache.addMapListener(MapListener<? super K,? super V_FRONT> listener, Filter filter, boolean fLite)
Add a map listener that receives events based on a filter evaluation.
|
void |
NearCache.addMapListener(MapListener<? super K,? super V> listener, Filter filter, boolean fLite)
Add a map listener that receives events based on a filter evaluation.
|
void |
AbstractSerializationCache.addMapListener(MapListener listener, Filter filter, boolean fLite)
Add a map listener that receives events based on a filter evaluation.
|
void |
CompactSerializationCache.addMapListener(MapListener listener, Filter filter, boolean fLite)
Add a map listener that receives events based on a filter evaluation.
|
void |
OldCache.addMapListener(MapListener listener, Filter filter, boolean fLite)
Deprecated.
Add a map listener that receives events based on a filter evaluation.
|
void |
OverflowMap.addMapListener(MapListener listener, Filter filter, boolean fLite)
Add a map listener that receives events based on a filter evaluation.
|
void |
ReadWriteBackingMap.addMapListener(MapListener listener, Filter filter, boolean fLite)
Add a map listener that receives events based on a filter evaluation.
|
<R> R |
ContinuousQueryCache.aggregate(Filter filter, InvocableMap.EntryAggregator<? super K,? super V_FRONT,R> aggregator)
Perform an aggregating operation against the set of entries that are selected by the given Filter.
|
<R> R |
NearCache.aggregate(Filter filter, InvocableMap.EntryAggregator<? super K,? super V,R> aggregator)
Perform an aggregating operation against the set of entries that are selected by the given Filter.
|
<R> R |
WrapperNamedCache.aggregate(Filter filter, InvocableMap.EntryAggregator<? super K,? super V,R> agent)
Perform an aggregating operation against the set of entries that are selected by the given Filter.
|
Set<Map.Entry<K,V_FRONT>> |
ContinuousQueryCache.entrySet(Filter filter)
Return a set view of the entries contained in this map that satisfy the criteria expressed by the filter.
|
Set<Map.Entry<K,V>> |
NearCache.entrySet(Filter filter)
Return a set view of the entries contained in this map that satisfy the criteria expressed by the filter.
|
Set<Map.Entry<K,V>> |
WrapperNamedCache.entrySet(Filter filter)
Return a set view of the entries contained in this map that satisfy the criteria expressed by the filter.
|
Set<Map.Entry<K,V_FRONT>> |
ContinuousQueryCache.entrySet(Filter filter, Comparator comparator)
Return a set view of the entries contained in this map that satisfy the criteria expressed by the filter.
|
Set<Map.Entry<K,V>> |
NearCache.entrySet(Filter filter, Comparator comparator)
Return a set view of the entries contained in this map that satisfy the criteria expressed by the filter.
|
Set<Map.Entry<K,V>> |
WrapperNamedCache.entrySet(Filter filter, Comparator comparator)
Return a set view of the entries contained in this map that satisfy the criteria expressed by the filter.
|
protected Set<Map.Entry<K,V_FRONT>> |
ContinuousQueryCache.entrySetInternal(Filter filter)
Return multiple values from the back cache based on a filter, transforming them in the process if necessary.
|
protected Set<Map.Entry<K,V_FRONT>> |
ContinuousQueryCache.entrySetInternal(Filter filter, Comparator comparator)
Return multiple values from the back cache based on a filter, transforming them in the process if necessary.
|
<R> Map<K,R> |
ContinuousQueryCache.invokeAll(Filter filter, InvocableMap.EntryProcessor<K,V_FRONT,R> processor)
Invoke the passed EntryProcessor against the set of entries that are selected by the given Filter, returning the result of the invocation for each.
|
<R> Map<K,R> |
NearCache.invokeAll(Filter filter, InvocableMap.EntryProcessor<K,V,R> processor)
Invoke the passed EntryProcessor against the set of entries that are selected by the given Filter, returning the result of the invocation for each.
|
<R> Map<K,R> |
ReadonlyNamedCache.invokeAll(Filter filter, InvocableMap.EntryProcessor<K,V,R> agent)
Should not be called.
|
<R> Map<K,R> |
WrapperNamedCache.invokeAll(Filter filter, InvocableMap.EntryProcessor<K,V,R> agent)
Invoke the passed EntryProcessor against the set of entries that are selected by the given Filter, returning the result of the invocation for each.
|
Set<K> |
ContinuousQueryCache.keySet(Filter filter)
Return a set view of the keys contained in this map for entries that satisfy the criteria expressed by the filter.
|
Set<K> |
NearCache.keySet(Filter filter)
Return a set view of the keys contained in this map for entries that satisfy the criteria expressed by the filter.
|
Set<K> |
WrapperNamedCache.keySet(Filter filter)
Return a set view of the keys contained in this map for entries that satisfy the criteria expressed by the filter.
|
protected Filter |
ContinuousQueryCache.mergeFilter(Filter filter)
Return a filter which merges the ContinuousQueueCache's filter with the supplied filter.
|
void |
ContinuousQueryCache.removeMapListener(MapListener<? super K,? super V_FRONT> listener, Filter filter)
Remove a map listener that previously signed up for events based on a filter evaluation.
|
void |
NearCache.removeMapListener(MapListener<? super K,? super V> listener, Filter filter)
Remove a map listener that previously signed up for events based on a filter evaluation.
|
void |
AbstractSerializationCache.removeMapListener(MapListener listener, Filter filter)
Remove a map listener that previously signed up for events based on a filter evaluation.
|
void |
CompactSerializationCache.removeMapListener(MapListener listener, Filter filter)
Remove a map listener that previously signed up for events based on a filter evaluation.
|
void |
OldCache.removeMapListener(MapListener listener, Filter filter)
Deprecated.
Remove a map listener that previously signed up for events based on a filter evaluation.
|
void |
OverflowMap.removeMapListener(MapListener listener, Filter filter)
Remove a map listener that previously signed up for events based on a filter evaluation.
|
void |
ReadWriteBackingMap.removeMapListener(MapListener listener, Filter filter)
Remove a map listener that previously signed up for events based on a filter evaluation.
|
Constructor and Description |
---|
ContinuousQueryCache(NamedCache<K,V_BACK> cache, Filter filter)
Create a locally materialized view of a NamedCache using a Filter.
|
ContinuousQueryCache(NamedCache<K,V_BACK> cache, Filter filter, boolean fCacheValues)
Create a materialized view of a NamedCache using a Filter.
|
ContinuousQueryCache(NamedCache<K,V_BACK> cache, Filter filter, boolean fCacheValues, MapListener<? super K,? super V_FRONT> listener, ValueExtractor<? super V_BACK,? extends V_FRONT> transformer)
Construct the ContinuousQueryCache.
|
ContinuousQueryCache(NamedCache<K,V_BACK> cache, Filter filter, MapListener<? super K,? super V_FRONT> listener)
Create a materialized view of a NamedCache using a Filter.
|
ContinuousQueryCache(NamedCache<K,V_BACK> cache, Filter filter, MapListener<? super K,? super V_FRONT> listener, ValueExtractor<? super V_BACK,? extends V_FRONT> transformer)
Create a materialized view of a NamedCache using a Filter.
|
ContinuousQueryCache(NamedCache<K,V_BACK> cache, Filter filter, ValueExtractor<? super V_BACK,? extends V_FRONT> transformer)
Create a locally materialized view of a NamedCache using a Filter and a transformer.
|
Modifier and Type | Class and Description |
---|---|
class |
ObjectNameExcludeFilter
Filter used to prevent registering MBeans that match the specified pattern.
|
Modifier and Type | Field and Description |
---|---|
protected Filter |
ObjectNameExcludeFilter.m_filter
The underlying filter.
|
Modifier and Type | Method and Description |
---|---|
Set<String> |
MBeanServerProxy.queryNames(String sPattern, Filter<ObjectName> filter)
Get the names of MBeans controlled by the MBean server that is collocated with the
cluster registry . |
Constructor and Description |
---|
QueryExpFilter(Filter<ObjectName> filter) |
Modifier and Type | Class and Description |
---|---|
class |
SimpleAssignmentStrategy.AnalysisContext.NotOwnedFilter
NotOwnedFilter is a Filter implementation used to evaluate Member objects, and selects members who are not represented in the reference ownership object.
|
class |
SimpleAssignmentStrategy.AnalysisContext.SafetyFilter
SafetyFilter is a Filter implementation used to evaluate Member objects, and selects members that are "strong" with respect to the reference ownership, as defined by the backup-strength.
|
class |
SimpleAssignmentStrategy.AnalysisContext.UnderloadedFilter
UnderloadedFilter is a Filter implementation that is used to evaluate Member objects, and selects those whose partition load is "underloaded" in comparison to the fair-share load.
|
Modifier and Type | Method and Description |
---|---|
Filter |
SimpleAssignmentStrategy.AnalysisContext.instantiateNotOwnedFilter(Ownership owners)
Instantiate and return a NotOwnedFilter with the specified ownership.
|
Filter |
SimpleAssignmentStrategy.AnalysisContext.instantiateOverloadedFilter(boolean fPrimary)
Instantiate a filter that matches members with an over-load.
|
Filter |
SimpleAssignmentStrategy.AnalysisContext.instantiateSafetyFilter(Ownership owners, int iStore)
Instantiate and return a SafetyFilter with the specified ownership.
|
Filter |
SimpleAssignmentStrategy.AnalysisContext.instantiateUnderloadedFilter(boolean fPrimary)
Instantiate a filter that matches members with an under-load.
|
Modifier and Type | Method and Description |
---|---|
void |
ObservableSplittingBackingMap.addMapListener(MapListener listener, Filter filter, boolean fLite)
Add a map listener that receives events based on a filter evaluation.
|
protected static int |
SimpleAssignmentStrategy.filterArray(Object[] ao, Filter filter)
Apply the specified filter to the elements of the specified array.
|
protected static int |
SimpleAssignmentStrategy.filterArray(Object[] ao, int cElems, Filter filter)
Apply the specified filter to the specified array elements.
|
protected static int |
SimpleAssignmentStrategy.filterSort(Object[] ao, Comparator comparator, Filter filter)
Filter the elements in the specified array and sort any matching elements using the specified comparator.
|
protected static int |
SimpleAssignmentStrategy.filterSort(Object[] ao, int cElems, Comparator comparator, Filter filter)
Filter the specified array elements and sort any matching elements using the specified comparator.
|
void |
ObservableSplittingBackingMap.removeMapListener(MapListener listener, Filter filter)
Remove a map listener that previously signed up for events based on a filter evaluation.
|
Constructor and Description |
---|
AbstractPartitionedIterator(Filter filter, NamedCache cache, PartitionSet setPids)
Create AbstractPartitionedIterator instance.
|
AbstractPartitionedIterator(Filter filter, NamedCache cache, PartitionSet setPids, boolean fByMember, boolean fRandom)
Create AbstractPartitionedIterator instance.
|
PartitionedIterator(NamedCache cache, Filter filter, PartitionSet setPids, int nOptions)
Construct PartitionedIterator that will provide iteration of the keys of the specified cache using the specified filter, but will only query one partition or one member at a time.
|
Modifier and Type | Class and Description |
---|---|
class |
ClassFilter
Filter which discards all objects that are not of a certain class.
|
class |
NullFilter
Filter which discards null references.
|
Modifier and Type | Field and Description |
---|---|
protected Filter[] |
MapListenerSupport.FilterEvent.f_aFilter
Filters that caused the event.
|
protected Filter |
FilterEnumerator.m_test
Test to perform on each item.
|
Modifier and Type | Field and Description |
---|---|
protected Map<Filter,SimpleQueryRecord.PartialResult.Step> |
SimpleQueryRecord.PartialResult.AbstractRecordableStep.m_mapSteps
The Map of child steps.
|
Modifier and Type | Method and Description |
---|---|
default Filter |
Filter.and(Filter other)
Return a composed filter that represents a short-circuiting logical AND of this filter and another.
|
static <T,E> Filter<T> |
Filters.arrayContains(ValueExtractor<T,E[]> extractor, E value)
Return a filter that tests if the extracted array contains the specified value.
|
static <T,E> Filter<T> |
Filters.arrayContainsAll(ValueExtractor<T,E[]> extractor, E... values)
Return a filter that tests if the extracted array contains all of the specified values.
|
static <T,E> Filter<T> |
Filters.arrayContainsAll(ValueExtractor<T,E[]> extractor, Set<? extends E> setValues)
Return a filter that tests if the extracted array contains all of the specified values.
|
static <T,E> Filter<T> |
Filters.arrayContainsAny(ValueExtractor<T,E[]> extractor, E... values)
Return a filter that tests if the extracted array contains any of the specified values.
|
static <T,E> Filter<T> |
Filters.arrayContainsAny(ValueExtractor<T,E[]> extractor, Set<? extends E> setValues)
Return a filter that tests if the extracted array contains any of the specified values.
|
static <T,E,C extends Collection<? extends E>> |
Filters.contains(ValueExtractor<T,C> extractor, E value)
Return a filter that tests if the extracted collection contains the specified value.
|
static <T,E,C extends Collection<? extends E>> |
Filters.containsAll(ValueExtractor<T,C> extractor, E... values)
Return a filter that tests if the extracted collection contains all of the specified values.
|
static <T,E,C extends Collection<? extends E>> |
Filters.containsAll(ValueExtractor<T,C> extractor, Set<? extends E> setValues)
Return a filter that tests if the extracted collection contains all of the specified values.
|
static <T,E,C extends Collection<? extends E>> |
Filters.containsAny(ValueExtractor<T,C> extractor, E... values)
Return a filter that tests if the extracted collection contains any of the specified values.
|
static <T,E,C extends Collection<? extends E>> |
Filters.containsAny(ValueExtractor<T,C> extractor, Set<? extends E> setValues)
Return a filter that tests if the extracted collection contains any of the specified values.
|
static Filter |
QueryHelper.createFilter(String sWhereClause)
Make a new Filter from the given String.
|
static Filter |
QueryHelper.createFilter(String sWhereClause, Map mapBindings)
Make a new Filter from the given String.
|
static Filter |
QueryHelper.createFilter(String sWhereClause, Object[] aBindings)
Make a new Filter from the given String.
|
static Filter |
QueryHelper.createFilter(String sWhereClause, Object[] aBindings, Map mapBindings)
Make a new Filter from the given String.
|
static Filter |
QueryHelper.createFilter(String sWhereClause, Object[] aBindings, Map mapBindings, CoherenceQueryLanguage language)
Make a new Filter from the given String.
|
Filter |
ConditionalIndex.getFilter()
Get the associated filter.
|
Filter[] |
MapListenerSupport.FilterEvent.getFilter()
Return an array of filters that are the cause of this event.
|
Filter[] |
Listeners.getFilters()
Return the array of filters associated with this Listeners object.
|
static <T> Filter<T> |
Filters.not(Filter<T> filter)
Return a filter that represents the logical negation of the specified filter.
|
default Filter |
Filter.or(Filter other)
Return a composed predicate that represents a short-circuiting logical OR of this predicate and another.
|
default Filter |
Filter.xor(Filter other)
Return a composed predicate that represents a logical XOR of this predicate and another.
|
Modifier and Type | Method and Description |
---|---|
void |
MapListenerSupport.addListener(MapListener listener, Filter filter, boolean fLite)
Add a map listener that receives events based on a filter evaluation.
|
boolean |
MapListenerSupport.addListenerWithCheck(MapListener listener, Filter filter, boolean fLite)
Add a map listener that receives events based on a filter evaluation.
|
void |
ObservableHashMap.addMapListener(MapListener<? super K,? super V> listener, Filter filter, boolean fLite)
Add a map listener that receives events based on a filter evaluation.
|
void |
ObservableMap.addMapListener(MapListener<? super K,? super V> listener, Filter filter, boolean fLite)
Add a map listener that receives events based on a filter evaluation.
|
void |
WrapperObservableMap.addMapListener(MapListener<? super K,? super V> listener, Filter filter, boolean fLite)
Add a map listener that receives events based on a filter evaluation.
|
void |
ConverterCollections.ConverterObservableMap.addMapListener(MapListener listener, Filter filter, boolean fLite)
Add a map listener that receives events based on a filter evaluation.
|
void |
NullImplementation.NullObservableMap.addMapListener(MapListener listener, Filter filter, boolean fLite)
Add a map listener that receives events based on a filter evaluation.
|
protected static void |
MapListenerSupport.addSafeListener(Map mapListeners, Filter anyFilter, MapListener listener)
Ensure that the specified map has a Listeners object associated with the specified Filter and add the specified listener to it.
|
Object |
ConverterCollections.ConverterInvocableMap.aggregate(Filter filter, InvocableMap.EntryAggregator agent)
Perform an aggregating operation against the set of entries that are selected by the given Filter.
|
Object |
ConverterCollections.ConverterNamedCache.aggregate(Filter filter, InvocableMap.EntryAggregator agent)
Perform an aggregating operation against the set of entries that are selected by the given Filter.
|
<R> R |
InvocableMap.aggregate(Filter filter, InvocableMap.EntryAggregator<? super K,? super V,R> aggregator)
Perform an aggregating operation against the set of entries that are selected by the given Filter.
|
static AllFilter |
Filters.all(Filter... filters)
Return a composite filter representing logical AND of all specified filters.
|
default Filter |
Filter.and(Filter other)
Return a composed filter that represents a short-circuiting logical AND of this filter and another.
|
static AnyFilter |
Filters.any(Filter... filters)
Return a composite filter representing logical OR of all specified filters.
|
boolean |
MapListenerSupport.containsStandardListeners(Filter filter)
Checks whether or not this MapListenerSupport object contains any standard (not lite) listeners for a given filter.
|
QueryRecord.PartialResult.ExplainStep |
QueryRecord.PartialResult.ExplainStep.ensureStep(Filter filter)
Ensure an inner nested explain step for the given filter.
|
QueryRecord.PartialResult.TraceStep |
QueryRecord.PartialResult.TraceStep.ensureStep(Filter filter)
Ensure an inner nested trace step for the given filter.
|
QueryRecord.PartialResult.ExplainStep |
SimpleQueryRecord.PartialResult.ExplainStep.ensureStep(Filter filter)
Ensure an inner nested explain step for the given filter.
|
QueryRecord.PartialResult.TraceStep |
SimpleQueryRecord.PartialResult.TraceStep.ensureStep(Filter filter)
Ensure an inner nested trace step for the given filter.
|
Set |
ConverterCollections.ConverterQueryMap.entrySet(Filter filter)
Return a set view of the entries contained in this map that satisfy the criteria expressed by the filter.
|
Set |
ConverterCollections.ConverterNamedCache.entrySet(Filter filter)
Return a set view of the entries contained in this map that satisfy the criteria expressed by the filter.
|
Set<Map.Entry<K,V>> |
QueryMap.entrySet(Filter filter)
Return a set view of the entries contained in this map that satisfy the criteria expressed by the filter.
|
Set |
ConverterCollections.ConverterQueryMap.entrySet(Filter filter, Comparator comparator)
Return a set view of the entries contained in this map that satisfy the criteria expressed by the filter.
|
Set |
ConverterCollections.ConverterNamedCache.entrySet(Filter filter, Comparator comparator)
Return a set view of the entries contained in this map that satisfy the criteria expressed by the filter.
|
Set<Map.Entry<K,V>> |
QueryMap.entrySet(Filter filter, Comparator comparator)
Return a set view of the entries contained in this map that satisfy the criteria expressed by the filter.
|
static <K,V> boolean |
InvocableMapHelper.evaluateEntry(Filter filter, K oKey, V oValue)
Check if an entry, expressed as a key and value, passes the filter evaluation.
|
static <K,V> boolean |
InvocableMapHelper.evaluateEntry(Filter filter, Map.Entry<K,V> entry)
Check if the entry passes the filter evaluation.
|
protected boolean |
MapListenerSupport.evaluateEvent(Filter filter, MapEvent event)
Evaluate whether or not the specified event should be delivered to the listener associated with the specified filter.
|
static boolean |
InvocableMapHelper.evaluateOriginalEntry(Filter filter, MapTrigger.Entry entry)
Check if the entry, in its "original" form, passes the filter evaluation.
|
default void |
QueryMap.forEach(Filter filter, BiConsumer<? super K,? super V> action)
Perform the given action for each entry selected by the specified filter until all entries have been processed or the action throws an exception.
|
Listeners |
MapListenerSupport.getListeners(Filter filter)
Obtain the Listeners object for a given filter.
|
QueryRecord.PartialResult.ExplainStep |
SimpleQueryRecord.PartialResult.instantiateExplainStep(Filter filter)
Instantiate a new explain step for the given filter and add it to this result's list of steps.
|
QueryRecord.PartialResult.TraceStep |
SimpleQueryRecord.PartialResult.instantiateTraceStep(Filter filter)
Instantiate a new trace step for the given filter and add it to this result's list of steps.
|
Map |
ConverterCollections.ConverterInvocableMap.invokeAll(Filter filter, InvocableMap.EntryProcessor agent)
Invoke the passed EntryProcessor against the set of entries that are selected by the given Filter, returning the result of the invocation for each.
|
Map |
ConverterCollections.ConverterNamedCache.invokeAll(Filter filter, InvocableMap.EntryProcessor agent)
Invoke the passed EntryProcessor against the set of entries that are selected by the given Filter, returning the result of the invocation for each.
|
<R> Map<K,R> |
InvocableMap.invokeAll(Filter filter, InvocableMap.EntryProcessor<K,V,R> processor)
Invoke the passed EntryProcessor against the set of entries that are selected by the given Filter, returning the result of the invocation for each.
|
boolean |
MapListenerSupport.isEmpty(Filter filter)
Checks whether or not this MapListenerSupport object contains any listeners for a given filter.
|
Set |
ConverterCollections.ConverterQueryMap.keySet(Filter filter)
Return a set view of the keys contained in this map for entries that satisfy the criteria expressed by the filter.
|
Set |
ConverterCollections.ConverterNamedCache.keySet(Filter filter)
Return a set view of the keys contained in this map for entries that satisfy the criteria expressed by the filter.
|
Set<K> |
QueryMap.keySet(Filter filter)
Return a set view of the keys contained in this map for entries that satisfy the criteria expressed by the filter.
|
static <T> Filter<T> |
Filters.not(Filter<T> filter)
Return a filter that represents the logical negation of the specified filter.
|
default Filter |
Filter.or(Filter other)
Return a composed predicate that represents a short-circuiting logical OR of this predicate and another.
|
static Set |
InvocableMapHelper.query(Map map, Filter filter, boolean fEntries, boolean fSort, Comparator comparator)
Generic implementation of the
QueryMap API. |
static Set |
InvocableMapHelper.query(Map map, Map mapIndexes, Filter filter, boolean fEntries, boolean fSort, Comparator comparator)
Generic implementation of the
QueryMap API. |
void |
MapListenerSupport.removeListener(MapListener listener, Filter filter)
Remove a map listener that previously signed up for events based on a filter evaluation.
|
boolean |
MapListenerSupport.removeListenerWithCheck(MapListener listener, Filter filter)
Remove a map listener that previously signed up for events based on a filter evaluation.
|
void |
ObservableHashMap.removeMapListener(MapListener<? super K,? super V> listener, Filter filter)
Remove a map listener that previously signed up for events based on a filter evaluation.
|
void |
ObservableMap.removeMapListener(MapListener<? super K,? super V> listener, Filter filter)
Remove a map listener that previously signed up for events based on a filter evaluation.
|
void |
WrapperObservableMap.removeMapListener(MapListener<? super K,? super V> listener, Filter filter)
Remove a map listener that previously signed up for events based on a filter evaluation.
|
void |
ConverterCollections.ConverterObservableMap.removeMapListener(MapListener listener, Filter filter)
Remove a map listener that previously signed up for events based on a filter evaluation.
|
void |
NullImplementation.NullObservableMap.removeMapListener(MapListener listener, Filter filter)
Remove a map listener that previously signed up for events based on a filter evaluation.
|
default void |
InvocableMap.replaceAll(Filter filter, Remote.BiFunction<? super K,? super V,? extends V> function)
Replace each entry's value with the result of invoking the given function on that entry until all entries selected by the specified filter have been processed or the function throws an exception.
|
void |
Listeners.setFilters(Filter[] aFilter)
Set the array of filters associated with this Listeners object.
|
default RemoteStream<InvocableMap.Entry<K,V>> |
InvocableMap.stream(Filter filter)
Return a filtered stream of entries in this map.
|
default <T,E> RemoteStream<E> |
InvocableMap.stream(Filter filter, ValueExtractor<T,? extends E> extractor)
Return a stream of values extracted from all the entries that satisfy the specified filter.
|
default Collection<V> |
QueryMap.values(Filter filter)
Return a collection of the values contained in this map that satisfy the criteria expressed by the filter.
|
default Collection<V> |
QueryMap.values(Filter filter, Comparator comparator)
Return a collection of the values contained in this map that satisfy the criteria expressed by the filter.
|
default Filter |
Filter.xor(Filter other)
Return a composed predicate that represents a logical XOR of this predicate and another.
|
Constructor and Description |
---|
AbstractRecordableStep(Filter filter)
Construct an AbstractRecordableStep.
|
ConditionalIndex(Filter filter, ValueExtractor extractor, boolean fOrdered, Comparator comparator, boolean fForwardIndex, BackingMapContext ctx)
Construct a ConditionalIndex.
|
ExplainStep(Filter filter)
Construct an ExplainStep
|
FilterEnumerator(Enumeration enmr, Filter test)
Construct the Filter enumerator based on an Enumeration.
|
FilterEnumerator(Iterator iter, Filter test)
Construct the Filter enumerator based on an Iterator.
|
FilterEnumerator(Object[] aoItem, Filter test)
Construct the Filter enumerator based on an array of objects.
|
FilterEvent(MapEvent event, Filter[] aFilter)
Constructs a new FilterEvent that wraps the given MapEvent.
|
FilterEvent(ObservableMap map, int nId, Object oKey, boolean fSynthetic, Filter[] aFilter)
Constructs a new lite (no values are specified) FilterEvent.
|
FilterEvent(ObservableMap map, int nId, Object oKey, Object oValueOld, Object oValueNew, boolean fSynthetic, CacheEvent.TransformationState transformState, Filter[] aFilter)
Constructs a new FilterEvent.
|
FilterEvent(ObservableMap map, int nId, Object oKey, Object oValueOld, Object oValueNew, boolean fSynthetic, Filter[] aFilter)
Constructs a new FilterEvent.
|
Step(Filter filter)
Construct a step.
|
TraceStep(Filter filter)
Construct a TraceStep
|
Modifier and Type | Field and Description |
---|---|
protected Filter |
GroupAggregator.m_filter
The Filter object representing the "having" clause of this "group by" aggregator.
|
Modifier and Type | Method and Description |
---|---|
static <K,V,R> GroupAggregator<K,V,Object,Object,R> |
GroupAggregator.createInstance(String sMethod, InvocableMap.EntryAggregator<K,V,R> aggregator, Filter filter)
Create an instance of GroupAggregator based on a specified method name(s), an
EntryAggregator and a result evaluation filter. |
static <K,V,T,E,R> |
GroupAggregator.createInstance(ValueExtractor<? super T,? extends E> extractor, InvocableMap.EntryAggregator<? super K,? super V,R> aggregator, Filter filter)
Create an instance of GroupAggregator based on a specified extractor and an
EntryAggregator and a result evaluation filter. |
Constructor and Description |
---|
GroupAggregator(ValueExtractor<? super T,? extends E> extractor, InvocableMap.EntryAggregator<? super K,? super V,R> aggregator, Filter filter)
Construct a GroupAggregator based on a specified ValueExtractor and underlying EntryAggregator.
|
Parallel(ValueExtractor<? super T,? extends E> extractor, InvocableMap.EntryAggregator<? super K,? super V,R> aggregator, Filter<?> filter)
Deprecated.
Construct a Parallel aggregator based on a specified ValueExtractor and underlying ParallelAwareAggregator.
|
Modifier and Type | Field and Description |
---|---|
protected Filter |
ConditionalExtractor.m_filter
The filter used by this extractor.
|
Constructor and Description |
---|
ConditionalExtractor(Filter filter, ValueExtractor<T,E> extractor, boolean fForwardIndex)
Construct the ConditionalExtractor.
|
ConditionalExtractor(Filter filter, ValueExtractor<T,E> extractor, boolean fForwardIndex, boolean fOptimizeMV)
Construct the ConditionalExtractor.
|
Modifier and Type | Interface and Description |
---|---|
interface |
EntryFilter<K,V>
EntryFilter provides an extension to Filter for those cases in which both a key and a value may be necessary to evaluate the conditional inclusion of a particular object.
|
interface |
IndexAwareFilter<K,V>
IndexAwareFilter is an extension to the EntryFilter interface that allows a filter to use a Map index to fully or partially evaluate itself.
|
interface |
QueryRecorderFilter<T>
QueryRecorderFilter is an extension of EntryFilter that allows the projected or actual costs of query execution to be recorded.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractQueryRecorderFilter<T>
Abstract base class implementation of
QueryRecorderFilter . |
class |
AllFilter
Filter which returns the logical "and" of a filter array.
|
class |
AlwaysFilter<T>
Filter which always evaluates to true.
|
class |
AndFilter
Filter which returns the logical "and" of two other filters.
|
class |
AnyFilter
Filter which returns the logical "or" of a filter array.
|
class |
ArrayFilter
Filter which is a logical operator of a filter array.
|
class |
BetweenFilter<T,E extends Comparable<? super E>>
Filter which compares the result of a method invocation with a value for "Between" condition.
|
class |
CacheEventFilter<T>
An extension of the
MapEventFilter which allows selection of client driven (natural) events, cache internal (synthetic) events, or both. |
class |
ComparisonFilter<T,E,C>
Filter which compares the result of a method invocation with a value.
|
class |
ContainsAllFilter<T,E>
Filter which tests a
Collection or Object array value returned from a method invocation for containment of all values in a Set. |
class |
ContainsAnyFilter<T,E>
Filter which tests a
Collection or Object array value returned from a method invocation for containment of any value in a Set. |
class |
ContainsFilter<T,E>
Filter which tests a
Collection or Object array value returned from a method invocation for containment of a given value. |
class |
EqualsFilter<T,E>
Filter which compares the result of a method invocation with a value for equality.
|
class |
ExtractorFilter<T,E>
Base Filter implementation for doing extractor-based processing.
|
class |
GreaterEqualsFilter<T,E extends Comparable<? super E>>
Filter which compares the result of a method invocation with a value for "Greater or Equal" condition.
|
class |
GreaterFilter<T,E extends Comparable<? super E>>
Filter which compares the result of a method invocation with a value for "Greater" condition.
|
class |
InFilter<T,E>
Filter which checks whether the result of a method invocation belongs to a predefined set of values.
|
class |
InKeySetFilter<T>
Filter that limits the underlying filter evaluation only to the specified set of keys.
|
class |
IsNotNullFilter<T,E>
Filter which tests the result of a method invocation for inequality to null.
|
class |
IsNullFilter<T,E>
Filter which compares the result of a method invocation with null.
|
class |
KeyAssociatedFilter<T>
Filter which limits the scope of another filter according to the key association information.
|
class |
KeyFilter<T>
EntryFilter which checks whether an entry key belongs to a set.
|
class |
LessEqualsFilter<T,E extends Comparable<? super E>>
Filter which compares the result of a method invocation with a value for "Less or Equals" condition.
|
class |
LessFilter<T,E extends Comparable<? super E>>
Filter which compares the result of a method invocation with a value for "Less" condition.
|
class |
LikeFilter<T,E>
Filter which compares the result of a method invocation with a value for pattern match.
|
class |
LimitFilter<T>
Filter which truncates the results of another filter.
|
class |
MapEventFilter<T>
Filter which evaluates the content of a MapEvent object according to the specified criteria.
|
class |
MapEventTransformerFilter<T>
MapEventTransformerFilter is a generic multiplexing wrapper that combines two implementations: a Filter (most commonly a
MapEventFilter ) and a MapEventTransformer and is used to register event listeners that allow to change the content of a MapEvent. |
class |
NeverFilter<T>
Filter which always evaluates to false.
|
class |
NotEqualsFilter<T,E>
Filter which compares the result of a method invocation with a value for inequality.
|
class |
NotFilter<T>
Filter which negates the results of another filter.
|
class |
OrFilter
Filter which returns the logical "or" of two other filters.
|
class |
PartitionedFilter<T>
Filter which limits the scope of another filter to those entries that have keys that belong to the specified partition set.
|
class |
PredicateFilter<T,E>
A
java.util.function.Predicate based ExtractorFilter . |
class |
PresentFilter<T>
Filter which returns true for
InvocableMap.Entry objects that currently exist in a Map. |
class |
PriorityFilter<T>
PriorityFilter is used to explicitly control the scheduling priority and timeouts for execution of filter-based methods.
|
class |
RegexFilter<T,E>
Filter which uses the regular expression pattern match defined by the
String.matches(String) contract. |
class |
ValueChangeEventFilter<V,E>
Filter which evaluates the content of a MapEvent values based on the specified value extractor.
|
class |
WrapperQueryRecorderFilter<T>
QueryRecorderFilter wrapper class.
|
class |
XorFilter
Filter which returns the logical exclusive or ("xor") of two other filters.
|
Modifier and Type | Field and Description |
---|---|
protected Filter[] |
ArrayFilter.m_aFilter
The Filter array.
|
protected Filter |
FilterTrigger.m_filter
The underlying filter.
|
protected Filter<T> |
MapEventFilter.m_filter
The event value(s) filter.
|
Modifier and Type | Method and Description |
---|---|
protected Filter |
ArrayFilter.applyFilter(Filter filter, int iFilter, Map mapIndexes, Set setKeys, QueryContext ctx, QueryRecord.PartialResult.TraceStep step)
Apply the specified IndexAwareFilter to the specified keySet.
|
<RK> Filter<V> |
IndexAwareFilter.applyIndex(Map<? extends ValueExtractor<? extends V,Object>,? extends MapIndex<? extends RK,? extends V,Object>> mapIndexes, Set<? extends RK> setKeys)
Filter remaining keys using a Map of available indexes.
|
Filter |
AlwaysFilter.applyIndex(Map mapIndexes, Set setKeys)
Filter remaining keys using a Map of available indexes.
|
Filter |
ArrayFilter.applyIndex(Map mapIndexes, Set setKeys)
Filter remaining keys using a Map of available indexes.
|
Filter |
BetweenFilter.applyIndex(Map mapIndexes, Set setKeys)
Filter remaining keys using a Map of available indexes.
|
Filter |
ContainsAllFilter.applyIndex(Map mapIndexes, Set setKeys)
Filter remaining keys using a Map of available indexes.
|
Filter |
ContainsAnyFilter.applyIndex(Map mapIndexes, Set setKeys)
Filter remaining keys using a Map of available indexes.
|
Filter |
ContainsFilter.applyIndex(Map mapIndexes, Set setKeys)
Filter remaining keys using a Map of available indexes.
|
Filter |
EqualsFilter.applyIndex(Map mapIndexes, Set setKeys)
Filter remaining keys using a Map of available indexes.
|
Filter |
ExtractorFilter.applyIndex(Map mapIndexes, Set setKeys)
Filter remaining keys using a Map of available indexes.
|
Filter |
GreaterEqualsFilter.applyIndex(Map mapIndexes, Set setKeys)
Filter remaining keys using a Map of available indexes.
|
Filter |
GreaterFilter.applyIndex(Map mapIndexes, Set setKeys)
Filter remaining keys using a Map of available indexes.
|
Filter |
InFilter.applyIndex(Map mapIndexes, Set setKeys)
Filter remaining keys using a Map of available indexes.
|
Filter |
InKeySetFilter.applyIndex(Map mapIndexes, Set setKeys)
Filter remaining keys using a Map of available indexes.
|
Filter |
KeyFilter.applyIndex(Map mapIndexes, Set setKeys)
Filter remaining keys using a Map of available indexes.
|
Filter |
LessEqualsFilter.applyIndex(Map mapIndexes, Set setKeys)
Filter remaining keys using a Map of available indexes.
|
Filter |
LessFilter.applyIndex(Map mapIndexes, Set setKeys)
Filter remaining keys using a Map of available indexes.
|
Filter |
LikeFilter.applyIndex(Map mapIndexes, Set setKeys)
Filter remaining keys using a Map of available indexes.
|
Filter |
LimitFilter.applyIndex(Map mapIndexes, Set setKeys)
Filter remaining keys using a Map of available indexes.
|
Filter |
NeverFilter.applyIndex(Map mapIndexes, Set setKeys)
Filter remaining keys using a Map of available indexes.
|
Filter |
NotEqualsFilter.applyIndex(Map mapIndexes, Set setKeys)
Filter remaining keys using a Map of available indexes.
|
Filter |
NotFilter.applyIndex(Map mapIndexes, Set setKeys)
Filter remaining keys using a Map of available indexes.
|
Filter |
PresentFilter.applyIndex(Map mapIndexes, Set setKeys)
Filter remaining keys using a Map of available indexes.
|
Filter |
PriorityFilter.applyIndex(Map mapIndexes, Set setKeys)
Filter remaining keys using a Map of available indexes.
|
protected Filter |
AllFilter.applyIndex(Map mapIndexes, Set setKeys, QueryContext ctx, QueryRecord.PartialResult.TraceStep step)
Apply the specified IndexAwareFilter to the specified keySet.
|
protected Filter |
AnyFilter.applyIndex(Map mapIndexes, Set setKeys, QueryContext ctx, QueryRecord.PartialResult.TraceStep step)
Apply the specified IndexAwareFilter to the specified keySet.
|
protected abstract Filter |
ArrayFilter.applyIndex(Map mapIndexes, Set setKeys, QueryContext ctx, QueryRecord.PartialResult.TraceStep step)
Apply the specified IndexAwareFilter to the specified keySet.
|
protected Filter |
XorFilter.applyIndex(Map mapIndexes, Set setKeys, QueryContext ctx, QueryRecord.PartialResult.TraceStep step)
Apply the specified IndexAwareFilter to the specified keySet.
|
Filter |
ArrayFilter.WeightedFilter.getFilter()
Get the wrapped filter.
|
Filter |
FilterTrigger.getFilter()
Obtain the underlying Filter.
|
Filter<T> |
InKeySetFilter.getFilter()
Obtain the underlying Filter.
|
Filter<T> |
KeyAssociatedFilter.getFilter()
Obtain the wrapped Filter.
|
Filter<T> |
LimitFilter.getFilter()
Obtain the Filter whose results are truncated by this filter.
|
Filter<T> |
MapEventFilter.getFilter()
Obtain the Filter object used to evaluate the event value(s).
|
Filter<T> |
NotFilter.getFilter()
Obtain the Filter whose results are negated by this filter.
|
Filter<T> |
PartitionedFilter.getFilter()
Obtain the wrapped Filter.
|
Filter[] |
ArrayFilter.getFilters()
Obtain the Filter array.
|
protected static <T> Filter<T> |
AbstractQueryRecorderFilter.trace(Filter<T> filter, Map mapIndexes, Set setKeys, QueryRecord.PartialResult.TraceStep step)
Record the actual cost of applying the specified filter to the specified keySet.
|
protected static <T> Filter<T> |
AbstractQueryRecorderFilter.trace(Filter<T> filter, Map mapIndexes, Set setKeys, QueryRecord.PartialResult.TraceStep step, ValueExtractor extractor)
Record the actual cost of applying the specified filter to the specified keySet.
|
Filter |
AbstractQueryRecorderFilter.trace(QueryContext ctx, QueryRecord.PartialResult.TraceStep step, Set setKeys)
Filter the given keys using available indexes and record the cost of execution on the given step of the
QueryRecord . |
Filter |
ArrayFilter.trace(QueryContext ctx, QueryRecord.PartialResult.TraceStep step, Set setKeys)
Filter the given keys using available indexes and record the cost of execution on the given step of the
QueryRecord . |
Filter |
BetweenFilter.trace(QueryContext ctx, QueryRecord.PartialResult.TraceStep step, Set setKeys)
Filter the given keys using available indexes and record the cost of execution on the given step of the
QueryRecord . |
Filter |
QueryRecorderFilter.trace(QueryContext ctx, QueryRecord.PartialResult.TraceStep step, Set setKeys)
Filter the given keys using available indexes and record the cost of execution on the given step of the
QueryRecord . |
Filter |
WrapperQueryRecorderFilter.trace(QueryContext ctx, QueryRecord.PartialResult.TraceStep step, Set setKeys)
Filter the given keys using available indexes and record the cost of execution on the given step of the
QueryRecord . |
Modifier and Type | Method and Description |
---|---|
protected Filter |
ArrayFilter.applyFilter(Filter filter, int iFilter, Map mapIndexes, Set setKeys, QueryContext ctx, QueryRecord.PartialResult.TraceStep step)
Apply the specified IndexAwareFilter to the specified keySet.
|
protected boolean |
ArrayFilter.evaluateFilter(Filter filter, Map.Entry entry, QueryContext ctx, QueryRecord.PartialResult.TraceStep step)
Check if the given entry passes the given filter's evaluation.
|
protected static <T> void |
AbstractQueryRecorderFilter.explain(Filter<T> filter, Map mapIndexes, Set setKeys, QueryRecord.PartialResult.ExplainStep step)
Record an estimated cost of query execution for a given filter.
|
protected static <T> void |
AbstractQueryRecorderFilter.explain(Filter<T> filter, Map mapIndexes, Set setKeys, QueryRecord.PartialResult.ExplainStep step, ValueExtractor extractor)
Record an estimated cost of query execution for a given filter.
|
protected static <T> boolean |
AbstractQueryRecorderFilter.trace(Filter<T> filter, Map.Entry entry, QueryRecord.PartialResult.TraceStep step)
Record the actual cost of query execution for a given filter.
|
protected static <T> Filter<T> |
AbstractQueryRecorderFilter.trace(Filter<T> filter, Map mapIndexes, Set setKeys, QueryRecord.PartialResult.TraceStep step)
Record the actual cost of applying the specified filter to the specified keySet.
|
protected static <T> Filter<T> |
AbstractQueryRecorderFilter.trace(Filter<T> filter, Map mapIndexes, Set setKeys, QueryRecord.PartialResult.TraceStep step, ValueExtractor extractor)
Record the actual cost of applying the specified filter to the specified keySet.
|
Constructor and Description |
---|
AllFilter(Filter[] afilter)
Construct an "all" filter.
|
AndFilter(Filter filterLeft, Filter filterRight)
Construct an "and" filter.
|
AndFilter(Filter filterLeft, Filter filterRight)
Construct an "and" filter.
|
AnyFilter(Filter[] afilter)
Construct an "any" filter.
|
ArrayFilter(Filter[] aFilter)
Construct a logical filter that applies a binary operator to a filter array.
|
CacheEventFilter(Filter<T> filter, int nMaskSynthetic)
Construct a CacheEventFilter that evaluates MapEvent objects that would affect the results of a keySet filter issued by a previous call to
QueryMap.keySet(com.tangosol.util.Filter) . |
CacheEventFilter(int nMask, Filter<T> filter, int nMaskSynthetic)
Construct a CacheEventFilter that evaluates MapEvent objects based on the specified combination of event types.
|
FilterTrigger(Filter<T> filter)
Construct a FilterTrigger based on the specified Filter object and ACTION_ROLLBACK.
|
FilterTrigger(Filter<T> filter, int nAction)
Construct a FilterTrigger based on the specified Filter object and the action constant.
|
InKeySetFilter(Filter<T> filter, Set<K> setKeys)
Construct an InFilter for testing "In" condition.
|
KeyAssociatedFilter(Filter<T> filter, Object oHostKey)
Construct a key associated filter.
|
LimitFilter(Filter<T> filter, int cPageSize)
Construct a limit filter.
|
MapEventFilter(Filter<T> filter)
Construct a MapEventFilter that evaluates MapEvent objects that would affect the results of a keySet filter issued by a previous call to
QueryMap.keySet(com.tangosol.util.Filter) . |
MapEventFilter(int nMask, Filter<T> filter)
Construct a MapEventFilter that evaluates MapEvent objects based on the specified combination of event types.
|
MapEventTransformerFilter(Filter<T> filter, MapEventTransformer transformer)
Construct a MapEventTransformerFilter based on the specified Filter and MapEventTransformer.
|
NotFilter(Filter<T> filter)
Construct a negation filter.
|
OrFilter(Filter filterLeft, Filter filterRight)
Construct an "or" filter.
|
OrFilter(Filter filterLeft, Filter filterRight)
Construct an "or" filter.
|
PartitionedFilter(Filter<T> filter, PartitionSet partitions)
Construct a PartitionedFilter.
|
WeightedFilter(Filter filter, int nEffect)
Construct the WeightedFilter.
|
WrapperQueryRecorderFilter(Filter<T> filter)
Construct a WrapperQueryRecorderFilter.
|
XorFilter(Filter filterLeft, Filter filterRight)
Construct a "xor" filter.
|
XorFilter(Filter filterLeft, Filter filterRight)
Construct a "xor" filter.
|
Modifier and Type | Field and Description |
---|---|
protected Filter<V> |
ConditionalProcessor.m_filter
The underlying filter.
|
protected Filter |
ConditionalPut.m_filter
The underlying filter.
|
protected Filter |
ConditionalPutAll.m_filter
The underlying filter.
|
protected Filter |
ConditionalRemove.m_filter
The underlying filter.
|
Constructor and Description |
---|
ConditionalProcessor(Filter<V> filter, InvocableMap.EntryProcessor<K,V,T> processor)
Construct a ConditionalProcessor for the specified filter and the processor.
|
ConditionalPut(Filter filter, V value)
Construct a ConditionalPut that updates an entry with a new value if and only if the filter applied to the entry evaluates to true.
|
ConditionalPut(Filter filter, V value, boolean fReturn)
Construct a ConditionalPut that updates an entry with a new value if and only if the filter applied to the entry evaluates to true.
|
ConditionalPutAll(Filter filter, Map<? extends K,? extends V> map)
Construct a ConditionalPutAll processor that updates an entry with a new value if and only if the filter applied to the entry evaluates to true.
|
ConditionalRemove(Filter filter)
Construct a ConditionalRemove processor that removes an InvocableMap entry if and only if the filter applied to the entry evaluates to true.
|
ConditionalRemove(Filter filter, boolean fReturn)
Construct a ConditionalRemove processor that removes an InvocableMap entry if and only if the filter applied to the entry evaluates to true.
|