Uses of Interface
com.tangosol.util.ValueExtractor
Package
Description
Coherence CDI provides support for CDI (Contexts and Dependency Injection)
within Coherence cluster members.
The Coherence gRPC server implementation.
Contains classes to enable Repository-like access to Coherence data.
Defines the Coherence configuration object model classes and interfaces for
Caching and Service Schemes.
Contains packages and classes supporting the Coherence CohQL command line tool.
This package contains builders for the various CohQL functions.
This package contains implementations of the
BaseOperator
interface.This package contains
StatementBuilder
implementations.Contains Federation conflict resolution interfaces.
Contains classes related to partitioned cache implementation of Coherence JCache.
Contains classes related to the Coherence REST API.
Contains classes related to the Coherence REST pluggable query engine.
Contains packages and classes related to the Coherence REST API utilities.
Contains classes related to REST-based aggregation.
Contains basic cluster interfaces and factories.
Contains classes providing various caching strategies.
Contains classes that providing topic entities for publish/subscribe messaging.
Contains various generic utilities.
Contains concrete
InvocableMap.EntryAggregator
implementations.Contains concrete
Comparator
implementations and related interfaces.Contains
ValueExtractor
and
ValueUpdater
related classes.Contains concrete
Filter
implementations and related interfaces.Contains Functional interfaces allowing remote execution of lambda expressions and method references.
Contains concrete
InvocableMap.EntryProcessor
implementations.Contains classes to support functional-style operations on remote streams of elements,
such as map-reduce transformations on collections.
Contains concrete
MapEventTransformer
implementations.-
Uses of ValueExtractor in com.oracle.coherence.cdi
Modifier and TypeMethodDescriptionCreate aValueExtractor
instance.ExtractorProducer.ChainedExtractorsSupplier.create
(ChainedExtractor.Extractors annotation) ExtractorProducer.ChainedExtractorSupplier.create
(ChainedExtractor annotation) ExtractorProducer.PofExtractorsSupplier.create
(PofExtractor.Extractors annotation) ExtractorProducer.PofExtractorSupplier.create
(PofExtractor annotation) ExtractorProducer.UniversalExtractorsSupplier.create
(PropertyExtractor.Extractors annotation) ExtractorProducer.UniversalExtractorSupplier.create
(PropertyExtractor annotation) <T,
E> ValueExtractor <T, E> ExtractorProducer.getValueExtractor
(jakarta.enterprise.inject.spi.InjectionPoint injectionPoint) Create an instance of aValueExtractor
based on injection point metadata. -
Uses of ValueExtractor in com.oracle.coherence.grpc.proxy
Modifier and TypeMethodDescriptionValueExtractor
<?, ?> 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
Modifier and TypeMethodDescription<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.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.AbstractRepository.getAll
(ValueExtractor<? super T, ? extends R> extractor) Return a map of values extracted from all entities in the repository.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.AbstractRepository.groupBy
(Filter<?> filter, ValueExtractor<? super T, ? extends K> extractor) Return the grouping of entities by the specified extractor.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.AbstractRepository.groupBy
(ValueExtractor<? super T, ? extends K> extractor) Return the grouping of entities by the specified extractor.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
Modifier and TypeMethodDescriptionContinuousQueryCacheScheme.getTransformerBuilder()
Return theParameterizedBuilder
used to construct theValueExtractor
to be used as a transformer by theContinuousQueryCache
.Modifier and TypeMethodDescriptionvoid
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
Modifier and TypeMethodDescriptionFilterBuilder.makeExtractor
(NodeTerm term) Process the AST Tree using the given Term that represents getter.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.Create aValueExtractor
for the given cache name, target and property chain. -
Uses of ValueExtractor in com.tangosol.coherence.dslquery.function
Modifier and TypeFieldDescriptionstatic ParameterizedBuilder
<ValueExtractor> FunctionBuilders.KEY_FUNCTION_BUILDER
ThisParameterizedBuilder
handles the key() function. -
Uses of ValueExtractor in com.tangosol.coherence.dslquery.operator
Modifier and TypeMethodDescriptionBaseOperator.makeExtractor
(Term termLeft, Term termRight, TermWalker walker) 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
Modifier and TypeFieldDescriptionprotected final ValueExtractor
CreateIndexStatementBuilder.CreateIndexStatement.f_extractor
TheValueExtractor
to be used to create the index.protected final ValueExtractor
DropIndexStatementBuilder.DropIndexStatement.f_extractor
TheValueExtractor
to be used to create the index.ModifierConstructorDescriptionCreateIndexStatement
(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
Modifier and TypeMethodDescription<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
Modifier and TypeClassDescriptionstatic class
Get CacheStatistics from binEntry's context for JCache id.ModifierConstructorDescriptionPartitionedCacheStatisticsAggregator
(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
Modifier and TypeMethodDescriptionprotected 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
(jakarta.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
Modifier and TypeMethodDescription<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
Modifier and TypeClassDescriptionclass
PropertySet<T>
Represents a set of named properties and allows the extraction of those properties from a target object.Modifier and TypeFieldDescriptionprotected ValueExtractor
PropertySpec.m_extractor
An extractor that can extract value of this property from a target object.Modifier and TypeMethodDescriptionprotected ValueExtractor
ComparatorBuilder.createExtractor
(String sExpr) Create expression extractor.protected ValueExtractor
PropertySpec.getExtractor()
Return extractor for this property.Modifier and TypeMethodDescriptionComparatorBuilder.asc
(ValueExtractor extractor) Add comparator to this builder.protected Comparator
ComparatorBuilder.createComparator
(ValueExtractor extractor) Create extractor comparator.ComparatorBuilder.desc
(ValueExtractor extractor) Add comparator to this builder. -
Uses of ValueExtractor in com.tangosol.coherence.rest.util.aggregator
Modifier and TypeMethodDescriptionprotected InvocableMap.EntryAggregator
DefaultAggregatorFactory.createAggregator
(ValueExtractor extractor) Create and initialize a new aggregator instance. -
Uses of ValueExtractor in com.tangosol.net
Modifier and TypeFieldDescriptionprotected 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
.Modifier and TypeMethodDescriptionBackingMapContext.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.BackingMapContext.getIndexMap
(PartitionSet partitions) Return a map of indexes defined for the specified partitions of thecache
that this BackingMapContext is associated with.Modifier and TypeMethodDescriptiondefault 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
Modifier and TypeFieldDescriptionprotected 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 TypeMethodDescriptionValueExtractor
<? 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.Modifier and TypeMethodDescription<T,
E> void ContinuousQueryCache.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> void NearCache.addIndex
(ValueExtractor<? super T, ? extends E> extractor, boolean fOrdered, Comparator<? super E> comparator) Add an index to this QueryMap.<T,
E> void WrapperNamedCache.addIndex
(ValueExtractor<? super T, ? extends E> extractor, boolean fOrdered, Comparator<? super E> comparator) Add an index to this QueryMap.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 ContinuousQueryCache.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> void NearCache.removeIndex
(ValueExtractor<? super T, ? extends E> extractor) Remove an index from this QueryMap.<T,
E> void WrapperNamedCache.removeIndex
(ValueExtractor<? super T, ? extends E> extractor) Remove an index from this QueryMap.ContinuousQueryCache.transform
(Set<Map.Entry<K, V_BACK>> setIn, ValueExtractor<? super V_BACK, ? extends V_FRONT> transformer) Transform a set of entries.ModifierConstructorDescriptionContinuousQueryCache
(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
Modifier and TypeMethodDescriptionValueExtractor
<? super V, U> Subscriber.Convert.getExtractor()
Return the option's converter function.Modifier and TypeMethodDescriptionvoid
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. -
Uses of ValueExtractor in com.tangosol.util
Modifier and TypeClassDescriptionstatic class
A ValueExtractor that always results in the passed-in value.Modifier and TypeFieldDescriptionprotected final 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.protected ValueExtractor
UniversalManipulator.m_extractor
The underlying ValueExtractor.Modifier and TypeMethodDescriptiondefault <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> 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> Returns an extractor that extracts the value of the specified field.static <T,
E> ValueExtractor <T, E> Returns an extractor that extracts the value of the specified field.static <T,
E> ValueExtractor <T, E> 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> 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> Returns an extractor that extracts the value of the specified index(es) from a POF encoded@PortableType
.UniversalManipulator.getExtractor()
Retrieve the underlying ValueExtractor reference.ValueManipulator.getExtractor()
Retrieve the underlying ValueExtractor reference.ForwardOnlyMapIndex.getValueExtractor()
Obtain the ValueExtractor object that the MapIndex uses to extract an indexable Object from a value stored in the indexed Map.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.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<?>> 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> Instantiate aValueExtractor
that is implemented using the specified language.Modifier and TypeMethodDescriptiondefault Map
<ValueExtractor, MapIndex> BinaryEntry.getIndexMap()
Return a map of indexes defined for the partition of thecache
that this BinaryEntry belongs to.Modifier and TypeMethodDescription<T,
E> void ConverterCollections.ConverterNamedCache.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.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> void QueryMap.addIndex
(ValueExtractor<? super T, ? extends E> extractor) Add an unordered index to this QueryMap.<T,
E> void QueryMap.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> E ConverterCollections.ConverterMapEvent.ConverterMapEventBinaryEntry.extract
(ValueExtractor<T, E> extractor) Depending upon the type of the ValueExtractor route the call to the appropriate extract method.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> E QueryMap.Entry.extract
(ValueExtractor<T, E> extractor) Extract a value out of the Entry's key or value.<T,
E> E SimpleMapEntry.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> void ConverterCollections.ConverterNamedCache.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.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> void QueryMap.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.ModifierConstructorDescriptionConditionalIndex
(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.protected
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
Modifier and TypeFieldDescriptionprotected 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.Modifier and TypeMethodDescriptionValueExtractor
<?, ? 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 TypeMethodDescriptionstatic <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
.ModifierConstructorDescriptionAbstractAggregator
(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.protected
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.protected
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
Modifier and TypeMethodDescriptionValueExtractor
<? super T, ? extends Comparable> ExtractorComparator.getExtractor()
Returns theValueExtractor
to extract value(s) to be used in comparison.ModifierConstructorDescriptionExtractorComparator
(ValueExtractor<? super T, ? extends E> extractor) Construct a ExtractorComparator with the specified extractor. -
Uses of ValueExtractor in com.tangosol.util.extractor
Modifier and TypeInterfaceDescriptioninterface
IndexAwareExtractor<T,
E> IndexAwareExtractor is an extension to theValueExtractor
interface that supports the creation and destruction of anindex
.Modifier and TypeClassDescriptionclass
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
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 is anIndexAwareExtractor
implementation that is used to create aForwardOnlyMapIndex
, which in turn is used for deserialization optimization.class
The EntryExtractor is a base abstract class for special purpose custom ValueExtractor implementations.class
AValueExtractor
that is used to extract aFragment
from an object.class
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
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.Modifier and TypeFieldDescriptionprotected 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.Modifier and TypeMethodDescription<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.CompositeUpdater.getExtractor()
Retrieve the ValueExtractor part.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.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.Modifier and TypeMethodDescription<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.Modifier and TypeMethodDescriptionConditionalExtractor.createIndex
(boolean fOrdered, Comparator comparator, Map<ValueExtractor<T, E>, MapIndex> mapIndex, BackingMapContext ctx) Create an index and associate it with the corresponding extractor.IndexAwareExtractor.createIndex
(boolean fOrdered, Comparator comparator, Map<ValueExtractor<T, E>, MapIndex> mapIndex, BackingMapContext ctx) Create an index and associate it with the corresponding extractor.ConditionalExtractor.destroyIndex
(Map<ValueExtractor<T, E>, MapIndex> mapIndex) Destroy an existing index and remove it from the given map of indexes.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
.ModifierConstructorDescriptionAbstractCompositeExtractor
(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
Modifier and TypeFieldDescriptionprotected 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 TypeMethodDescriptionBetweenFilter.getValueExtractor()
Obtain the ValueExtractor used by this filter.ValueExtractor
<? super T, ? extends E> ExtractorFilter.getValueExtractor()
Obtain the ValueExtractor used by this filter.Modifier and TypeMethodDescriptionprotected 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 TypeMethodDescriptionFilter
<?> 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.ModifierConstructorDescriptionBetweenFilter
(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.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
Modifier and TypeMethodDescriptionstatic <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
Modifier and TypeFieldDescriptionprotected ValueExtractor
<? super T, ? extends E> ExtractorProcessor.m_extractor
The underlying value extractor.protected ValueExtractor
<V, R> PropertyManipulator.m_extractor
The underlying ValueExtractor.Modifier and TypeMethodDescriptionPropertyManipulator.getExtractor()
Retrieve the underlying ValueExtractor reference.ModifierConstructorDescriptionExtractorProcessor
(ValueExtractor<? super T, ? extends E> extractor) Construct an ExtractorProcessor based on the specified ValueExtractor. -
Uses of ValueExtractor in com.tangosol.util.stream
Modifier and TypeMethodDescriptionstatic <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.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>
.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, ?, ConcurrentMap<K, V>> RemoteCollectors.toConcurrentMap
(ValueExtractor<? super U1, ? extends K> keyMapper, ValueExtractor<? super U2, ? extends V> valueMapper) Returns a concurrentCollector
that accumulates elements into aConcurrentMap
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, ?, ConcurrentMap<K, V>> RemoteCollectors.toConcurrentMap
(ValueExtractor<? super U1, ? extends K> keyMapper, ValueExtractor<? super U2, ? extends V> valueMapper, Remote.BinaryOperator<V> mergeFunction) Returns a concurrentCollector
that accumulates elements into aConcurrentMap
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) 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
.static <T,
U1, U2, K, V>
RemoteCollector<T, ?, Map<K, V>> RemoteCollectors.toUnmodifiableMap
(ValueExtractor<? super U1, ? extends K> keyMapper, ValueExtractor<? super U2, ? extends V> valueMapper) Returns aCollector
that accumulates elements into an unmodifiable Map 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.toUnmodifiableMap
(ValueExtractor<? super U1, ? extends K> keyMapper, ValueExtractor<? super U2, ? extends V> valueMapper, Remote.BinaryOperator<V> mergeFunction) Returns aCollector
that accumulates elements into an unmodifiable Map whose keys and values are the result of applying the provided mapping functions to the input elements. -
Uses of ValueExtractor in com.tangosol.util.transformer
Modifier and TypeMethodDescriptionExtractorEventTransformer.getNewValueExtractor()
Return a ValueExtractor used to transfrom the event's NewValue.ExtractorEventTransformer.getOldValueExtractor()
Return a ValueExtractor used to transfrom the event's OldValue.ModifierConstructorDescriptionExtractorEventTransformer
(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.