Uses of Interface
com.tangosol.util.ValueExtractor
-
Packages that use ValueExtractor Package Description com.oracle.coherence.cdi Coherence CDI provides support for CDI (Contexts and Dependency Injection) within Coherence cluster members.com.oracle.coherence.grpc.proxy The Coherence gRPC server implementation.com.oracle.coherence.repository Contains classes to enable Repository-like access to Coherence data.com.tangosol.coherence.config.scheme Defines the Coherence configuration object model classes and interfaces for Caching and Service Schemes.com.tangosol.coherence.dslquery Contains packages and classes supporting the Coherence CohQL command line tool.com.tangosol.coherence.dslquery.function This package contains builders for the various CohQL functions.com.tangosol.coherence.dslquery.operator This package contains implementations of theBaseOperator
interface.com.tangosol.coherence.dslquery.statement This package containsStatementBuilder
implementations.com.tangosol.coherence.federation Contains Federation conflict resolution interfaces.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 Contains packages and classes related to the Coherence REST API utilities.com.tangosol.coherence.rest.util.aggregator Contains classes related to REST-based aggregation.com.tangosol.coherence.rest.util.extractor Contains classes related to REST-based extractor.com.tangosol.net Contains basic cluster interfaces and factories.com.tangosol.net.cache Contains classes providing various caching strategies.com.tangosol.net.topic Contains classes that providing topic entities for publish/subscribe messaging.com.tangosol.util Contains various generic utilities.com.tangosol.util.aggregator Contains concreteInvocableMap.EntryAggregator
implementations.com.tangosol.util.comparator Contains concreteComparator
implementations and related interfaces.com.tangosol.util.extractor ContainsValueExtractor
andValueUpdater
related classes.com.tangosol.util.filter Contains concreteFilter
implementations and related interfaces.com.tangosol.util.function Contains Functional interfaces allowing remote execution of lambda expressions and method references.com.tangosol.util.processor Contains concreteInvocableMap.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 concreteMapEventTransformer
implementations. -
-
Uses of ValueExtractor in com.oracle.coherence.cdi
Methods in com.oracle.coherence.cdi that return ValueExtractor Modifier and Type Method Description ValueExtractor<T,E>
ExtractorFactory. create(A annotation)
Create aValueExtractor
instance.ValueExtractor<Object,Object>
ExtractorProducer.ChainedExtractorsSupplier. create(ChainedExtractor.Extractors annotation)
ValueExtractor<Object,Object>
ExtractorProducer.ChainedExtractorSupplier. create(ChainedExtractor annotation)
ValueExtractor<Object,Object>
ExtractorProducer.PofExtractorsSupplier. create(PofExtractor.Extractors annotation)
ValueExtractor<Object,Object>
ExtractorProducer.PofExtractorSupplier. create(PofExtractor annotation)
ValueExtractor<Object,Object>
ExtractorProducer.UniversalExtractorsSupplier. create(PropertyExtractor.Extractors annotation)
ValueExtractor<Object,Object>
ExtractorProducer.UniversalExtractorSupplier. create(PropertyExtractor annotation)
<T,E>
ValueExtractor<T,E>ExtractorProducer. getValueExtractor(javax.enterprise.inject.spi.InjectionPoint injectionPoint)
Create an instance of aValueExtractor
based on injection point metadata. -
Uses of ValueExtractor in com.oracle.coherence.grpc.proxy
Methods in com.oracle.coherence.grpc.proxy that return ValueExtractor Modifier and Type Method Description ValueExtractor<?,?>
NamedCacheServiceImpl. ensureValueExtractor(com.google.protobuf.ByteString bytes, Serializer serializer)
Obtain aValueExtractor
from the serialized data in aByteString
. -
Uses of ValueExtractor in com.oracle.coherence.repository
Methods in com.oracle.coherence.repository with parameters of type ValueExtractor Modifier and Type Method Description <R> CompletableFuture<Collection<? extends R>>
AbstractAsyncRepository. distinct(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor)
Return the set of distinct values for the specified extractor.<R> CompletableFuture<Collection<? extends R>>
AbstractAsyncRepository. distinct(ValueExtractor<? super T,? extends R> extractor)
Return the set of distinct values for the specified extractor.<R> Collection<? extends R>
AbstractRepository. distinct(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor)
Return the set of distinct values for the specified extractor.<R> Collection<? extends R>
AbstractRepository. distinct(ValueExtractor<? super T,? extends R> extractor)
Return the set of distinct values for the specified extractor.<R> CompletableFuture<R>
AbstractAsyncRepository. get(ID id, ValueExtractor<? super T,? extends R> extractor)
Return the value extracted from an entity with a given identifier.<R> R
AbstractRepository. get(ID id, ValueExtractor<? super T,? extends R> extractor)
Return the value extracted from an entity with a given identifier.<R> CompletableFuture<Map<ID,R>>
AbstractAsyncRepository. getAll(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor)
Return a map of values extracted from a set of entities based on the specified criteria.<R> CompletableFuture<Void>
AbstractAsyncRepository. getAll(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor, BiConsumer<? super ID,? super R> callback)
Streams the id and the associated extracted value from a set of entities based on the specified criteria.<R> CompletableFuture<Map<ID,R>>
AbstractAsyncRepository. getAll(ValueExtractor<? super T,? extends R> extractor)
Return a map of values extracted from all entities in the repository.<R> CompletableFuture<Void>
AbstractAsyncRepository. getAll(ValueExtractor<? super T,? extends R> extractor, BiConsumer<? super ID,? super R> callback)
Streams the id and the associated extracted value from all entities in the repository.<R> CompletableFuture<Map<ID,R>>
AbstractAsyncRepository. getAll(Collection<? extends ID> colIds, ValueExtractor<? super T,? extends R> extractor)
Return a map of values extracted from a set of entities with the given identifiers.<R> CompletableFuture<Void>
AbstractAsyncRepository. getAll(Collection<? extends ID> colIds, ValueExtractor<? super T,? extends R> extractor, BiConsumer<? super ID,? super R> callback)
Stream the entities associated with the specified ids to the provided callback.<R> Map<ID,R>
AbstractRepository. getAll(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor)
Return a map of values extracted from a set of entities based on the specified criteria.<R> Map<ID,R>
AbstractRepository. getAll(ValueExtractor<? super T,? extends R> extractor)
Return a map of values extracted from all entities in the repository.<R> Map<ID,R>
AbstractRepository. getAll(Collection<? extends ID> colIds, ValueExtractor<? super T,? extends R> extractor)
Return a map of values extracted from a set of entities with the given identifiers.<R extends Comparable<? super R>>
CompletableFuture<Collection<T>>AbstractAsyncRepository. getAllOrderedBy(Filter<?> filter, ValueExtractor<? super T,? extends R> orderBy)
Return all entities that satisfy the specified criteria, sorted using specifiedComparable
attribute.<R extends Comparable<? super R>>
CompletableFuture<Collection<T>>AbstractAsyncRepository. getAllOrderedBy(ValueExtractor<? super T,? extends R> orderBy)
Return all entities in this repository, sorted using specifiedComparable
attribute.<R extends Comparable<? super R>>
Collection<T>AbstractRepository. getAllOrderedBy(Filter<?> filter, ValueExtractor<? super T,? extends R> orderBy)
Return all entities that satisfy the specified criteria, sorted using specifiedComparable
attribute.<R extends Comparable<? super R>>
Collection<T>AbstractRepository. getAllOrderedBy(ValueExtractor<? super T,? extends R> orderBy)
Return all entities in this repository, sorted using specifiedComparable
attribute.<K> CompletableFuture<Map<K,Set<T>>>
AbstractAsyncRepository. groupBy(Filter<?> filter, ValueExtractor<? super T,? extends K> extractor)
Return the grouping of entities by the specified extractor.<K> CompletableFuture<Map<K,SortedSet<T>>>
AbstractAsyncRepository. groupBy(Filter<?> filter, ValueExtractor<? super T,? extends K> extractor, Remote.Comparator<? super T> orderBy)
Return the grouping of entities by the specified extractor, ordered by the specified attribute within each group.<K,A,R,M extends Map<K,R>>
CompletableFuture<M>AbstractAsyncRepository. groupBy(Filter<?> filter, ValueExtractor<? super T,? extends K> extractor, Remote.Supplier<M> mapFactory, RemoteCollector<? super T,A,R> collector)
Return the grouping of entities by the specified extractor.<K,A,R>
CompletableFuture<Map<K,R>>AbstractAsyncRepository. groupBy(Filter<?> filter, ValueExtractor<? super T,? extends K> extractor, RemoteCollector<? super T,A,R> collector)
Return the grouping of entities by the specified extractor.<K> CompletableFuture<Map<K,Set<T>>>
AbstractAsyncRepository. groupBy(ValueExtractor<? super T,? extends K> extractor)
Return the grouping of entities by the specified extractor.<K> CompletableFuture<Map<K,SortedSet<T>>>
AbstractAsyncRepository. groupBy(ValueExtractor<? super T,? extends K> extractor, Remote.Comparator<? super T> orderBy)
Return the grouping of entities by the specified extractor, ordered by the specified attribute within each group.<K,A,R,M extends Map<K,R>>
CompletableFuture<M>AbstractAsyncRepository. groupBy(ValueExtractor<? super T,? extends K> extractor, Remote.Supplier<M> mapFactory, RemoteCollector<? super T,A,R> collector)
Return the grouping of entities by the specified extractor.<K,A,R>
CompletableFuture<Map<K,R>>AbstractAsyncRepository. groupBy(ValueExtractor<? super T,? extends K> extractor, RemoteCollector<? super T,A,R> collector)
Return the grouping of entities by the specified extractor.<K> Map<K,Set<T>>
AbstractRepository. groupBy(Filter<?> filter, ValueExtractor<? super T,? extends K> extractor)
Return the grouping of entities by the specified extractor.<K> Map<K,SortedSet<T>>
AbstractRepository. groupBy(Filter<?> filter, ValueExtractor<? super T,? extends K> extractor, Remote.Comparator<? super T> orderBy)
Return the grouping of entities by the specified extractor, ordered by the specified attribute within each group.<K,A,R,M extends Map<K,R>>
MAbstractRepository. groupBy(Filter<?> filter, ValueExtractor<? super T,? extends K> extractor, Remote.Supplier<M> mapFactory, RemoteCollector<? super T,A,R> collector)
Return the grouping of entities by the specified extractor.<K,A,R>
Map<K,R>AbstractRepository. groupBy(Filter<?> filter, ValueExtractor<? super T,? extends K> extractor, RemoteCollector<? super T,A,R> collector)
Return the grouping of entities by the specified extractor.<K> Map<K,Set<T>>
AbstractRepository. groupBy(ValueExtractor<? super T,? extends K> extractor)
Return the grouping of entities by the specified extractor.<K> Map<K,SortedSet<T>>
AbstractRepository. groupBy(ValueExtractor<? super T,? extends K> extractor, Remote.Comparator<? super T> orderBy)
Return the grouping of entities by the specified extractor, ordered by the specified attribute within each group.<K,A,R,M extends Map<K,R>>
MAbstractRepository. groupBy(ValueExtractor<? super T,? extends K> extractor, Remote.Supplier<M> mapFactory, RemoteCollector<? super T,A,R> collector)
Return the grouping of entities by the specified extractor.<K,A,R>
Map<K,R>AbstractRepository. groupBy(ValueExtractor<? super T,? extends K> extractor, RemoteCollector<? super T,A,R> collector)
Return the grouping of entities by the specified extractor.<R extends Comparable<? super R>>
CompletableFuture<Optional<T>>AbstractAsyncRepository. maxBy(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor)
Return the entity with the maximum value of the specified function.<R extends Comparable<? super R>>
CompletableFuture<Optional<T>>AbstractAsyncRepository. maxBy(ValueExtractor<? super T,? extends R> extractor)
Return the entity with the maximum value of the specified function.<R extends Comparable<? super R>>
Optional<T>AbstractRepository. maxBy(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor)
Return the entity with the maximum value of the specified function.<R extends Comparable<? super R>>
Optional<T>AbstractRepository. maxBy(ValueExtractor<? super T,? extends R> extractor)
Return the entity with the maximum value of the specified function.<R extends Comparable<? super R>>
CompletableFuture<Optional<T>>AbstractAsyncRepository. minBy(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor)
Return the entity with the minimum value of the specified function.<R extends Comparable<? super R>>
CompletableFuture<Optional<T>>AbstractAsyncRepository. minBy(ValueExtractor<? super T,? extends R> extractor)
Return the entity with the minimum value of the specified function.<R extends Comparable<? super R>>
Optional<T>AbstractRepository. minBy(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor)
Return the entity with the minimum value of the specified function.<R extends Comparable<? super R>>
Optional<T>AbstractRepository. minBy(ValueExtractor<? super T,? extends R> extractor)
Return the entity with the minimum value of the specified function.<R extends Comparable<? super R>>
CompletableFuture<List<R>>AbstractAsyncRepository. top(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor, int cResults)
Return the top N highest values for the specified extractor.<R> CompletableFuture<List<R>>
AbstractAsyncRepository. top(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor, Remote.Comparator<? super R> comparator, int cResults)
Return the top N highest values for the specified extractor.<R extends Comparable<? super R>>
CompletableFuture<List<R>>AbstractAsyncRepository. top(ValueExtractor<? super T,? extends R> extractor, int cResults)
Return the top N highest values for the specified extractor.<R> CompletableFuture<List<R>>
AbstractAsyncRepository. top(ValueExtractor<? super T,? extends R> extractor, Remote.Comparator<? super R> comparator, int cResults)
Return the top N highest values for the specified extractor.<R extends Comparable<? super R>>
List<R>AbstractRepository. top(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor, int cResults)
Return the top N highest values for the specified extractor.<R> List<R>
AbstractRepository. top(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor, Remote.Comparator<? super R> comparator, int cResults)
Return the top N highest values for the specified extractor.<R extends Comparable<? super R>>
List<R>AbstractRepository. top(ValueExtractor<? super T,? extends R> extractor, int cResults)
Return the top N highest values for the specified extractor.<R> List<R>
AbstractRepository. top(ValueExtractor<? super T,? extends R> extractor, Remote.Comparator<? super R> comparator, int cResults)
Return the top N highest values for the specified extractor.<R extends Comparable<? super R>>
CompletableFuture<List<T>>AbstractAsyncRepository. topBy(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor, int cResults)
Return the top N entities with the highest values for the specified extractor.<R extends Comparable<? super R>>
CompletableFuture<List<T>>AbstractAsyncRepository. topBy(ValueExtractor<? super T,? extends R> extractor, int cResults)
Return the top N entities with the highest values for the specified extractor.<R extends Comparable<? super R>>
List<T>AbstractRepository. topBy(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor, int cResults)
Return the top N entities with the highest values for the specified extractor.<R extends Comparable<? super R>>
List<T>AbstractRepository. topBy(ValueExtractor<? super T,? extends R> extractor, int cResults)
Return the top N entities with the highest values for the specified extractor. -
Uses of ValueExtractor in com.tangosol.coherence.config.scheme
Methods in com.tangosol.coherence.config.scheme that return types with arguments of type ValueExtractor Modifier and Type Method Description ParameterizedBuilder<ValueExtractor>
ContinuousQueryCacheScheme. getTransformerBuilder()
Return theParameterizedBuilder
used to construct theValueExtractor
to be used as a transformer by theContinuousQueryCache
.Method parameters in com.tangosol.coherence.config.scheme with type arguments of type ValueExtractor Modifier and Type Method Description void
ContinuousQueryCacheScheme. setTransformerBuilder(ParameterizedBuilder<ValueExtractor> transformerBuilder)
Set theParameterizedBuilder
used to construct theValueExtractor
to be used as a transformer by theContinuousQueryCache
. -
Uses of ValueExtractor in com.tangosol.coherence.dslquery
Methods in com.tangosol.coherence.dslquery that return ValueExtractor Modifier and Type Method Description ValueExtractor
FilterBuilder. makeExtractor(NodeTerm term)
Process the AST Tree using the given Term that represents getter.ValueExtractor
ChainedExtractorBuilder. realize(String sCacheName, int nTarget, String sProperties)
Call the realize(String, int, String) method on eachExtractorBuilder
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 aValueExtractor
for the given cache name, target and property chain.ValueExtractor
ReflectionExtractorBuilder. realize(String sCacheName, int nTarget, String sProperties)
ValueExtractor
UniversalExtractorBuilder. realize(String sCacheName, int nTarget, String sProperties)
-
Uses of ValueExtractor in com.tangosol.coherence.dslquery.function
Fields in com.tangosol.coherence.dslquery.function with type parameters of type ValueExtractor Modifier and Type Field Description static ParameterizedBuilder<ValueExtractor>
FunctionBuilders. KEY_FUNCTION_BUILDER
ThisParameterizedBuilder
handles the key() function. -
Uses of ValueExtractor in com.tangosol.coherence.dslquery.operator
Methods in com.tangosol.coherence.dslquery.operator that return ValueExtractor Modifier and Type Method Description ValueExtractor
BaseOperator. makeExtractor(Term termLeft, Term termRight, TermWalker walker)
ValueExtractor
BaseOperator. makeExtractor(Object oLeft, Object oRight)
Create aValueExtractor
for thisBaseOperator
using the specified left and right values. -
Uses of ValueExtractor in com.tangosol.coherence.dslquery.statement
Fields in com.tangosol.coherence.dslquery.statement declared as ValueExtractor Modifier and Type Field Description protected ValueExtractor
CreateIndexStatementBuilder.CreateIndexStatement. f_extractor
TheValueExtractor
to be used to create the index.protected ValueExtractor
DropIndexStatementBuilder.DropIndexStatement. f_extractor
TheValueExtractor
to be used to create the index.Constructors in com.tangosol.coherence.dslquery.statement with parameters of type ValueExtractor Constructor Description CreateIndexStatement(String sCache, ValueExtractor extractor)
Construct a CreateIndexStatement that will create an index on the specified cache using the specifiedValueExtractor
.DropIndexStatement(String sCacheName, ValueExtractor extractor)
Construct a DropIndexStatement that will drop the index created with the specifiedValueExtractor
from the cache with the specified name. -
Uses of ValueExtractor in com.tangosol.coherence.federation
Methods in com.tangosol.coherence.federation with parameters of type ValueExtractor Modifier and Type Method Description <T> T
ChangeRecord.Entry. extract(ValueExtractor<V,T> extractor)
Extract a value from the entry value using theValueExtractor
. -
Uses of ValueExtractor in com.tangosol.coherence.jcache.partitionedcache
Classes in com.tangosol.coherence.jcache.partitionedcache that implement ValueExtractor Modifier and Type Class Description static class
PartitionedJCacheStatistics.CacheStatisticsExtractor
Get CacheStatistics from binEntry's context for JCache id.Constructors in com.tangosol.coherence.jcache.partitionedcache with parameters of type ValueExtractor Constructor 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. -
Uses of ValueExtractor in com.tangosol.coherence.rest
Methods in com.tangosol.coherence.rest with parameters of type ValueExtractor Modifier and Type Method 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. -
Uses of ValueExtractor in com.tangosol.coherence.rest.query
Methods in com.tangosol.coherence.rest.query with parameters of type ValueExtractor Modifier and Type Method 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. -
Uses of ValueExtractor in com.tangosol.coherence.rest.util
Classes in com.tangosol.coherence.rest.util that implement ValueExtractor Modifier and Type Class Description class
PropertySet<T>
Represents a set of named properties and allows the extraction of those properties from a target object.Fields in com.tangosol.coherence.rest.util declared as ValueExtractor Modifier and Type Field Description protected ValueExtractor
MvelManipulator. m_extractor
The underlying ValueExtractor.protected ValueExtractor
PropertySpec. m_extractor
An extractor that can extract value of this property from a target object.Methods in com.tangosol.coherence.rest.util that return ValueExtractor Modifier and Type Method Description protected ValueExtractor
ComparatorBuilder. createExtractor(String sExpr)
Create expression extractor.ValueExtractor
MvelManipulator. getExtractor()
Retrieve the underlying ValueExtractor reference.protected ValueExtractor
PropertySpec. getExtractor()
Return extractor for this property.Methods in com.tangosol.coherence.rest.util with parameters of type ValueExtractor Modifier and Type Method 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. -
Uses of ValueExtractor in com.tangosol.coherence.rest.util.aggregator
Methods in com.tangosol.coherence.rest.util.aggregator with parameters of type ValueExtractor Modifier and Type Method Description protected InvocableMap.EntryAggregator
DefaultAggregatorFactory. createAggregator(ValueExtractor extractor)
Create and initialize a new aggregator instance. -
Uses of ValueExtractor in com.tangosol.coherence.rest.util.extractor
Classes in com.tangosol.coherence.rest.util.extractor that implement ValueExtractor Modifier and Type Class Description class
MvelExtractor
MVEL-based ValueExtractor implementation. -
Uses of ValueExtractor in com.tangosol.net
Fields in com.tangosol.net declared as ValueExtractor Modifier and Type Field Description protected ValueExtractor<? super V,?>
MapViewBuilder. m_mapper
TheValueExtractor
that will be used to transform values retrieved from the underlying map before storing them locally; if specified, thisview
will becomeread-only
.Methods in com.tangosol.net that return types with arguments of type ValueExtractor Modifier and Type Method Description Map<ValueExtractor,MapIndex>
BackingMapContext. getIndexMap()
Return a map of indexes defined for all partitions of thecache
that this BackingMapContext is associated with.default Map<ValueExtractor,MapIndex>
BackingMapContext. getIndexMap(int nPartition)
Return a map of indexes defined for the specified partition of thecache
that this BackingMapContext is associated with.Map<ValueExtractor,MapIndex>
BackingMapContext. getIndexMap(PartitionSet partitions)
Return a map of indexes defined for the specified partitions of thecache
that this BackingMapContext is associated with.Methods in com.tangosol.net with parameters of type ValueExtractor Modifier and Type Method Description default long
PagedTopicService. ensureSubscriberGroup(String sTopicName, String sGroupName, Filter<?> filter, ValueExtractor<?,?> extractor)
Ensure the specified subscriber group is created in a subscription.long
PagedTopicService. ensureSubscription(String sTopicName, com.tangosol.internal.net.topic.impl.paged.model.SubscriberGroupId groupId, Subscriber.Id subscriberId, Filter<?> filter, ValueExtractor<?,?> extractor)
Ensure the specified subscriber is created in a subscription.<U> MapViewBuilder<K,U>
MapViewBuilder. map(ValueExtractor<? super V,? extends U> mapper)
TheValueExtractor
that thisview
will use to transform the results from the underlying map prior to storing them locally.<U> ViewBuilder<K,U>
ViewBuilder. map(ValueExtractor<? super V,? extends U> mapper)
TheValueExtractor
that thisview
will use to transform the results from the underlying cache prior to storing them locally. -
Uses of ValueExtractor in com.tangosol.net.cache
Fields in com.tangosol.net.cache declared as ValueExtractor Modifier and Type Field 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.Methods in com.tangosol.net.cache that return ValueExtractor Modifier and Type Method Description ValueExtractor<? super V_BACK,? extends V_FRONT>
ContinuousQueryCache. getTransformer()
Obtain the transformer that thisContinuousQueryCache
is using to transform the results from the underlying cache prior to storing them locally.Methods in com.tangosol.net.cache with parameters of type ValueExtractor Modifier and Type Method Description <T,E>
voidContinuousQueryCache. addIndex(ValueExtractor<? super T,? extends E> extractor, boolean fOrdered, Comparator<? super E> comparator)
IfContinuousQueryCache.isCacheValues()
istrue
, the index will be created locally as well as on theNamedCache
thisContinuousQueryCache
wraps, otherwise, the index will be created on the wrappedNamedCache
only.<T,E>
voidNearCache. addIndex(ValueExtractor<? super T,? extends E> extractor, boolean fOrdered, Comparator<? super E> comparator)
Add an index to this QueryMap.<T,E>
voidWrapperNamedCache. addIndex(ValueExtractor<? super T,? extends E> extractor, boolean fOrdered, Comparator<? super E> comparator)
Add an index to this QueryMap.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>
voidContinuousQueryCache. removeIndex(ValueExtractor<? super T,? extends E> extractor)
IfContinuousQueryCache.isCacheValues()
istrue
, the index will be removed locally, however, this call will not cause the index on theNamedCache
thisContinuousQueryCache
wraps.<T,E>
voidNearCache. removeIndex(ValueExtractor<? super T,? extends E> extractor)
Remove an index from this QueryMap.<T,E>
voidWrapperNamedCache. removeIndex(ValueExtractor<? super T,? extends E> extractor)
Remove an index from this QueryMap.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.Constructors in com.tangosol.net.cache with parameters of type ValueExtractor Constructor 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 aNamedCache
using aFilter
.ContinuousQueryCache(NamedCache<K,V_BACK> cache, Filter filter, ValueExtractor<? super V_BACK,? extends V_FRONT> transformer)
Create a locally materialized view of aNamedCache
using aFilter
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 aNamedCache
using aFilter
. -
Uses of ValueExtractor in com.tangosol.net.topic
Methods in com.tangosol.net.topic that return ValueExtractor Modifier and Type Method Description ValueExtractor<? super V,U>
Subscriber.Convert. getExtractor()
Return the option's converter function.Methods in com.tangosol.net.topic with parameters of type ValueExtractor Modifier and Type Method Description void
NamedTopic. ensureSubscriberGroup(String sGroup, Filter<?> filter, ValueExtractor<?,?> extractor)
Ensure that the specified subscriber group exists for this topic.static <V,U>
Subscriber.Convert<V,U>Subscriber.Convert. using(ValueExtractor<? super V,U> extractor)
Return a Convert option with the specified extractor.static <V,U>
Subscriber.Convert<V,U>Subscriber. withConverter(ValueExtractor<? super V,U> extractor)
Return a Convert option with the specified extractor.Constructors in com.tangosol.net.topic with parameters of type ValueExtractor Constructor Description Convert(ValueExtractor<? super V,U> extractor)
-
Uses of ValueExtractor in com.tangosol.util
Classes in com.tangosol.util that implement ValueExtractor Modifier and Type Class Description static class
NullImplementation.NullValueExtractor
A ValueExtractor that always results in the passed-in value.Fields in com.tangosol.util declared as ValueExtractor Modifier and Type Field 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.Methods in com.tangosol.util that return ValueExtractor Modifier and Type Method 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 theafter
extractor to the result.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 <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.default <V> ValueExtractor<V,E>
ValueExtractor. compose(ValueExtractor<? super V,? extends T> before)
Returns a composed extractor that first applies thebefore
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.static <T,E>
ValueExtractor<T,E>ValueExtractor. forMethod(Method method)
Return aValueExtractor
for the specifiedMethod
.static <T> ValueExtractor<T,Fragment<T>>
Extractors. fragment(ValueExtractor<? super T,?>... aExtractors)
Return aValueExtractor
that extracts aFragment
from a target object.static <T,E>
ValueExtractor<T,Fragment<E>>Extractors. fragment(ValueExtractor<? super T,E> from, ValueExtractor<? super E,?>... aExtractors)
Return aValueExtractor
that extracts a nestedFragment
from a property of the target object.default ValueExtractor<T,E>
ValueExtractor. fromKey()
Obtain a version of thisValueExtractor
that targets an entry's key.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.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,E>
ValueExtractor<T,E>Extractors. fromPof(Class<E> cls, String sPath)
Returns an extractor that extracts the value of the specified index(es) from a POF encoded@PortableType
.ValueExtractor<T,V>
ValueManipulator. getExtractor()
Retrieve the underlying ValueExtractor reference.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<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.static <T,E>
ValueExtractor<T,E>NullImplementation. getValueExtractor()
Factory method: Obtain a null implementation of a ValueExtractor.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> ValueExtractor<T,T>
Extractors. identity()
Returns an extractor that always returns its input argument.static <T> ValueExtractor<T,T>
ValueExtractor. identity()
Returns an extractor that always returns its input argument.static <T,E>
ValueExtractor<T,E>Extractors. identityCast()
Returns an extractor that casts its input argument.static <T,E>
ValueExtractor<T,E>ValueExtractor. identityCast()
Returns an extractor that casts its input argument.static <T> ValueExtractor<T,List<?>>
Extractors. multi(ValueExtractor<T,?>... extractors)
Returns an extractor that extracts values using the specifiedValueExtractor
s and returns the extracted values in aList
.static <T> ValueExtractor<T,List<?>>
Extractors. multi(String... fields)
Returns an extractor that extracts the specified fields and returns the extracted values in aList
.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 aValueExtractor
that is implemented using the specified language.Methods in com.tangosol.util that return types with arguments of type ValueExtractor Modifier and Type Method Description default Map<ValueExtractor,MapIndex>
BinaryEntry. getIndexMap()
Return a map of indexes defined for the partition of thecache
that this BinaryEntry belongs to.Methods in com.tangosol.util with parameters of type ValueExtractor Modifier and Type Method Description <T,E>
voidConverterCollections.ConverterNamedCache. addIndex(ValueExtractor<? super T,? extends E> extractor, boolean fOrdered, Comparator<? super E> comparator)
Add an index to this QueryMap.<T,E>
voidConverterCollections.ConverterQueryMap. 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 <T,E>
voidQueryMap. addIndex(ValueExtractor<? super T,? extends E> extractor)
Add an unordered index to this QueryMap.<T,E>
voidQueryMap. addIndex(ValueExtractor<? super T,? extends E> extractor, boolean fOrdered, Comparator<? super E> comparator)
Add an index to this QueryMap.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 theafter
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>>
Filter<T>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>>
InvocableMap.StreamingAggregator<K,V,?,R>Aggregators. comparableMax(ValueExtractor<? super T,? extends R> extractor)
Return an aggregator that calculates a maximum of theComparable
values extracted from a set of entries in a Map.static <K,V,T,R extends Comparable<? super R>>
InvocableMap.StreamingAggregator<K,V,?,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>>
InvocableMap.StreamingAggregator<K,V,?,R>Aggregators. comparableMin(ValueExtractor<? super T,? extends R> extractor)
Return an aggregator that calculates a minimum of theComparable
values extracted from a set of entries in a Map.static <K,V,T,R extends Comparable<? super R>>
InvocableMap.StreamingAggregator<K,V,?,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 thebefore
extractor to its input, and then applies this extractor to the result.static <T,E,C extends Collection<? extends E>>
Filter<T>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>>
Filter<T>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>>
Filter<T>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>>
Filter<T>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>>
Filter<T>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.<T,E>
EConverterCollections.ConverterMapEvent.ConverterMapEventBinaryEntry. extract(ValueExtractor<T,E> 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 specifiedValueExtractor
.<T,E>
EQueryMap.Entry. extract(ValueExtractor<T,E> extractor)
Extract a value out of the Entry's key or value.<T,E>
ESimpleMapEntry. extract(ValueExtractor<T,E> extractor)
Extract a value out of the Entry's key or value.static <T,E,K,V>
EInvocableMapHelper. 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> ValueExtractor<T,Fragment<T>>
Extractors. fragment(ValueExtractor<? super T,?>... aExtractors)
Return aValueExtractor
that extracts aFragment
from a target object.static <T,E>
ValueExtractor<T,Fragment<E>>Extractors. fragment(ValueExtractor<? super T,E> from, ValueExtractor<? super E,?>... aExtractors)
Return aValueExtractor
that extracts a nestedFragment
from a property of the target object.<E> E
Fragment. get(ValueExtractor<? super T,? extends E> extractor)
Get the value of the attribute extracted by the specified extractor.<E> Fragment<E>
Fragment. getFragment(ValueExtractor<? super T,? extends E> extractor)
Get the nested fragment extracted from the specified attribute.static <T,E extends Comparable<? super E>>
Filter<T>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>>
Filter<T>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>
InvocableMap.StreamingAggregator<K,V,Map<E,Object>,Map<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 anInvocableMap.EntryAggregator
.static <K,V,T,E,R>
InvocableMap.StreamingAggregator<K,V,Map<E,Object>,Map<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 anInvocableMap.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> Filter<T>
Filters. isFalse(ValueExtractor<T,Boolean> extractor)
Return a filter that evaluates to true if the extracted value isfalse
.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> Filter<T>
Filters. isTrue(ValueExtractor<T,Boolean> extractor)
Return a filter that evaluates to true if the extracted value istrue
.static <T,E extends Comparable<? super E>>
Filter<T>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>>
Filter<T>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 specifiedValueExtractor
s and returns the extracted values in aList
.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 givenPredicate
.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).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).static <K,V,T,R extends Comparable<? super R>>
InvocableMap.StreamingAggregator<K,V,?,Map<K,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>
voidConverterCollections.ConverterNamedCache. removeIndex(ValueExtractor<? super T,? extends E> extractor)
Remove an index from this QueryMap.<T,E>
voidConverterCollections.ConverterQueryMap. 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.<T,E>
voidQueryMap. removeIndex(ValueExtractor<? super T,? extends E> extractor)
Remove an index from this QueryMap.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.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.static <K,V,T,R extends Comparable<? super R>>
InvocableMap.StreamingAggregator<K,V,?,R[]>Aggregators. topN(ValueExtractor<? super T,? extends R> extractor, int cResults)
Return an aggregator that calculates the top n of theComparable
values extracted from a set of entries in a Map.static <K,V,T,R>
InvocableMap.StreamingAggregator<K,V,?,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.Constructors in com.tangosol.util with parameters of type ValueExtractor Constructor 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, boolean fInit, BackingMapContext ctx)
Construct an index for the given map.SimpleMapIndex(ValueExtractor extractor, boolean fOrdered, Comparator comparator, BackingMapContext ctx)
Construct an index for the given map. -
Uses of ValueExtractor in com.tangosol.util.aggregator
Fields in com.tangosol.util.aggregator declared as ValueExtractor Modifier and Type Field Description protected ValueExtractor<? super T,? extends E>
GroupAggregator. m_extractor
The underlying ValueExtractor.protected ValueExtractor<? super T,? extends E>
TopNAggregator. m_extractor
The ValueExtractor used by this aggregator.Methods in com.tangosol.util.aggregator that return ValueExtractor Modifier and Type Method 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.Methods in com.tangosol.util.aggregator with parameters of type ValueExtractor Modifier and Type Method Description static <K,V,T,E,R>
GroupAggregator<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 anEntryAggregator
and a result evaluation filter.static <K,V,T,E,R>
GroupAggregator<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 anEntryAggregator
.Constructors in com.tangosol.util.aggregator with parameters of type ValueExtractor Constructor Description AbstractAggregator(ValueExtractor<? super T,? extends E> extractor)
Construct an AbstractAggregator that will aggregate values extracted from a set ofInvocableMap.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. -
Uses of ValueExtractor in com.tangosol.util.comparator
Methods in com.tangosol.util.comparator that return ValueExtractor Modifier and Type Method Description ValueExtractor<? super T,? extends Comparable>
ExtractorComparator. getExtractor()
Returns theValueExtractor
to extract value(s) to be used in comparison.Constructors in com.tangosol.util.comparator with parameters of type ValueExtractor Constructor Description ExtractorComparator(ValueExtractor<? super T,? extends E> extractor)
Construct a ExtractorComparator with the specified extractor. -
Uses of ValueExtractor in com.tangosol.util.extractor
Subinterfaces of ValueExtractor in com.tangosol.util.extractor Modifier and Type Interface Description interface
IndexAwareExtractor<T,E>
IndexAwareExtractor is an extension to theValueExtractor
interface that supports the creation and destruction of anindex
.Classes in com.tangosol.util.extractor that implement ValueExtractor Modifier and Type Class 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
ChainedFragmentExtractor<T,E>
AValueExtractor
that extracts aFragment
from a nested property of the target object.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 aConditionalIndex
.class
DeserializationAccelerator
DeserializationAccelerator is anIndexAwareExtractor
implementation that is used to create aForwardOnlyMapIndex
, which in turn is used for deserialization optimization.class
EntryExtractor
The EntryExtractor is a base abstract class for special purpose custom ValueExtractor implementations.class
FragmentExtractor<T>
AValueExtractor
that is used to extract aFragment
from an object.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 anAbstractExtractor
that wraps a script written in one of the languages supported by Graal VM.class
UniversalExtractor<T,E>
Universal ValueExtractor implementation.Fields in com.tangosol.util.extractor declared as ValueExtractor Modifier and Type Field Description protected ValueExtractor[]
AbstractCompositeExtractor. m_aExtractor
The ValueExtractor array.protected ValueExtractor
CompositeUpdater. m_extractor
The ValueExtractor part.protected ValueExtractor<T,E>
ConditionalExtractor. m_extractor
The underlying extractor.protected ValueExtractor
DeserializationAccelerator. m_extractor
The underlying extractor.protected ValueExtractor<? super T,? extends E>
KeyExtractor. m_extractor
The underlying ValueExtractor.Methods in com.tangosol.util.extractor that return ValueExtractor Modifier and Type Method 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 ofReflectionExtractor
objects.static ValueExtractor[]
MultiExtractor. createExtractors(String sNames)
Parse a comma-delimited sequence of method names and instantiate a corresponding array ofValueExtractor
objects.ValueExtractor
CompositeUpdater. getExtractor()
Retrieve the ValueExtractor part.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 theindex creation
.ValueExtractor<? super T,? extends E>
KeyExtractor. getExtractor()
Obtain the underlying ValueExtractor.ValueExtractor[]
AbstractCompositeExtractor. getExtractors()
Obtain the ValueExtractor array.protected static ValueExtractor[]
ChainedExtractor. merge(ValueExtractor[] aHead, ValueExtractor[] aTail)
Return aValueExtractor
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.Methods in com.tangosol.util.extractor with parameters of type ValueExtractor Modifier and Type Method 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 aValueExtractor
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.Method parameters in com.tangosol.util.extractor with type arguments of type ValueExtractor Modifier and Type Method Description 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. 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. destroyIndex(Map<ValueExtractor<T,E>,MapIndex> mapIndex)
Destroy an existing index and remove it from the given map of indexes.MapIndex
IndexAwareExtractor. 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 theindex creation
.Constructors in com.tangosol.util.extractor with parameters of type ValueExtractor Constructor 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.ChainedFragmentExtractor(ValueExtractor<? super T,? extends E> from, ValueExtractor<? super E,?>... aExtractors)
ConstructChainedFragmentExtractor
instance.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.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.FragmentExtractor(ValueExtractor<? super T,?>[] aExtractors)
ConstructFragmentExtractor
instance.KeyExtractor(ValueExtractor<? super T,? extends E> extractor)
Construct a KeyExtractor based on a specified ValueExtractor.MultiExtractor(ValueExtractor[] aExtractor)
Construct a MultiExtractor. -
Uses of ValueExtractor in com.tangosol.util.filter
Fields in com.tangosol.util.filter declared as ValueExtractor Modifier and Type Field 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
Methods in com.tangosol.util.filter that return ValueExtractor Modifier and Type Method Description ValueExtractor
BetweenFilter. getValueExtractor()
Obtain the ValueExtractor used by this filter.ValueExtractor<? super T,? extends E>
ExtractorFilter. getValueExtractor()
Obtain the ValueExtractor used by this filter.Methods in com.tangosol.util.filter with parameters of type ValueExtractor Modifier and Type Method 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.Method parameters in com.tangosol.util.filter with type arguments of type ValueExtractor Modifier and Type Method Description Filter<?>
IndexAwareFilter. applyIndex(Map<? extends ValueExtractor<? extends V,?>,? extends MapIndex<? extends K,? extends V,?>> mapIndexes, Set<? extends K> setKeys)
Filter remaining keys using a Map of available indexes.int
IndexAwareFilter. calculateEffectiveness(Map<? extends ValueExtractor<? extends V,?>,? extends MapIndex<? extends K,? extends V,?>> mapIndexes, Set<? extends K> 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.Constructors in com.tangosol.util.filter with parameters of type ValueExtractor Constructor 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 aPredicateFilter
.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. -
Uses of ValueExtractor in com.tangosol.util.function
Methods in com.tangosol.util.function with parameters of type ValueExtractor Modifier and Type Method Description static <T,E extends Comparable<? super E>>
Remote.Comparator<T>Remote. comparator(ValueExtractor<? super T,? extends E> extractor)
CreateRemote.Comparator
for the specified extractor that returns aComparable
value.static <T,E extends Comparable<? super E>>
Remote.BinaryOperator<T>Remote.BinaryOperator. maxBy(ValueExtractor<? super T,? extends E> comparable)
Returns aRemote.BinaryOperator
which returns the greater of two elements according to the specifiedComparable
value.static <T,E extends Comparable<? super E>>
Remote.BinaryOperator<T>Remote.BinaryOperator. minBy(ValueExtractor<? super T,? extends E> comparable)
Returns aRemote.BinaryOperator
which returns the lesser of two elements according to the specifiedComparable
value. -
Uses of ValueExtractor in com.tangosol.util.processor
Fields in com.tangosol.util.processor declared as ValueExtractor Modifier and Type Field Description protected ValueExtractor<? super T,? extends E>
ExtractorProcessor. m_extractor
The underlying value extractor.protected ValueExtractor<V,R>
PropertyManipulator. m_extractor
The underlying ValueExtractor.Methods in com.tangosol.util.processor that return ValueExtractor Modifier and Type Method Description ValueExtractor<V,R>
PropertyManipulator. getExtractor()
Retrieve the underlying ValueExtractor reference.Constructors in com.tangosol.util.processor with parameters of type ValueExtractor Constructor Description ExtractorProcessor(ValueExtractor<? super T,? extends E> extractor)
Construct an ExtractorProcessor based on the specified ValueExtractor. -
Uses of ValueExtractor in com.tangosol.util.stream
Methods in com.tangosol.util.stream with parameters of type ValueExtractor Modifier and Type Method Description static <T,U>
RemoteCollector<T,?,Double>RemoteCollectors. averagingDouble(ValueExtractor<? super U,? extends Number> extractor)
Returns aCollector
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 aCollector
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 aCollector
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 aCollector
implementing a "group by" operation on input elements of typeT
, grouping elements according to a classification function, and returning the results in aMap
.static <T,U,K,D,A,M extends Map<K,D>>
RemoteCollector<T,?,M>RemoteCollectors. groupingBy(ValueExtractor<? super U,? extends K> extractor, Remote.Supplier<M> mapFactory, RemoteCollector<? super T,A,D> downstream)
Returns aCollector
implementing a cascaded "group by" operation on input elements of typeT
, grouping elements according to a classification function, and then performing a reduction operation on the values associated with a given key using the specified downstreamCollector
.static <T,U,K,A,D>
RemoteCollector<T,?,Map<K,D>>RemoteCollectors. groupingBy(ValueExtractor<? super U,? extends K> classifier, RemoteCollector<? super T,A,D> downstream)
Returns aCollector
implementing a cascaded "group by" operation on input elements of typeT
, grouping elements according to a classification function, and then performing a reduction operation on the values associated with a given key using the specified downstreamCollector
.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 anDoubleStream
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 anIntStream
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 anLongStream
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 providedValueExtractor
.static <T,E extends Comparable<? super E>>
RemoteCollector<T,?,Optional<T>>RemoteCollectors. maxBy(ValueExtractor<? super T,? extends E> comparable)
Returns aCollector
that produces the maximal element according to a givenComparable
attribute, described as anOptional<T>
.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 providedValueExtractor
.static <T,E extends Comparable<? super E>>
RemoteCollector<T,?,Optional<T>>RemoteCollectors. minBy(ValueExtractor<? super T,? extends E> comparable)
Returns aCollector
that produces the minimal element according to a givenComparable
attribute, described as anOptional<T>
.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 providedValueExtractor
.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 providedValueExtractor
.static <T,U>
RemoteCollector<T,?,com.tangosol.internal.util.DoubleSummaryStatistics>RemoteCollectors. summarizingDouble(ValueExtractor<? super U,? extends Number> extractor)
Returns aCollector
which applies andouble
-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 aCollector
which applies anint
-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 aCollector
which applies anlong
-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 aCollector
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 aCollector
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 aCollector
that produces the sum of a long-valued function applied to the input elements.static <T,U1,U2,K,V>
RemoteCollector<T,?,Map<K,V>>RemoteCollectors. toMap(ValueExtractor<? super U1,? extends K> keyMapper, ValueExtractor<? super U2,? extends V> valueMapper)
Returns aCollector
that accumulates elements into aMap
whose keys and values are the result of applying the provided mapping functions to the input elements.static <T,U1,U2,K,V>
RemoteCollector<T,?,Map<K,V>>RemoteCollectors. toMap(ValueExtractor<? super U1,? extends K> keyMapper, ValueExtractor<? super U2,? extends V> valueMapper, Remote.BinaryOperator<V> mergeFunction)
Returns aCollector
that accumulates elements into aMap
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>>
RemoteCollector<T,?,M>RemoteCollectors. toMap(ValueExtractor<? super U1,? extends K> keyExtractor, ValueExtractor<? super U2,? extends V> valueExtractor, Remote.BinaryOperator<V> mergeFunction, Remote.Supplier<M> mapSupplier)
Returns aCollector
that accumulates elements into aMap
whose keys and values are the result of applying the provided mapping functions to the input elements.static <T,E extends Comparable<? super E>>
RemoteCollector<T,?,Collection<T>>RemoteCollectors. toSortedBag(ValueExtractor<? super T,? extends E> comparable)
Returns aCollector
that accumulates the input elements into a newSortedBag
.static <T,E extends Comparable<? super E>>
RemoteCollector<T,?,SortedSet<T>>RemoteCollectors. toSortedSet(ValueExtractor<? super T,? extends E> comparable)
Returns aCollector
that accumulates the input elements into a newSortedSet
. -
Uses of ValueExtractor in com.tangosol.util.transformer
Methods in com.tangosol.util.transformer that return ValueExtractor Modifier and Type Method 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.Constructors in com.tangosol.util.transformer with parameters of type ValueExtractor Constructor 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.
-