Package | Description |
---|---|
com.tangosol.coherence.config.scheme |
Defines the Coherence configuration object model classes and interfaces for
Caching and Service Schemes.
|
com.tangosol.coherence.dslquery | |
com.tangosol.coherence.dslquery.function |
This package contains builders for the various CohQL functions.
|
com.tangosol.coherence.dslquery.internal | |
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.partitionedcache |
Contains classes related to partitioned cache implementation of Coherence JCache.
|
com.tangosol.coherence.rest |
Contains classes related to the Coherence REST API.
|
com.tangosol.coherence.rest.query |
Contains classes related to the Coherence REST pluggable query engine.
|
com.tangosol.coherence.rest.util | |
com.tangosol.coherence.rest.util.aggregator |
Contains classes related to REST-based aggregation.
|
com.tangosol.coherence.rest.util.extractor | |
com.tangosol.net |
Contains basic cluster interfaces and factories.
|
com.tangosol.net.cache |
Contains classes providing various caching strategies.
|
com.tangosol.util |
Contains various generic utilities.
|
com.tangosol.util.aggregator |
Contains concrete
InvocableMap.EntryAggregator
implementations. |
com.tangosol.util.comparator |
Contains concrete
Comparator implementations and related interfaces. |
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. |
com.tangosol.util.stream |
Contains classes to support functional-style operations on remote streams of elements,
such as map-reduce transformations on collections.
|
com.tangosol.util.transformer |
Contains concrete
MapEventTransformer
implementations. |
Modifier and Type | Method and Description |
---|---|
ParameterizedBuilder<ValueExtractor> |
ContinuousQueryCacheScheme.getTransformerBuilder()
Return the
ParameterizedBuilder used to construct the ValueExtractor to be used as a
transformer by the ContinuousQueryCache . |
Modifier and Type | Method and Description |
---|---|
void |
ContinuousQueryCacheScheme.setTransformerBuilder(ParameterizedBuilder<ValueExtractor> transformerBuilder)
Set the
ParameterizedBuilder used to construct the ValueExtractor to be used as a transformer
by the ContinuousQueryCache . |
Modifier and Type | Method and Description |
---|---|
ValueExtractor |
FilterBuilder.makeExtractor(NodeTerm term)
Process the AST Tree using the given Term that represents getter.
|
ValueExtractor |
ReflectionExtractorBuilder.realize(String sCacheName,
int nTarget,
String sProperties) |
ValueExtractor |
ChainedExtractorBuilder.realize(String sCacheName,
int nTarget,
String sProperties)
Call the realize(String, int, String) method on each
ExtractorBuilder
in the chain returning the result of the first ExtractorBuilder to return a non-null
value. |
ValueExtractor |
ExtractorBuilder.realize(String sCacheName,
int nTarget,
String sProperties)
Create a
ValueExtractor for the given cache name, target and property chain. |
Modifier and Type | Field and Description |
---|---|
static ParameterizedBuilder<ValueExtractor> |
FunctionBuilders.KEY_FUNCTION_BUILDER
This
ParameterizedBuilder handles the key() function. |
Modifier and Type | Method and Description |
---|---|
protected ValueExtractor |
AbstractCoherenceQueryWalker.buildExtractor(List<ValueExtractor> listExtractors)
Create a single
ValueExtractor from the List of
ValueExtractors. |
ValueExtractor |
PropertyBuilder.extractorFor(String sName)
Make a ValueExtractor for the given String.
|
ValueExtractor |
PropertyBuilder.extractorFor(String[] asProps)
Make a ValueExtractor for the given array of property Strings.
|
ValueExtractor |
SelectListMaker.getResultsAsValueExtractor()
Turn the results of tree processing into a ValueExtractor
|
ValueExtractor |
UpdateSetListMaker.makeValueExtractor(Object oValue)
Make a ValueExtractor out of the given Object.
|
Modifier and Type | Method and Description |
---|---|
protected ValueExtractor |
AbstractCoherenceQueryWalker.buildExtractor(List<ValueExtractor> listExtractors)
Create a single
ValueExtractor from the List of
ValueExtractors. |
Modifier and Type | Method and Description |
---|---|
ValueExtractor |
BaseOperator.makeExtractor(Object oLeft,
Object oRight)
Create a
ValueExtractor for this BaseOperator using the
specified left and right values. |
ValueExtractor |
BaseOperator.makeExtractor(Term termLeft,
Term termRight,
TermWalker walker)
|
Modifier and Type | Field and Description |
---|---|
protected ValueExtractor |
CreateIndexStatementBuilder.CreateIndexStatement.f_extractor
The
ValueExtractor to be used to create the index. |
protected ValueExtractor |
DropIndexStatementBuilder.DropIndexStatement.f_extractor
The
ValueExtractor to be used to create the index. |
Constructor and Description |
---|
CreateIndexStatement(String sCache,
ValueExtractor extractor)
Construct a CreateIndexStatement that will create an index on the
specified cache using the specified
ValueExtractor . |
DropIndexStatement(String sCacheName,
ValueExtractor extractor)
Construct a DropIndexStatement that will drop the index
created with the specified
ValueExtractor from the
cache with the specified name. |
Modifier and Type | Class and Description |
---|---|
static class |
PartitionedJCacheStatistics.CacheStatisticsExtractor
Get CacheStatistics from binEntry's context for JCache id.
|
Constructor and Description |
---|
PartitionedCacheStatisticsAggregator(JCacheIdentifier id,
ValueExtractor valueExtractor)
Constructs an aggregator to aggregate JCache Cache Statistics from
all storage-enabled servers for a JCache implemented as a Partitioned Cache.
|
PartitionedCacheStatisticsClear(JCacheIdentifier id,
ValueExtractor valueExtractor)
Constructs an aggregator to aggregate JCache Cache Statistics from
all storage-enabled servers for a JCache implemented as a Partitioned Cache.
|
Modifier and Type | Method and Description |
---|---|
protected Collection |
CacheResource.executeQuery(String sQuery,
ValueExtractor<Map.Entry,?> extractor,
int nStart,
int cResults,
String sSort)
Returns a collection of extracted values for cache entries that satisfy
the criteria expressed by the query.
|
protected Collection |
NamedQueryResource.executeQuery(javax.ws.rs.core.UriInfo uriInfo,
ValueExtractor<Map.Entry,?> extractor,
int nStart,
int cResults,
String sSort)
Returns a collection of extracted values for cache entries that satisfy
the criteria expressed by the query.
|
Modifier and Type | Method and Description |
---|---|
<E> Collection<E> |
Query.execute(NamedCache cache,
ValueExtractor<Map.Entry,? extends E> extractor,
String sOrder,
int nStart,
int cResults)
Return the values that satisfy this query.
|
Modifier and Type | Class and Description |
---|---|
class |
PropertySet<T>
Represents a set of named properties and allows the extraction of those
properties from a target object.
|
Modifier and Type | Field and Description |
---|---|
protected ValueExtractor |
PropertySpec.m_extractor
An extractor that can extract value of this property from a target
object.
|
protected ValueExtractor |
MvelManipulator.m_extractor
The underlying ValueExtractor.
|
Modifier and Type | Method and Description |
---|---|
protected ValueExtractor |
ComparatorBuilder.createExtractor(String sExpr)
Create expression extractor.
|
protected ValueExtractor |
PropertySpec.getExtractor()
Return extractor for this property.
|
ValueExtractor |
MvelManipulator.getExtractor()
Retrieve the underlying ValueExtractor reference.
|
Modifier and Type | Method and Description |
---|---|
ComparatorBuilder |
ComparatorBuilder.asc(ValueExtractor extractor)
Add comparator to this builder.
|
protected Comparator |
ComparatorBuilder.createComparator(ValueExtractor extractor)
Create extractor comparator.
|
ComparatorBuilder |
ComparatorBuilder.desc(ValueExtractor extractor)
Add comparator to this builder.
|
Modifier and Type | Method and Description |
---|---|
protected InvocableMap.EntryAggregator |
DefaultAggregatorFactory.createAggregator(ValueExtractor extractor)
Create and initialize a new aggregator instance.
|
Modifier and Type | Class and Description |
---|---|
class |
MvelExtractor
MVEL-based ValueExtractor implementation.
|
Modifier and Type | Method and Description |
---|---|
Map<ValueExtractor,MapIndex> |
BackingMapContext.getIndexMap()
Return a map of indexes defined for the
cache that
this BackingMapContext is associated with. |
Modifier and Type | Method and Description |
---|---|
ViewBuilder<K,V_BACK,V_FRONT> |
ViewBuilder.map(ValueExtractor<? super V_BACK,? extends V_FRONT> mapper)
The
ValueExtractor that this view will use to transform the results from
the underlying cache prior to storing them locally. |
Modifier and Type | Field and Description |
---|---|
protected ValueExtractor<? super V_BACK,? extends V_FRONT> |
ContinuousQueryCache.m_transformer
The transformer that should be used to convert values from the
underlying cache.
|
Modifier and Type | Method and Description |
---|---|
ValueExtractor<? super V_BACK,? extends V_FRONT> |
ContinuousQueryCache.getTransformer()
Obtain the transformer that this
ContinuousQueryCache is using to transform the results from
the underlying cache prior to storing them locally. |
Modifier and Type | Method and Description |
---|---|
<T,E> void |
WrapperNamedCache.addIndex(ValueExtractor<? super T,? extends E> extractor,
boolean fOrdered,
Comparator<? super E> comparator)
Add an index to this QueryMap.
|
<T,E> void |
NearCache.addIndex(ValueExtractor<? super T,? extends E> extractor,
boolean fOrdered,
Comparator<? super E> comparator)
Add an index to this QueryMap.
|
<T,E> void |
ContinuousQueryCache.addIndex(ValueExtractor<? super T,? extends E> extractor,
boolean fOrdered,
Comparator<? super E> comparator)
If
ContinuousQueryCache.isCacheValues() is true , the index will be created locally as well as
on the NamedCache this ContinuousQueryCache wraps, otherwise, the index will be
created on the wrapped NamedCache only. |
Object |
BackingMapBinaryEntry.extract(ValueExtractor extractor)
Extract a value out of the Entry's key or value.
|
protected static String |
ContinuousQueryCache.getDefaultName(String sCacheName,
Filter filter,
ValueExtractor transformer)
Return the default name used by the CQC.
|
<T,E> void |
WrapperNamedCache.removeIndex(ValueExtractor<? super T,? extends E> extractor)
Remove an index from this QueryMap.
|
<T,E> void |
NearCache.removeIndex(ValueExtractor<? super T,? extends E> extractor)
Remove an index from this QueryMap.
|
<T,E> void |
ContinuousQueryCache.removeIndex(ValueExtractor<? super T,? extends E> extractor)
If
ContinuousQueryCache.isCacheValues() is true , the index will be removed locally, however, this call
will not cause the index on the NamedCache this ContinuousQueryCache wraps. |
protected Map<K,V_FRONT> |
ContinuousQueryCache.transform(Set<Map.Entry<K,V_BACK>> setIn,
ValueExtractor<? super V_BACK,? extends V_FRONT> transformer)
Transform a set of entries.
|
Constructor and Description |
---|
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,
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. |
ContinuousQueryCache(Supplier<NamedCache<K,V_BACK>> supplierCache,
Filter filter,
boolean fCacheValues,
MapListener<? super K,? super V_FRONT> listener,
ValueExtractor<? super V_BACK,? extends V_FRONT> transformer,
ClassLoader loader)
Create a materialized view of a
NamedCache using a Filter . |
Modifier and Type | Class and Description |
---|---|
static class |
NullImplementation.NullValueExtractor
A ValueExtractor that always results in the passed-in value.
|
Modifier and Type | Field and Description |
---|---|
protected ValueExtractor |
ForwardOnlyMapIndex.f_extractor
ValueExtractor object that this MapIndex uses to extract an indexable
property value from a [converted] value stored in the resource map.
|
protected ValueExtractor |
SimpleMapIndex.m_extractor
ValueExtractor object that this MapIndex uses to extract an indexable
property value from a [converted] value stored in the resource map.
|
Modifier and Type | Method and Description |
---|---|
default <V> ValueExtractor<T,V> |
ValueExtractor.andThen(ValueExtractor<? super E,? extends V> after)
Returns a composed extractor that first applies this extractor to its
input, and then applies the
after extractor to the result. |
static <T,R> ValueExtractor<T,R> |
Extractors.chained(String... fields)
Returns an extractor that extracts the specified fields
where extraction occurs in a chain where the result of each
field extraction is the input to the next extractor.
|
static <T,R> ValueExtractor<T,R> |
Extractors.chained(ValueExtractor<?,?>... extractors)
Returns an extractor that extracts the specified fields
where extraction occurs in a chain where the result of each
field extraction is the input to the next extractor.
|
default <V> ValueExtractor<V,E> |
ValueExtractor.compose(ValueExtractor<? super V,? extends T> before)
Returns a composed extractor that first applies the
before
extractor to its input, and then applies this extractor to the result. |
static ValueExtractor |
QueryHelper.createExtractor(String s)
Make a new ValueExtractor from the given String.
|
static ValueExtractor |
QueryHelper.createExtractor(String sQuery,
CoherenceQueryLanguage language)
Make a new ValueExtractor from the given String.
|
static <T,E> ValueExtractor<T,E> |
Extractors.extract(String from)
Returns an extractor that extracts the value of the specified field.
|
static <T,E> ValueExtractor<T,E> |
Extractors.extract(String from,
Object... aoParam)
Returns an extractor that extracts the value of the specified field.
|
default ValueExtractor<T,E> |
ValueExtractor.fromKey()
Obtain a version of this
ValueExtractor that targets an entry's key. |
static <T,E> ValueExtractor<T,E> |
Extractors.fromPof(Class<E> cls,
int... indexes)
Returns an extractor that extracts the value of the specified index(es)
from a POF encoded binary value.
|
static <T,E> ValueExtractor<T,E> |
Extractors.fromPof(Class<E> cls,
PofNavigator navigator)
Returns an extractor that extracts the value of the specified index(es)
from a POF encoded binary value.
|
static <T> ValueExtractor<T,?> |
Extractors.fromPof(int... indexes)
Returns an extractor that extracts the value of the specified index(es)
from a POF encoded binary value.
|
ValueExtractor<T,V> |
ValueManipulator.getExtractor()
Retrieve the underlying ValueExtractor reference.
|
ValueExtractor<V,E> |
MapIndex.getValueExtractor()
Obtain the ValueExtractor object that the MapIndex uses to extract
an indexable Object from a value stored in the indexed Map.
|
ValueExtractor |
ForwardOnlyMapIndex.getValueExtractor()
Obtain the ValueExtractor object that the MapIndex uses to extract
an indexable Object from a value stored in the indexed Map.
|
ValueExtractor |
SimpleMapIndex.getValueExtractor()
Obtain the ValueExtractor object that the MapIndex uses to extract
an indexable Object from a value stored in the indexed Map.
|
static <T,E> ValueExtractor<T,E> |
NullImplementation.getValueExtractor()
Factory method: Obtain a null implementation of a ValueExtractor.
|
static <T> ValueExtractor<T,T> |
ValueExtractor.identity()
Returns an extractor that always returns its input argument.
|
static <T> ValueExtractor<T,T> |
Extractors.identity()
Returns an extractor that always returns its input argument.
|
static <T,E> ValueExtractor<T,E> |
ValueExtractor.identityCast()
Returns an extractor that casts its input argument.
|
static <T,E> ValueExtractor<T,E> |
Extractors.identityCast()
Returns an extractor that casts its input argument.
|
static <T> ValueExtractor<T,List<?>> |
Extractors.multi(String... fields)
Returns an extractor that extracts the specified fields
and returns the extracted values in a
List . |
static <T> ValueExtractor<T,List<?>> |
Extractors.multi(ValueExtractor<T,?>... extractors)
Returns an extractor that extracts values using the specified
ValueExtractor s and returns the extracted values in a List . |
static <T,E> ValueExtractor<T,E> |
ValueExtractor.of(ValueExtractor<T,E> extractor)
Helper method to allow composition/chaining of extractors.
|
static <T,E> ValueExtractor<T,E> |
Extractors.script(String sLanguage,
String sScriptPath,
Object... aoArgs)
Instantiate a
ValueExtractor that is implemented using the specified
language. |
Modifier and Type | Method and Description |
---|---|
<T,E> void |
QueryMap.addIndex(ValueExtractor<? super T,? extends E> extractor,
boolean fOrdered,
Comparator<? super E> comparator)
Add an index to this QueryMap.
|
<T,E> void |
ConverterCollections.ConverterQueryMap.addIndex(ValueExtractor<? super T,? extends E> extractor,
boolean fOrdered,
Comparator<? super E> comparator)
Add an index to this QueryMap.
|
<T,E> void |
ConverterCollections.ConverterNamedCache.addIndex(ValueExtractor<? super T,? extends E> extractor,
boolean fOrdered,
Comparator<? super E> comparator)
Add an index to this QueryMap.
|
static void |
InvocableMapHelper.addIndex(ValueExtractor extractor,
boolean fOrdered,
Comparator comparator,
ObservableMap map,
Map mapIndex)
Add an index to the given map of indexes, keyed by the given extractor.
|
default <V> ValueExtractor<T,V> |
ValueExtractor.andThen(ValueExtractor<? super E,? extends V> after)
Returns a composed extractor that first applies this extractor to its
input, and then applies the
after extractor to the result. |
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 <K,V,T> InvocableMap.StreamingAggregator<K,V,?,Double> |
Aggregators.average(ValueExtractor<? super T,? extends Number> extractor)
Return an aggregator that calculates a average of the numeric values extracted
from a set of entries in a Map.
|
static <T,E extends Comparable<? super E>> |
Filters.between(ValueExtractor<T,? extends E> extractor,
E from,
E to)
Return a filter that tests if the extracted value is between
the specified values (inclusive).
|
static <K,V,T> InvocableMap.StreamingAggregator<K,V,?,BigDecimal> |
Aggregators.bigDecimalAverage(ValueExtractor<? super T,? extends Number> extractor)
Return an aggregator that calculates a average of the numeric values extracted
from a set of entries in a Map.
|
static <K,V,T> InvocableMap.StreamingAggregator<K,V,?,BigDecimal> |
Aggregators.bigDecimalMax(ValueExtractor<? super T,? extends Number> extractor)
Return an aggregator that calculates a maximum of the numeric values extracted
from a set of entries in a Map.
|
static <K,V,T> InvocableMap.StreamingAggregator<K,V,?,BigDecimal> |
Aggregators.bigDecimalMin(ValueExtractor<? super T,? extends Number> extractor)
Return an aggregator that calculates a minimum of the numeric values extracted
from a set of entries in a Map.
|
static <K,V,T> InvocableMap.StreamingAggregator<K,V,?,BigDecimal> |
Aggregators.bigDecimalSum(ValueExtractor<? super T,? extends Number> extractor)
Return an aggregator that calculates a sum of the numeric values extracted
from a set of entries in a Map.
|
static <T,R> ValueExtractor<T,R> |
Extractors.chained(ValueExtractor<?,?>... extractors)
Returns an extractor that extracts the specified fields
where extraction occurs in a chain where the result of each
field extraction is the input to the next extractor.
|
static <K,V,T,R extends Comparable<? super R>> |
Aggregators.comparableMax(ValueExtractor<? super T,? extends R> extractor)
Return an aggregator that calculates a maximum of the
Comparable values
extracted from a set of entries in a Map. |
static <K,V,T,R extends Comparable<? super R>> |
Aggregators.comparableMax(ValueExtractor<? super T,? extends R> extractor,
Comparator<? super R> comparator)
Return an aggregator that calculates a maximum of the values extracted from a set
of entries in a Map.
|
static <K,V,T,R extends Comparable<? super R>> |
Aggregators.comparableMin(ValueExtractor<? super T,? extends R> extractor)
Return an aggregator that calculates a minimum of the
Comparable values
extracted from a set of entries in a Map. |
static <K,V,T,R extends Comparable<? super R>> |
Aggregators.comparableMin(ValueExtractor<? super T,? extends R> extractor,
Comparator<? super R> comparator)
Return an aggregator that calculates a minimum of the values extracted from a set
of entries in a Map.
|
default <V> ValueExtractor<V,E> |
ValueExtractor.compose(ValueExtractor<? super V,? extends T> before)
Returns a composed extractor that first applies the
before
extractor to its input, and then applies this extractor to the result. |
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 <K,V,T,R> InvocableMap.StreamingAggregator<K,V,?,Collection<R>> |
Aggregators.distinctValues(ValueExtractor<? super T,? extends R> extractor)
Return an aggregator that calculates the set of distinct values extracted from the entries in a Map.
|
static <K,V,T> InvocableMap.StreamingAggregator<K,V,?,Double> |
Aggregators.doubleMax(ValueExtractor<? super T,? extends Number> extractor)
Return an aggregator that calculates a maximum of the numeric values extracted
from a set of entries in a Map.
|
static <K,V,T> InvocableMap.StreamingAggregator<K,V,?,Double> |
Aggregators.doubleMin(ValueExtractor<? super T,? extends Number> extractor)
Return an aggregator that calculates a minimum of the numeric values extracted
from a set of entries in a Map.
|
static <K,V,T> InvocableMap.StreamingAggregator<K,V,?,Double> |
Aggregators.doubleSum(ValueExtractor<? super T,? extends Number> extractor)
Return an aggregator that calculates a sum of the numeric values extracted
from a set of entries in a Map.
|
static <T,E> Filter<T> |
Filters.equal(ValueExtractor<T,? extends E> extractor,
E value)
Return a filter that tests for equality.
|
Object |
ConverterCollections.ConverterMapEvent.ConverterMapEventBinaryEntry.extract(ValueExtractor extractor)
Depending upon the type of the ValueExtractor route the call
to the appropriate extract method.
|
Object |
InvocableMapHelper.RoutingMapTriggerEntry.extract(ValueExtractor extractor)
Extract a value out of the Entry's key or value.
|
static <K,V,T,R> InvocableMap.EntryProcessor<K,V,R> |
Processors.extract(ValueExtractor<? super T,? extends R> extractor)
Construct an extract processor based on the specified
ValueExtractor . |
<T,E> E |
SimpleMapEntry.extract(ValueExtractor<T,E> extractor)
Extract a value out of the Entry's key or value.
|
<T,E> E |
QueryMap.Entry.extract(ValueExtractor<T,E> extractor)
Extract a value out of the Entry's key or value.
|
static <T,E,K,V> E |
InvocableMapHelper.extractFromEntry(ValueExtractor<? super T,? extends E> extractor,
Map.Entry<? extends K,? extends V> entry)
Extract a value from the specified entry using the specified extractor.
|
default <E> E |
QueryMap.Entry.extractFromKey(ValueExtractor<? super K,E> extractor)
Extract a value out of the Entry's key.
|
default <E> E |
QueryMap.Entry.extractFromValue(ValueExtractor<? super V,E> extractor)
Extract a value out of the Entry's value.
|
static Object |
InvocableMapHelper.extractOriginalFromEntry(ValueExtractor extractor,
MapTrigger.Entry entry)
Extract a value from the "original value" of the specified entry using
the specified extractor.
|
static <T,E extends Comparable<? super E>> |
Filters.greater(ValueExtractor<T,? extends E> extractor,
E value)
Return a filter that tests if the extracted value is greater than the
specified value.
|
static <T,E extends Comparable<? super E>> |
Filters.greaterEqual(ValueExtractor<T,? extends E> extractor,
E value)
Return a filter that tests if the extracted value is greater than or equal
to the specified value.
|
static <K,V,T,E,R> |
Aggregators.grouping(ValueExtractor<? super T,? extends E> extractor,
InvocableMap.EntryAggregator<? super K,? super V,R> aggregator,
Filter filter)
Create an instance of group aggregator based on a specified property or method
name(s) and an
InvocableMap.EntryAggregator . |
static <K,V,T,E,R> |
Aggregators.grouping(ValueExtractor<? super T,? extends E> extractor,
InvocableMap.EntryAggregator<K,V,R> aggregator)
Create an instance of group aggregator based on a specified property or method
name(s) and an
InvocableMap.EntryAggregator . |
static <T,E> Filter<T> |
Filters.in(ValueExtractor<T,? extends E> extractor,
E... values)
Return a filter that tests if the extracted value is contained in the
specified array.
|
static <T,E> Filter<T> |
Filters.in(ValueExtractor<T,? extends E> extractor,
Set<? extends E> setValues)
Return a filter that tests if the extracted value is contained in the
specified set.
|
static <T,E> Filter<T> |
Filters.isNotNull(ValueExtractor<T,E> extractor)
Return a filter that evaluates to true for non-null values.
|
static <T,E> Filter<T> |
Filters.isNull(ValueExtractor<T,E> extractor)
Return a filter that evaluates to true for null values.
|
static <T,E extends Comparable<? super E>> |
Filters.less(ValueExtractor<T,? extends E> extractor,
E value)
Return a filter that tests if the extracted value is less than the
specified value.
|
static <T,E extends Comparable<? super E>> |
Filters.lessEqual(ValueExtractor<T,? extends E> extractor,
E value)
Return a filter that tests if the extracted value is less than or equal
to the specified value.
|
static <T,E> Filter<T> |
Filters.like(ValueExtractor<T,E> extractor,
String sPattern)
Return a LikeFilter for pattern match.
|
static <T,E> Filter<T> |
Filters.like(ValueExtractor<T,E> extractor,
String sPattern,
boolean fIgnoreCase)
Return a LikeFilter for pattern match.
|
static <T,E> Filter<T> |
Filters.like(ValueExtractor<T,E> extractor,
String sPattern,
char chEscape)
Return a LikeFilter for pattern match.
|
static <T,E> Filter<T> |
Filters.like(ValueExtractor<T,E> extractor,
String sPattern,
char chEscape,
boolean fIgnoreCase)
Return a LikeFilter for pattern match.
|
static <K,V,T> InvocableMap.StreamingAggregator<K,V,?,Long> |
Aggregators.longMax(ValueExtractor<? super T,? extends Number> extractor)
Return an aggregator that calculates a maximum of the numeric values extracted
from a set of entries in a Map.
|
static <K,V,T> InvocableMap.StreamingAggregator<K,V,?,Long> |
Aggregators.longMin(ValueExtractor<? super T,? extends Number> extractor)
Return an aggregator that calculates a minimum of the numeric values extracted
from a set of entries in a Map.
|
static <K,V,T> InvocableMap.StreamingAggregator<K,V,?,Long> |
Aggregators.longSum(ValueExtractor<? super T,? extends Number> extractor)
Return an aggregator that calculates a sum of the numeric values extracted
from a set of entries in a Map.
|
static <T> ValueExtractor<T,List<?>> |
Extractors.multi(ValueExtractor<T,?>... extractors)
Returns an extractor that extracts values using the specified
ValueExtractor s and returns the extracted values in a List . |
static <T,E> Filter<T> |
Filters.notEqual(ValueExtractor<T,? extends E> extractor,
E value)
Return a filter that tests for non-equality.
|
static <T,E> ValueExtractor<T,E> |
ValueExtractor.of(ValueExtractor<T,E> extractor)
Helper method to allow composition/chaining of extractors.
|
static <T,E> Filter<T> |
Filters.predicate(ValueExtractor<T,? extends E> extractor,
Remote.Predicate<? super E> predicate)
Return a PredicateFilter for a given
Predicate . |
void |
SimpleQueryRecord.PartialResult.AbstractRecordableStep.recordExtractor(ValueExtractor extractor)
Record all relevant index information for any index associated
with the given extractor (e.g. index lookup and range scan).
|
void |
QueryRecord.PartialResult.RecordableStep.recordExtractor(ValueExtractor extractor)
Record all relevant index information for any index associated
with the given extractor (e.g. index lookup and range scan).
|
static <K,V,T,R extends Comparable<? super R>> |
Aggregators.reduce(ValueExtractor<? super T,? extends R> extractor)
Return an aggregator that will return the extracted value for each entry in the map.
|
static <T,E> Filter<T> |
Filters.regex(ValueExtractor<T,E> extractor,
String sRegex)
Return a RegexFilter for pattern match.
|
<T,E> void |
QueryMap.removeIndex(ValueExtractor<? super T,? extends E> extractor)
Remove an index from this QueryMap.
|
<T,E> void |
ConverterCollections.ConverterQueryMap.removeIndex(ValueExtractor<? super T,? extends E> extractor)
Remove an index from this QueryMap.
|
<T,E> void |
ConverterCollections.ConverterNamedCache.removeIndex(ValueExtractor<? super T,? extends E> extractor)
Remove an index from this QueryMap.
|
static void |
InvocableMapHelper.removeIndex(ValueExtractor extractor,
ObservableMap map,
Map mapIndex)
Remove the index keyed by the given extractor from the given map of
indexes.
|
default <T,E> RemoteStream<E> |
InvocableMap.stream(Collection<? extends K> collKeys,
ValueExtractor<T,? extends E> extractor)
Return a stream of values extracted from the entries with the specified keys.
|
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 <T,E> RemoteStream<E> |
InvocableMap.stream(ValueExtractor<T,? extends E> extractor)
Return a stream of values extracted from the entries of this map.
|
static <K,V,T,R extends Comparable<? super R>> |
Aggregators.topN(ValueExtractor<? super T,? extends R> extractor,
Comparator<? super R> comparator,
int cResults)
Return an aggregator that calculates the top n of the values extracted from a set
of entries in a Map.
|
static <K,V,T,R extends Comparable<? super R>> |
Aggregators.topN(ValueExtractor<? super T,? extends R> extractor,
int cResults)
Return an aggregator that calculates the top n of the
Comparable values
extracted from a set of entries in a Map. |
Constructor and Description |
---|
ConditionalIndex(Filter filter,
ValueExtractor extractor,
boolean fOrdered,
Comparator comparator,
boolean fForwardIndex,
BackingMapContext ctx)
Construct a ConditionalIndex.
|
ForwardOnlyMapIndex(ValueExtractor extractor,
BackingMapContext ctx,
boolean fOnDemand)
Construct an index for the given map.
|
IndexLookupRecord(ValueExtractor extractor,
MapIndex index)
Construct an IndexLookupRecord.
|
SimpleMapIndex(ValueExtractor extractor,
boolean fOrdered,
Comparator comparator,
BackingMapContext ctx)
Construct an index for the given map.
|
SimpleMapIndex(ValueExtractor extractor,
boolean fOrdered,
Comparator comparator,
boolean fInit,
BackingMapContext ctx)
Construct an index for the given map.
|
Modifier and Type | Field and Description |
---|---|
protected ValueExtractor<? super T,? extends E> |
TopNAggregator.m_extractor
The ValueExtractor used by this aggregator.
|
protected ValueExtractor<? super T,? extends E> |
GroupAggregator.m_extractor
The underlying ValueExtractor.
|
Modifier and Type | Method and Description |
---|---|
ValueExtractor<?,? extends E> |
GroupAggregator.getExtractor()
Obtain the underlying ValueExtractor.
|
ValueExtractor<? super T,? extends E> |
AbstractAggregator.getValueExtractor()
Determine the ValueExtractor whose values this aggregator is
aggregating.
|
Modifier and Type | Method and Description |
---|---|
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. |
static <K,V,T,E,R> |
GroupAggregator.createInstance(ValueExtractor<? super T,? extends E> extractor,
InvocableMap.EntryAggregator<K,V,R> aggregator)
Create an instance of GroupAggregator based on a specified extractor and
an
EntryAggregator . |
Constructor and Description |
---|
AbstractAggregator(ValueExtractor<? super T,? extends E> extractor)
Construct an AbstractAggregator that will aggregate values extracted from
a set of
InvocableMap.Entry objects. |
AbstractBigDecimalAggregator(ValueExtractor<? super T,? extends Number> extractor)
Construct an AbstractBigDecimalAggregator object.
|
AbstractComparableAggregator(ValueExtractor<? super T,? extends E> extractor)
Construct an AbstractComparableAggregator object.
|
AbstractComparableAggregator(ValueExtractor<? super T,? extends R> extractor,
Comparator<? super R> comparator)
Construct an AbstractComparableAggregator object.
|
AbstractDoubleAggregator(ValueExtractor<? super T,? extends Number> extractor)
Construct an AbstractDoubleAggregator object.
|
AbstractLongAggregator(ValueExtractor<? super T,? extends Number> extractor)
Construct an AbstractLongAggregator object.
|
BigDecimalAverage(ValueExtractor<? super T,? extends Number> extractor)
Construct a BigDecimalAverage aggregator.
|
BigDecimalMax(ValueExtractor<? super T,? extends Number> extractor)
Construct a BigDecimalMax aggregator.
|
BigDecimalMin(ValueExtractor<? super T,? extends Number> extractor)
Construct a BigDecimalMin aggregator.
|
BigDecimalSum(ValueExtractor<? super T,? extends Number> extractor)
Construct a BigDecimalSum aggregator.
|
ComparableMax(ValueExtractor<? super T,? extends E> extractor)
Construct a ComparableMax aggregator.
|
ComparableMax(ValueExtractor<? super T,? extends R> extractor,
Comparator<? super R> comparator)
Construct a ComparableMax aggregator.
|
ComparableMin(ValueExtractor<? super T,? extends E> extractor)
Construct a ComparableMin aggregator.
|
ComparableMin(ValueExtractor<? super T,? extends R> extractor,
Comparator<? super R> comparator)
Construct a ComparableMin aggregator.
|
DistinctValues(ValueExtractor<? super T,? extends E> extractor)
Construct a DistinctValues aggregator.
|
DoubleAverage(ValueExtractor<? super T,? extends Number> extractor)
Construct a DoubleAverage aggregator.
|
DoubleMax(ValueExtractor<? super T,? extends Number> extractor)
Construct a DoubleMax aggregator.
|
DoubleMin(ValueExtractor<? super T,? extends Number> extractor)
Construct a DoubleMin aggregator.
|
DoubleSum(ValueExtractor<? super T,? extends Number> extractor)
Construct a DoubleSum aggregator.
|
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.
|
LongMax(ValueExtractor<? super T,? extends Number> extractor)
Construct a LongMax aggregator.
|
LongMin(ValueExtractor<? super T,? extends Number> extractor)
Construct a LongMin aggregator.
|
LongSum(ValueExtractor<? super T,? extends Number> extractor)
Construct a LongSum aggregator.
|
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.
|
ReducerAggregator(ValueExtractor<? super T,? extends E> extractor)
Construct a ReducerAggregator based on the specified extractor.
|
TopNAggregator(ValueExtractor<? super T,? extends E> extractor,
Comparator<? super E> comparator,
int cResults)
Construct a TopNAggregator that will aggregate the top extracted values,
as determined by the specified comparator.
|
Modifier and Type | Method and Description |
---|---|
ValueExtractor<? super T,? extends Comparable> |
ExtractorComparator.getExtractor()
Returns the
ValueExtractor to extract value(s) to be used in comparison. |
Constructor and Description |
---|
ExtractorComparator(ValueExtractor<? super T,? extends E> extractor)
Construct a ExtractorComparator with the specified extractor.
|
Modifier and Type | Interface and Description |
---|---|
interface |
IndexAwareExtractor<T,E>
IndexAwareExtractor is an extension to the
ValueExtractor interface
that supports the creation and destruction of an index . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractCompositeExtractor<T,E>
Abstract super class for ValueExtractor implementations that are based on
an underlying array of ValueExtractor objects.
|
class |
AbstractExtractor<T,E>
Abstract base for ValueExtractor implementations.
|
class |
ChainedExtractor<T,E>
Composite ValueExtractor implementation based on an array of extractors.
|
class |
ComparisonValueExtractor<T,E extends Number>
A synthetic ValueExtractor that returns a result of comparison between two
values extracted from the same target.
|
class |
ConditionalExtractor<T,E>
An IndexAwareExtractor implementation that is only used to create a
ConditionalIndex . |
class |
DeserializationAccelerator
DeserializationAccelerator is an
IndexAwareExtractor implementation that
is used to create a ForwardOnlyMapIndex , which in turn is used for
deserialization optimization. |
class |
EntryExtractor
The EntryExtractor is a base abstract class for special purpose custom
ValueExtractor implementations.
|
class |
IdentityExtractor<T>
Trivial ValueExtractor implementation that does not actually extract
anything from the passed value, but returns the value itself.
|
class |
KeyExtractor<T,E>
The KeyExtractor is a special purpose ValueExtractor implementation that
serves as an indicator that a query should be run against the key objects
rather than the values.
|
class |
MultiExtractor
Composite ValueExtractor implementation based on an array of extractors.
|
class |
PofExtractor<T,E>
POF-based ValueExtractor implementation.
|
class |
ReflectionExtractor<T,E>
Reflection-based ValueExtractor implementation.
|
class |
ScriptValueExtractor<T,E>
ScriptValueExtractor is an
AbstractExtractor that wraps a script
written in one of the languages supported by Graal VM. |
class |
UniversalExtractor<T,E>
Universal ValueExtractor implementation.
|
Modifier and Type | Field and Description |
---|---|
protected ValueExtractor[] |
AbstractCompositeExtractor.m_aExtractor
The ValueExtractor array.
|
protected ValueExtractor |
CompositeUpdater.m_extractor
The ValueExtractor part.
|
protected ValueExtractor<? super T,? extends E> |
KeyExtractor.m_extractor
The underlying ValueExtractor.
|
protected ValueExtractor |
DeserializationAccelerator.m_extractor
The underlying extractor.
|
protected ValueExtractor<T,E> |
ConditionalExtractor.m_extractor
The underlying extractor.
|
Modifier and Type | Method and Description |
---|---|
<V> ValueExtractor<T,V> |
ChainedExtractor.andThen(ValueExtractor<? super E,? extends V> after) |
<V> ValueExtractor<V,E> |
ChainedExtractor.compose(ValueExtractor<? super V,? extends T> before) |
static <T,E> ValueExtractor<T,E> |
UniversalExtractor.createExtractor(String sNames)
Return a ValueExtractor representing dot separated list of property
and/or method names.
|
static ValueExtractor[] |
ChainedExtractor.createExtractors(String sName)
Parse a dot-delimited sequence of method names and instantiate
a corresponding array of
ReflectionExtractor objects. |
static ValueExtractor[] |
MultiExtractor.createExtractors(String sNames)
Parse a comma-delimited sequence of method names and instantiate
a corresponding array of
ValueExtractor objects. |
ValueExtractor |
CompositeUpdater.getExtractor()
Retrieve the ValueExtractor part.
|
ValueExtractor<? super T,? extends E> |
KeyExtractor.getExtractor()
Obtain the underlying ValueExtractor.
|
ValueExtractor |
ConditionalExtractor.getExtractor() |
default ValueExtractor |
IndexAwareExtractor.getExtractor(Map<ValueExtractor<T,E>,MapIndex> mapIndex,
MapIndex index)
Obtain the underlying ValueExtractor that was added to the index map
during the
index creation . |
ValueExtractor[] |
AbstractCompositeExtractor.getExtractors()
Obtain the ValueExtractor array.
|
protected static ValueExtractor[] |
ChainedExtractor.merge(ValueExtractor[] aHead,
ValueExtractor[] aTail)
Return a
ValueExtractor array with the provided arrays merged
into a single array. |
static <T,E> ValueExtractor<T,E> |
KeyExtractor.of(ValueExtractor<T,E> extractor)
Factory method for key extractor.
|
Modifier and Type | Method and Description |
---|---|
<V> ValueExtractor<T,V> |
ChainedExtractor.andThen(ValueExtractor<? super E,? extends V> after) |
<V> ValueExtractor<V,E> |
ChainedExtractor.compose(ValueExtractor<? super V,? extends T> before) |
protected static ValueExtractor[] |
ChainedExtractor.merge(ValueExtractor[] aHead,
ValueExtractor[] aTail)
Return a
ValueExtractor array with the provided arrays merged
into a single array. |
protected static ValueExtractor[] |
ChainedExtractor.merge(ValueExtractor[] aHead,
ValueExtractor[] aTail)
Return a
ValueExtractor array with the provided arrays merged
into a single array. |
static <T,E> ValueExtractor<T,E> |
KeyExtractor.of(ValueExtractor<T,E> extractor)
Factory method for key extractor.
|
Modifier and Type | Method and Description |
---|---|
MapIndex |
IndexAwareExtractor.createIndex(boolean fOrdered,
Comparator comparator,
Map<ValueExtractor<T,E>,MapIndex> mapIndex,
BackingMapContext ctx)
Create an index and associate it with the corresponding extractor.
|
MapIndex |
ConditionalExtractor.createIndex(boolean fOrdered,
Comparator comparator,
Map<ValueExtractor<T,E>,MapIndex> mapIndex,
BackingMapContext ctx)
Create an index and associate it with the corresponding extractor.
|
MapIndex |
IndexAwareExtractor.destroyIndex(Map<ValueExtractor<T,E>,MapIndex> mapIndex)
Destroy an existing index and remove it from the given map of indexes.
|
MapIndex |
ConditionalExtractor.destroyIndex(Map<ValueExtractor<T,E>,MapIndex> mapIndex)
Destroy an existing index and remove it from the given map of indexes.
|
default ValueExtractor |
IndexAwareExtractor.getExtractor(Map<ValueExtractor<T,E>,MapIndex> mapIndex,
MapIndex index)
Obtain the underlying ValueExtractor that was added to the index map
during the
index creation . |
Constructor and Description |
---|
AbstractCompositeExtractor(ValueExtractor[] aExtractor)
Construct a AbstractCompositeExtractor based on the specified
ValueExtractor array.
|
ChainedExtractor(ValueExtractor[] aExtractor)
Construct a ChainedExtractor based on a specified ValueExtractor array.
|
ChainedExtractor(ValueExtractor<? super T,? extends U> extractor1,
ValueExtractor<? super U,? extends E> extractor2)
Construct a ChainedExtractor based on two extractors.
|
ChainedExtractor(ValueExtractor<? super T,? extends U> extractor1,
ValueExtractor<? super U,? extends E> extractor2)
Construct a ChainedExtractor based on two extractors.
|
ComparisonValueExtractor(ValueExtractor<T,E> ve1,
ValueExtractor<T,E> ve2)
Construct a ComparisonValueExtractor based on two specified extractors.
|
ComparisonValueExtractor(ValueExtractor<T,E> ve1,
ValueExtractor<T,E> ve2)
Construct a ComparisonValueExtractor based on two specified extractors.
|
ComparisonValueExtractor(ValueExtractor<T,E> ve1,
ValueExtractor<T,E> ve2,
Comparator<? super E> comp)
Construct a ComparisonValueExtractor based on two specified extractors and
a Comparator object.
|
ComparisonValueExtractor(ValueExtractor<T,E> ve1,
ValueExtractor<T,E> ve2,
Comparator<? super E> comp)
Construct a ComparisonValueExtractor based on two specified extractors and
a Comparator object.
|
CompositeUpdater(ValueExtractor extractor,
ValueUpdater updater)
Construct a CompositeUpdater based on the specified extractor and
updater.
|
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.
|
DeserializationAccelerator(ValueExtractor extractor)
Construct the DeserializationAccelerator.
|
DeserializationAccelerator(ValueExtractor extractor,
boolean fOnDemand)
Construct the DeserializationAccelerator.
|
KeyExtractor(ValueExtractor<? super T,? extends E> extractor)
Construct a KeyExtractor based on a specified ValueExtractor.
|
MultiExtractor(ValueExtractor[] aExtractor)
Construct a MultiExtractor.
|
Modifier and Type | Field and Description |
---|---|
protected ValueExtractor<? super T,? extends E> |
ExtractorFilter.m_extractor
The ValueExtractor used by this filter.
|
protected ValueExtractor<? super V,? extends E> |
ValueChangeEventFilter.m_extractor |
Modifier and Type | Method and Description |
---|---|
ValueExtractor<? super T,? extends E> |
ExtractorFilter.getValueExtractor()
Obtain the ValueExtractor used by this filter.
|
ValueExtractor |
BetweenFilter.getValueExtractor()
Obtain the ValueExtractor used by this filter.
|
Modifier and Type | Method and Description |
---|---|
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> 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.
|
Modifier and Type | Method and Description |
---|---|
<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.
|
<RK> int |
IndexAwareFilter.calculateEffectiveness(Map<? extends ValueExtractor<? extends V,Object>,? extends MapIndex<? extends RK,? extends V,Object>> mapIndexes,
Set<? extends RK> setKeys)
Given a Map of available indexes, determine if this IndexAwareFilter
can use any of the indexes to assist in its processing, and if so,
determine how effective the use of that index would be.
|
Constructor and Description |
---|
BetweenFilter(ValueExtractor<? super T,? extends E> extractor,
E from,
E to)
Construct a BetweenFilter for testing "Between" condition.
|
BetweenFilter(ValueExtractor<? super T,? extends E> extractor,
E lowerBound,
E upperBound,
boolean fIncludeLowerBound,
boolean fIncludeUpperBound)
Construct a BetweenFilter for testing "Between" condition.
|
ComparisonFilter(ValueExtractor<? super T,? extends E> extractor,
C value)
Construct a ComparisonFilter.
|
ContainsAllFilter(ValueExtractor<? super T,? extends E> extractor,
Set<?> setValues)
Construct an ContainsAllFilter for testing containment of the given Set
of values.
|
ContainsAnyFilter(ValueExtractor<? super T,? extends E> extractor,
Set<?> setValues)
Construct an ContainsAnyFilter for testing containment of any value in
the given Set.
|
ContainsFilter(ValueExtractor<? super T,? extends E> extractor,
E value)
Construct an ContainsFilter for testing containment of the given
object.
|
EqualsFilter(ValueExtractor<? super T,? extends E> extractor,
E value)
Construct an EqualsFilter for testing equality.
|
ExtractorFilter(ValueExtractor<? super T,? extends E> extractor)
Construct a ExtractorFilter for a given ValueExtractor.
|
GreaterEqualsFilter(ValueExtractor<? super T,? extends E> extractor,
E value)
Construct a GreaterEqualFilter for testing "Greater or Equal"
condition.
|
GreaterFilter(ValueExtractor<? super T,? extends E> extractor,
E value)
Construct a GreaterFilter for testing "Greater" condition.
|
InFilter(ValueExtractor<? super T,? extends E> extractor,
Set<? extends E> setValues)
Construct an InFilter for testing "In" condition.
|
IsNotNullFilter(ValueExtractor<? super T,? extends E> extractor)
Construct a IsNotNullFilter for testing inequality to null.
|
IsNullFilter(ValueExtractor<? super T,? extends E> extractor)
Construct a IsNullFilter for testing equality to null.
|
LessEqualsFilter(ValueExtractor<? super T,? extends E> extractor,
E value)
Construct a LessEqualsFilter for testing "Less or Equals" condition.
|
LessFilter(ValueExtractor<? super T,? extends E> extractor,
E value)
Construct a LessFilter for testing "Less" condition.
|
LikeFilter(ValueExtractor<? super T,? extends E> extractor,
String sPattern)
Construct a LikeFilter for pattern match.
|
LikeFilter(ValueExtractor<? super T,? extends E> extractor,
String sPattern,
char chEscape,
boolean fIgnoreCase)
Construct a LikeFilter for pattern match.
|
NotEqualsFilter(ValueExtractor<? super T,? extends E> extractor,
E value)
Construct a NotEqualsFilter for testing inequality.
|
PredicateFilter(ValueExtractor<? super T,? extends E> extractor,
Predicate<? super E> predicate)
Constructs a
PredicateFilter . |
RegexFilter(ValueExtractor<? super T,? extends E> extractor,
String sRegex)
Construct a RegexFilter for testing pattern matching.
|
ValueChangeEventFilter(ValueExtractor<? super V,? extends E> extractor)
Construct a ValueChangeEventFilter that evaluates MapEvent values
based on the specified extractor.
|
Modifier and Type | Field and Description |
---|---|
protected ValueExtractor<V,R> |
PropertyManipulator.m_extractor
The underlying ValueExtractor.
|
protected ValueExtractor<? super T,? extends E> |
ExtractorProcessor.m_extractor
The underlying value extractor.
|
Modifier and Type | Method and Description |
---|---|
ValueExtractor<V,R> |
PropertyManipulator.getExtractor()
Retrieve the underlying ValueExtractor reference.
|
Constructor and Description |
---|
ExtractorProcessor(ValueExtractor<? super T,? extends E> extractor)
Construct an ExtractorProcessor based on the specified ValueExtractor.
|
Modifier and Type | Method and Description |
---|---|
static <T,U> RemoteCollector<T,?,Double> |
RemoteCollectors.averagingDouble(ValueExtractor<? super U,? extends Number> extractor)
Returns a
Collector that produces the arithmetic mean of a
double-valued function applied to the input elements. |
static <T,U> RemoteCollector<T,?,Double> |
RemoteCollectors.averagingInt(ValueExtractor<? super U,? extends Number> extractor)
Returns a
Collector that produces the arithmetic mean of an
integer-valued function applied to the input elements. |
static <T,U> RemoteCollector<T,?,Double> |
RemoteCollectors.averagingLong(ValueExtractor<? super U,? extends Number> extractor)
Returns a
Collector that produces the arithmetic mean of a
long-valued function applied to the input elements. |
static <T,U,K> RemoteCollector<T,?,Map<K,List<T>>> |
RemoteCollectors.groupingBy(ValueExtractor<? super U,? extends K> classifier)
Returns a
Collector implementing a "group by" operation on input
elements of type T , grouping elements according to a
classification function, and returning the results in a Map . |
static <T,U,K,D,A,M extends Map<K,D>> |
RemoteCollectors.groupingBy(ValueExtractor<? super U,? extends K> extractor,
Remote.Supplier<M> mapFactory,
RemoteCollector<? super T,A,D> downstream)
Returns a
Collector implementing a cascaded "group by" operation
on input elements of type T , grouping elements according to a
classification function, and then performing a reduction operation on the
values associated with a given key using the specified downstream Collector . |
static <T,U,K,A,D> |
RemoteCollectors.groupingBy(ValueExtractor<? super U,? extends K> classifier,
RemoteCollector<? super T,A,D> downstream)
Returns a
Collector implementing a cascaded "group by" operation
on input elements of type T , grouping elements according to a
classification function, and then performing a reduction operation on the
values associated with a given key using the specified downstream Collector . |
default <R> RemoteStream<R> |
RemoteStream.map(ValueExtractor<? super T,? extends R> mapper)
Returns a stream consisting of the results of applying the given extractor
to the elements of this stream.
|
default RemoteDoubleStream |
RemoteStream.mapToDouble(ValueExtractor<? super T,? extends Number> mapper)
Returns an
DoubleStream consisting of the results of applying the
given extractor to the elements of this stream. |
default RemoteIntStream |
RemoteStream.mapToInt(ValueExtractor<? super T,? extends Number> mapper)
Returns an
IntStream consisting of the results of applying the
given extractor to the elements of this stream. |
default RemoteLongStream |
RemoteStream.mapToLong(ValueExtractor<? super T,? extends Number> mapper)
Returns an
LongStream consisting of the results of applying the
given extractor to the elements of this stream. |
default <U> Optional<T> |
RemoteStream.max(ValueExtractor<? super U,? extends Comparable> extractor)
Returns the maximum element of this stream according to the attribute
extracted by the provided
ValueExtractor . |
default <U> Optional<T> |
RemoteStream.min(ValueExtractor<? super U,? extends Comparable> extractor)
Returns the minimum element of this stream according to the attribute
extracted by the provided
ValueExtractor . |
default <U> RemoteStream<T> |
RemoteStream.sorted(ValueExtractor<? super U,? extends Comparable> extractor)
Returns a stream consisting of the elements of this stream, sorted
according to attribute extracted by the provided
ValueExtractor . |
default <U> RemoteStream<T> |
RemoteStream.sorted(ValueExtractor<? super U,? extends Comparable> extractor,
boolean fInverse)
Returns a stream consisting of the elements of this stream, sorted
according to attribute extracted by the provided
ValueExtractor . |
static <T,U> RemoteCollector<T,?,com.tangosol.internal.util.DoubleSummaryStatistics> |
RemoteCollectors.summarizingDouble(ValueExtractor<? super U,? extends Number> extractor)
Returns a
Collector which applies an double -producing
mapping function to each input element, and returns summary statistics
for the resulting values. |
static <T,U> RemoteCollector<T,?,com.tangosol.internal.util.IntSummaryStatistics> |
RemoteCollectors.summarizingInt(ValueExtractor<? super U,? extends Number> extractor)
Returns a
Collector which applies an int -producing
mapping function to each input element, and returns summary statistics
for the resulting values. |
static <T,U> RemoteCollector<T,?,com.tangosol.internal.util.LongSummaryStatistics> |
RemoteCollectors.summarizingLong(ValueExtractor<? super U,? extends Number> extractor)
Returns a
Collector which applies an long -producing
mapping function to each input element, and returns summary statistics
for the resulting values. |
static <T,U> RemoteCollector<T,?,Double> |
RemoteCollectors.summingDouble(ValueExtractor<? super U,? extends Number> extractor)
Returns a
Collector that produces the sum of a double-valued
function applied to the input elements. |
static <T,U> RemoteCollector<T,?,Integer> |
RemoteCollectors.summingInt(ValueExtractor<? super U,? extends Number> extractor)
Returns a
Collector that produces the sum of a integer-valued
function applied to the input elements. |
static <T,U> RemoteCollector<T,?,Long> |
RemoteCollectors.summingLong(ValueExtractor<? super U,? extends Number> extractor)
Returns a
Collector that produces the sum of a long-valued
function applied to the input elements. |
static <T,U1,U2,K,V> |
RemoteCollectors.toMap(ValueExtractor<? super U1,? extends K> keyMapper,
ValueExtractor<? super U2,? extends V> valueMapper)
Returns a
Collector that accumulates elements into a Map
whose keys and values are the result of applying the provided mapping
functions to the input elements. |
static <T,U1,U2,K,V> |
RemoteCollectors.toMap(ValueExtractor<? super U1,? extends K> keyMapper,
ValueExtractor<? super U2,? extends V> valueMapper)
Returns a
Collector that accumulates elements into a Map
whose keys and values are the result of applying the provided mapping
functions to the input elements. |
static <T,U1,U2,K,V> |
RemoteCollectors.toMap(ValueExtractor<? super U1,? extends K> keyMapper,
ValueExtractor<? super U2,? extends V> valueMapper,
Remote.BinaryOperator<V> mergeFunction)
Returns a
Collector that accumulates elements into a Map
whose keys and values are the result of applying the provided mapping
functions to the input elements. |
static <T,U1,U2,K,V> |
RemoteCollectors.toMap(ValueExtractor<? super U1,? extends K> keyMapper,
ValueExtractor<? super U2,? extends V> valueMapper,
Remote.BinaryOperator<V> mergeFunction)
Returns a
Collector that accumulates elements into a Map
whose keys and values are the result of applying the provided mapping
functions to the input elements. |
static <T,U1,U2,K,V,M extends Map<K,V>> |
RemoteCollectors.toMap(ValueExtractor<? super U1,? extends K> keyExtractor,
ValueExtractor<? super U2,? extends V> valueExtractor,
Remote.BinaryOperator<V> mergeFunction,
Remote.Supplier<M> mapSupplier)
Returns a
Collector that accumulates elements into a Map
whose keys and values are the result of applying the provided mapping
functions to the input elements. |
static <T,U1,U2,K,V,M extends Map<K,V>> |
RemoteCollectors.toMap(ValueExtractor<? super U1,? extends K> keyExtractor,
ValueExtractor<? super U2,? extends V> valueExtractor,
Remote.BinaryOperator<V> mergeFunction,
Remote.Supplier<M> mapSupplier)
Returns a
Collector that accumulates elements into a Map
whose keys and values are the result of applying the provided mapping
functions to the input elements. |
Modifier and Type | Method and Description |
---|---|
ValueExtractor |
ExtractorEventTransformer.getNewValueExtractor()
Return a ValueExtractor used to transfrom the event's NewValue.
|
ValueExtractor |
ExtractorEventTransformer.getOldValueExtractor()
Return a ValueExtractor used to transfrom the event's OldValue.
|
Constructor and Description |
---|
ExtractorEventTransformer(ValueExtractor<? super V,? extends E> extractor)
Construct a ExtractorEventTransformer that transforms MapEvent values
based on the specified extractor.
|
ExtractorEventTransformer(ValueExtractor<? super V,? extends E> extractorOld,
ValueExtractor<? super V,? extends E> extractorNew)
Construct a ExtractorEventTransformer that transforms MapEvent values
based on the specified extractors.
|
ExtractorEventTransformer(ValueExtractor<? super V,? extends E> extractorOld,
ValueExtractor<? super V,? extends E> extractorNew)
Construct a ExtractorEventTransformer that transforms MapEvent values
based on the specified extractors.
|