Uses of Interface
com.tangosol.util.ValueExtractor
Packages that use ValueExtractor
Package
Description
Contains classes for Coherence AI vector database functionality.
Contains classes for Coherence AI vector database indexes.
Contains classes for Coherence AI vector database Knn search functionality.
Coherence CDI provides support for CDI (Contexts and Dependency Injection)
within Coherence cluster members.
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 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.ai
Subinterfaces of ValueExtractor in com.oracle.coherence.aiModifier and TypeInterfaceDescriptioninterfaceVectorIndexExtractor<V,T> AnIndexAwareExtractorused to create aVectorIndex -
Uses of ValueExtractor in com.oracle.coherence.ai.index
Classes in com.oracle.coherence.ai.index that implement ValueExtractorModifier and TypeClassDescriptionclassBinaryQuantIndex<K,V, T> AnVectorIndexExtractorto create aVectorIndexusing binary quantization of vectors.Methods in com.oracle.coherence.ai.index that return ValueExtractorMethod parameters in com.oracle.coherence.ai.index with type arguments of type ValueExtractorModifier and TypeMethodDescriptionBinaryQuantIndex.createIndex(boolean b, Comparator comparator, Map<ValueExtractor<V, Vector<T>>, MapIndex> map, BackingMapContext backingMapContext) BinaryQuantIndex.destroyIndex(Map<ValueExtractor<V, Vector<T>>, MapIndex> map) Constructors in com.oracle.coherence.ai.index with parameters of type ValueExtractorModifierConstructorDescriptionBinaryQuantIndex(ValueExtractor<V, Vector<T>> extractor) Create aBinaryQuantIndex. -
Uses of ValueExtractor in com.oracle.coherence.ai.search
Fields in com.oracle.coherence.ai.search declared as ValueExtractorModifier and TypeFieldDescriptionprotected ValueExtractor<? super V, ? extends Vector<T>> SimilaritySearch.m_extractorTheValueExtractorto extract the vector from the entry value.Methods in com.oracle.coherence.ai.search that return ValueExtractorModifier and TypeMethodDescriptionValueExtractor<? super V, ? extends Vector<T>> SimilaritySearch.getExtractor()Constructors in com.oracle.coherence.ai.search with parameters of type ValueExtractorModifierConstructorDescriptionSimilaritySearch(ValueExtractor<? super V, ? extends Vector<T>> extractor, Vector<T> vector, int maxResults) Create aSimilaritySearchaggregator that will use cosine distance to calculate and return up tomaxResultsresults that are closest to the specifiedvector. -
Uses of ValueExtractor in com.oracle.coherence.cdi
Methods in com.oracle.coherence.cdi that return ValueExtractorModifier and TypeMethodDescriptionCreate aValueExtractorinstance.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 aValueExtractorbased on injection point metadata. -
Uses of ValueExtractor in com.oracle.coherence.repository
Methods in com.oracle.coherence.repository with parameters of type ValueExtractorModifier 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> RAbstractRepository.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 specifiedComparableattribute.<R extends Comparable<? super R>>
CompletableFuture<Collection<T>> AbstractAsyncRepository.getAllOrderedBy(ValueExtractor<? super T, ? extends R> orderBy) Return all entities in this repository, sorted using specifiedComparableattribute.<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 specifiedComparableattribute.<R extends Comparable<? super R>>
Collection<T> AbstractRepository.getAllOrderedBy(ValueExtractor<? super T, ? extends R> orderBy) Return all entities in this repository, sorted using specifiedComparableattribute.<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
Methods in com.tangosol.coherence.config.scheme that return types with arguments of type ValueExtractorModifier and TypeMethodDescriptionContinuousQueryCacheScheme.getTransformerBuilder()Return theParameterizedBuilderused to construct theValueExtractorto be used as a transformer by theContinuousQueryCache.Method parameters in com.tangosol.coherence.config.scheme with type arguments of type ValueExtractorModifier and TypeMethodDescriptionvoidContinuousQueryCacheScheme.setTransformerBuilder(ParameterizedBuilder<ValueExtractor> transformerBuilder) Set theParameterizedBuilderused to construct theValueExtractorto be used as a transformer by theContinuousQueryCache. -
Uses of ValueExtractor in com.tangosol.coherence.dslquery
Methods in com.tangosol.coherence.dslquery that return ValueExtractorModifier and TypeMethodDescriptionFilterBuilder.makeExtractor(NodeTerm term) Process the AST Tree using the given Term that represents getter.Call the realize(String, int, String) method on eachExtractorBuilderin the chain returning the result of the first ExtractorBuilder to return a non-null value.Create aValueExtractorfor the given cache name, target and property chain. -
Uses of ValueExtractor in com.tangosol.coherence.dslquery.function
Fields in com.tangosol.coherence.dslquery.function with type parameters of type ValueExtractorModifier and TypeFieldDescriptionstatic ParameterizedBuilder<ValueExtractor> FunctionBuilders.KEY_FUNCTION_BUILDERThisParameterizedBuilderhandles the key() function. -
Uses of ValueExtractor in com.tangosol.coherence.dslquery.operator
Methods in com.tangosol.coherence.dslquery.operator that return ValueExtractorModifier and TypeMethodDescriptionBaseOperator.makeExtractor(Term termLeft, Term termRight, TermWalker walker) BaseOperator.makeExtractor(Object oLeft, Object oRight) Create aValueExtractorfor thisBaseOperatorusing the specified left and right values. -
Uses of ValueExtractor in com.tangosol.coherence.dslquery.statement
Fields in com.tangosol.coherence.dslquery.statement declared as ValueExtractorModifier and TypeFieldDescriptionprotected final ValueExtractorCreateIndexStatementBuilder.CreateIndexStatement.f_extractorTheValueExtractorto be used to create the index.protected final ValueExtractorDropIndexStatementBuilder.DropIndexStatement.f_extractorTheValueExtractorto be used to create the index.Constructors in com.tangosol.coherence.dslquery.statement with parameters of type ValueExtractorModifierConstructorDescriptionCreateIndexStatement(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 specifiedValueExtractorfrom the cache with the specified name. -
Uses of ValueExtractor in com.tangosol.coherence.jcache.partitionedcache
Classes in com.tangosol.coherence.jcache.partitionedcache that implement ValueExtractorModifier and TypeClassDescriptionstatic classGet CacheStatistics from binEntry's context for JCache id.Constructors in com.tangosol.coherence.jcache.partitionedcache with parameters of type ValueExtractorModifierConstructorDescriptionPartitionedCacheStatisticsAggregator(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 ValueExtractorModifier and TypeMethodDescriptionprotected CollectionCacheResource.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 CollectionNamedQueryResource.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
Methods in com.tangosol.coherence.rest.query with parameters of type ValueExtractorModifier 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
Classes in com.tangosol.coherence.rest.util that implement ValueExtractorModifier and TypeClassDescriptionclassPropertySet<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 ValueExtractorModifier and TypeFieldDescriptionprotected ValueExtractorPropertySpec.m_extractorAn extractor that can extract value of this property from a target object.Methods in com.tangosol.coherence.rest.util that return ValueExtractorModifier and TypeMethodDescriptionprotected ValueExtractorComparatorBuilder.createExtractor(String sExpr) Create expression extractor.protected ValueExtractorPropertySpec.getExtractor()Return extractor for this property.Methods in com.tangosol.coherence.rest.util with parameters of type ValueExtractorModifier and TypeMethodDescriptionComparatorBuilder.asc(ValueExtractor extractor) Add comparator to this builder.protected ComparatorComparatorBuilder.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
Methods in com.tangosol.coherence.rest.util.aggregator with parameters of type ValueExtractorModifier and TypeMethodDescriptionprotected InvocableMap.EntryAggregatorDefaultAggregatorFactory.createAggregator(ValueExtractor extractor) Create and initialize a new aggregator instance. -
Uses of ValueExtractor in com.tangosol.net
Fields in com.tangosol.net declared as ValueExtractorModifier and TypeFieldDescriptionprotected ValueExtractor<? super V, ?> MapViewBuilder.m_mapperTheValueExtractorthat will be used to transform values retrieved from the underlying map before storing them locally; if specified, thisviewwill becomeread-only.Methods in com.tangosol.net that return types with arguments of type ValueExtractorModifier and TypeMethodDescriptionBackingMapContext.getIndexMap()Return a map of indexes defined for all partitions of thecachethat this BackingMapContext is associated with.default Map<ValueExtractor, MapIndex> BackingMapContext.getIndexMap(int nPartition) Return a map of indexes defined for the specified partition of thecachethat this BackingMapContext is associated with.BackingMapContext.getIndexMap(PartitionSet partitions) Return a map of indexes defined for the specified partitions of thecachethat this BackingMapContext is associated with.Methods in com.tangosol.net with parameters of type ValueExtractorModifier and TypeMethodDescriptionlongPagedTopicService.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.longPagedTopicService.ensureSubscription(String sTopicName, com.tangosol.internal.net.topic.impl.paged.model.SubscriberGroupId groupId, Subscriber.Id subscriberId, Filter<?> filter, ValueExtractor<?, ?> extractor, int[] anChannel) Ensure the specified subscriber is created in a subscription.<U> MapViewBuilder<K, U> MapViewBuilder.map(ValueExtractor<? super V, ? extends U> mapper) TheValueExtractorthat thisviewwill 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) TheValueExtractorthat thisviewwill 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 ValueExtractorModifier and TypeFieldDescriptionprotected ValueExtractor<? super V_BACK, ? extends V_FRONT> ContinuousQueryCache.m_transformerThe transformer that should be used to convert values from the underlying cache.Methods in com.tangosol.net.cache that return ValueExtractorModifier and TypeMethodDescriptionValueExtractor<? super V_BACK, ? extends V_FRONT> ContinuousQueryCache.getTransformer()Obtain the transformer that thisContinuousQueryCacheis using to transform the results from the underlying cache prior to storing them locally.Methods in com.tangosol.net.cache with parameters of type ValueExtractorModifier 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 theNamedCachethisContinuousQueryCachewraps, otherwise, the index will be created on the wrappedNamedCacheonly.<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 StringContinuousQueryCache.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 theNamedCachethisContinuousQueryCachewraps.<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.Constructors in com.tangosol.net.cache with parameters of type ValueExtractorModifierConstructorDescriptionContinuousQueryCache(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 aNamedCacheusing aFilter.ContinuousQueryCache(NamedCache<K, V_BACK> cache, Filter filter, ValueExtractor<? super V_BACK, ? extends V_FRONT> transformer) Create a locally materialized view of aNamedCacheusing aFilterand 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 aNamedCacheusing aFilter. -
Uses of ValueExtractor in com.tangosol.net.topic
Methods in com.tangosol.net.topic that return ValueExtractorModifier and TypeMethodDescriptionValueExtractor<? super V, U> Subscriber.Convert.getExtractor()Return the option's converter function.Methods in com.tangosol.net.topic with parameters of type ValueExtractorModifier and TypeMethodDescriptionvoidNamedTopic.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 -
Uses of ValueExtractor in com.tangosol.util
Classes in com.tangosol.util that implement ValueExtractorModifier and TypeClassDescriptionstatic classA ValueExtractor that always results in the passed-in value.Fields in com.tangosol.util declared as ValueExtractorModifier and TypeFieldDescriptionprotected final ValueExtractorForwardOnlyMapIndex.f_extractorValueExtractor object that this MapIndex uses to extract an indexable property value from a [converted] value stored in the resource map.protected ValueExtractorSimpleMapIndex.m_extractorValueExtractor object that this MapIndex uses to extract an indexable property value from a [converted] value stored in the resource map.protected ValueExtractorUniversalManipulator.m_extractorThe underlying ValueExtractor.Methods in com.tangosol.util that return ValueExtractorModifier 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 theafterextractor 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 thebeforeextractor to its input, and then applies this extractor to the result.static ValueExtractorQueryHelper.createExtractor(String s) Make a new ValueExtractor from the given String.static ValueExtractorQueryHelper.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 aValueExtractorfor the specifiedMethod.default ValueExtractor<T, E> ValueExtractor.fromKey()Obtain a version of thisValueExtractorthat targets an entry's key.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> 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,R> ValueExtractor <T, R> Extractors.key(ValueExtractor<?, ?>... extractors) Returns aKeyExtractorthat wraps the specifiedValueExtractors.static <T,R> ValueExtractor <T, R> Returns aKeyExtractorthat 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> ValueExtractor<T, List<?>> Extractors.multi(ValueExtractor<T, ?>... extractors) Returns an extractor that extracts values using the specifiedValueExtractors 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.Methods in com.tangosol.util that return types with arguments of type ValueExtractorModifier and TypeMethodDescriptiondefault Map<ValueExtractor, MapIndex> BinaryEntry.getIndexMap()Return a map of indexes defined for the partition of thecachethat this BinaryEntry belongs to.Methods in com.tangosol.util with parameters of type ValueExtractorModifier 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 voidInvocableMapHelper.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 theafterextractor to the result.static <T,E> ContainsFilter <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> ContainsAllFilter <T, E[]> 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> ContainsAllFilter <T, E[]> 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> ContainsAnyFilter <T, E[]> 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> ContainsAnyFilter <T, E[]> 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>>
BetweenFilter<T, E> Filters.between(ValueExtractor<T, ? extends E> extractor, E from, E to) Return a filter that tests if the extracted value is between the specified values (inclusive).static <K,V, T> InvocableMap.StreamingAggregator <K, V, ?, BigDecimal> Aggregators.bigDecimalAverage(ValueExtractor<? super T, ? extends Number> extractor) Return an aggregator that calculates a average of the numeric values extracted from a set of entries in a Map.static <K,V, T> InvocableMap.StreamingAggregator <K, V, ?, BigDecimal> Aggregators.bigDecimalMax(ValueExtractor<? super T, ? extends Number> extractor) Return an aggregator that calculates a maximum of the numeric values extracted from a set of entries in a Map.static <K,V, T> InvocableMap.StreamingAggregator <K, V, ?, BigDecimal> Aggregators.bigDecimalMin(ValueExtractor<? super T, ? extends Number> extractor) Return an aggregator that calculates a minimum of the numeric values extracted from a set of entries in a Map.static <K,V, T> InvocableMap.StreamingAggregator <K, V, ?, BigDecimal> Aggregators.bigDecimalSum(ValueExtractor<? super T, ? extends Number> extractor) Return an aggregator that calculates a sum of the numeric values extracted from a set of entries in a Map.static <T,R> ValueExtractor <T, R> Extractors.chained(ValueExtractor<?, ?>... extractors) Returns an extractor that extracts the specified fields where extraction occurs in a chain where the result of each field extraction is the input to the next extractor.static <K,V, T, R extends Comparable<? super R>>
InvocableMap.StreamingAggregator<K, V, ?, R> Aggregators.comparableMax(ValueExtractor<? super T, ? extends R> extractor) Return an aggregator that calculates a maximum of theComparablevalues 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 theComparablevalues 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 thebeforeextractor to its input, and then applies this extractor to the result.static <T,E, C extends Collection<? extends E>>
ContainsFilter<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>>
ContainsAllFilter<T, C> 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>>
ContainsAllFilter<T, C> 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>>
ContainsAnyFilter<T, C> 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>>
ContainsAnyFilter<T, C> 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>
DistinctValues<K, V, T, 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> EqualsFilter <T, E> 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>
ExtractorProcessor<K, V, T, 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> EQueryMap.Entry.extractFromKey(ValueExtractor<? super K, E> extractor) Extract a value out of the Entry's key.default <E> EQueryMap.Entry.extractFromValue(ValueExtractor<? super V, E> extractor) Extract a value out of the Entry's value.static ObjectInvocableMapHelper.extractOriginalFromEntry(ValueExtractor extractor, MapTrigger.Entry entry) Extract a value from the "original value" of the specified entry using the specified extractor.static <T> FragmentExtractor<T> Extractors.fragment(ValueExtractor<? super T, ?>... aExtractors) Return aValueExtractorthat extracts aFragmentfrom a target object.static <T,E> ChainedFragmentExtractor <T, E> Extractors.fragment(ValueExtractor<? super T, E> from, ValueExtractor<? super E, ?>... aExtractors) Return aValueExtractorthat extracts a nestedFragmentfrom a property of the target object.static <T,E> CollectionExtractor <T, E> Extractors.fromCollection(ValueExtractor<T, E> extractor) Returns aCollectionExtractorthat wraps the specifiedValueExtractor.<E> EFragment.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>>
GreaterFilter<T, E> Filters.greater(ValueExtractor<T, ? extends E> extractor, E value) Return a filter that tests if the extracted value is greater than the specified value.static <T,E extends Comparable<? super E>>
GreaterEqualsFilter<T, E> Filters.greaterEqual(ValueExtractor<T, ? extends E> extractor, E value) Return a filter that tests if the extracted value is greater than or equal to the specified value.static <K,V, T, E, R>
GroupAggregator<K, V, T, E, R> Aggregators.grouping(ValueExtractor<? super T, ? extends E> extractor, InvocableMap.EntryAggregator<? super K, ? super V, R> aggregator, Filter filter) Create an instance of group aggregator based on a specified property or method name(s) and anInvocableMap.EntryAggregator.static <K,V, T, E, R>
GroupAggregator<K, V, T, E, R> Aggregators.grouping(ValueExtractor<? super T, ? extends E> extractor, InvocableMap.EntryAggregator<K, V, R> aggregator) Create an instance of group aggregator based on a specified property or method name(s) and anInvocableMap.EntryAggregator.static <T,E> InFilter <T, E> 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> InFilter <T, E> 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> EqualsFilter<T, Boolean> Filters.isFalse(ValueExtractor<T, Boolean> extractor) Return a filter that evaluates to true if the extracted value isfalse.static <T,E> IsNotNullFilter <T, E> Filters.isNotNull(ValueExtractor<T, E> extractor) Return a filter that evaluates to true for non-null values.static <T,E> IsNullFilter <T, E> Filters.isNull(ValueExtractor<T, E> extractor) Return a filter that evaluates to true for null values.static <T> EqualsFilter<T, Boolean> Filters.isTrue(ValueExtractor<T, Boolean> extractor) Return a filter that evaluates to true if the extracted value istrue.static <T,R> ValueExtractor <T, R> Extractors.key(ValueExtractor<?, ?>... extractors) Returns aKeyExtractorthat wraps the specifiedValueExtractors.static <T,E extends Comparable<? super E>>
LessFilter<T, E> Filters.less(ValueExtractor<T, ? extends E> extractor, E value) Return a filter that tests if the extracted value is less than the specified value.static <T,E extends Comparable<? super E>>
LessEqualsFilter<T, E> Filters.lessEqual(ValueExtractor<T, ? extends E> extractor, E value) Return a filter that tests if the extracted value is less than or equal to the specified value.static <T,E> LikeFilter <T, E> Filters.like(ValueExtractor<T, E> extractor, String sPattern) Return a LikeFilter for pattern match.static <T,E> LikeFilter <T, E> Filters.like(ValueExtractor<T, E> extractor, String sPattern, boolean fIgnoreCase) Return a LikeFilter for pattern match.static <T,E> LikeFilter <T, E> Filters.like(ValueExtractor<T, E> extractor, String sPattern, char chEscape) Return a LikeFilter for pattern match.static <T,E> LikeFilter <T, E> 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 specifiedValueExtractors and returns the extracted values in aList.static <T,E> NotEqualsFilter <T, E> 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> PredicateFilter <T, E> Filters.predicate(ValueExtractor<T, ? extends E> extractor, Remote.Predicate<? super E> predicate) Return a PredicateFilter for a givenPredicate.voidQueryRecord.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).voidSimpleQueryRecord.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>>
ReducerAggregator<K, V, T, 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> RegexFilter <T, E> 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 voidInvocableMapHelper.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.static <K,V, T> SimilaritySearch <K, V, T> Aggregators.similaritySearch(ValueExtractor<? super V, ? extends Vector<T>> extractor, Vector<T> vector, int maxResults) Return aSimilaritySearchaggregator that will use cosine distance to calculate and return up tomaxResultsresults that are closest to the specifiedvector.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>>
TopNAggregator<K, V, T, R> Aggregators.topN(ValueExtractor<? super T, ? extends R> extractor, int cResults) Return an aggregator that calculates the top n of theComparablevalues extracted from a set of entries in a Map.static <K,V, T, R>
TopNAggregator<K, V, T, 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 ValueExtractorModifierConstructorDescriptionConditionalIndex(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.protectedSimpleMapIndex(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 ValueExtractorModifier and TypeFieldDescriptionprotected ValueExtractor<? super T, ? extends E> GroupAggregator.m_extractorThe underlying ValueExtractor.protected ValueExtractor<? super T, ? extends E> TopNAggregator.m_extractorThe ValueExtractor used by this aggregator.Methods in com.tangosol.util.aggregator that return ValueExtractorModifier 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.Methods in com.tangosol.util.aggregator with parameters of type ValueExtractorModifier 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 anEntryAggregatorand 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 ValueExtractorModifierConstructorDescriptionAbstractAggregator(ValueExtractor<? super T, ? extends E> extractor) Construct an AbstractAggregator that will aggregate values extracted from a set ofInvocableMap.Entryobjects.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.protectedGroupAggregator(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.protectedParallel(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 ValueExtractorModifier and TypeMethodDescriptionValueExtractor<? super T, ? extends Comparable> ExtractorComparator.getExtractor()Returns theValueExtractorto extract value(s) to be used in comparison.Constructors in com.tangosol.util.comparator with parameters of type ValueExtractorModifierConstructorDescriptionExtractorComparator(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.extractorModifier and TypeInterfaceDescriptioninterfaceIndexAwareExtractor<T,E> IndexAwareExtractor is an extension to theValueExtractorinterface that supports the creation and destruction of anindex.Classes in com.tangosol.util.extractor that implement ValueExtractorModifier and TypeClassDescriptionclassAbstract super class for ValueExtractor implementations that are based on an underlying array of ValueExtractor objects.classAbstractExtractor<T,E> Abstract base for ValueExtractor implementations.classChainedExtractor<T,E> Composite ValueExtractor implementation based on an array of extractors.classAValueExtractorthat extracts aFragmentfrom a nested property of the target object.classCollectionExtractor<T,E> Collection Extractor is used to extract values from Collections using the providedValueExtractor.classComparisonValueExtractor<T,E extends Number> A synthetic ValueExtractor that returns a result of comparison between two values extracted from the same target.classConditionalExtractor<T,E> An IndexAwareExtractor implementation that is only used to create aConditionalIndex.classDeserializationAccelerator is anIndexAwareExtractorimplementation that is used to create aForwardOnlyMapIndex, which in turn is used for deserialization optimization.classThe EntryExtractor is a base abstract class for special purpose custom ValueExtractor implementations.classAValueExtractorthat is used to extract aFragmentfrom an object.classTrivial ValueExtractor implementation that does not actually extract anything from the passed value, but returns the value itself.classKeyExtractor<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.classComposite ValueExtractor implementation based on an array of extractors.classPofExtractor<T,E> POF-based ValueExtractor implementation.classReflectionExtractor<T,E> Reflection-based ValueExtractor implementation.classScriptValueExtractor<T,E> ScriptValueExtractor is anAbstractExtractorthat wraps a script written in one of the languages supported by Graal VM.classUniversalExtractor<T,E> Universal ValueExtractor implementation.Fields in com.tangosol.util.extractor declared as ValueExtractorModifier and TypeFieldDescriptionprotected ValueExtractor[]AbstractCompositeExtractor.m_aExtractorThe ValueExtractor array.protected ValueExtractor<T, E> CollectionExtractor.m_extractorThe underlying ValueExtractor.protected ValueExtractorCompositeUpdater.m_extractorThe ValueExtractor part.protected ValueExtractor<T, E> ConditionalExtractor.m_extractorThe underlying extractor.protected ValueExtractorDeserializationAccelerator.m_extractorThe underlying extractor.protected ValueExtractor<? super T, ? extends E> KeyExtractor.m_extractorThe underlying ValueExtractor.Methods in com.tangosol.util.extractor that return ValueExtractorModifier 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) Deprecated.static ValueExtractor[]MultiExtractor.createExtractors(String sNames) Deprecated.CollectionExtractor.fromKey()PofExtractor.fromKey()ReflectionExtractor.fromKey()UniversalExtractor.fromKey()CompositeUpdater.getExtractor()Retrieve the ValueExtractor part.ConditionalExtractor.getExtractor()default ValueExtractorIndexAwareExtractor.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 aValueExtractorarray 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 ValueExtractorModifier 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 aValueExtractorarray 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 ValueExtractorModifier 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 ValueExtractorIndexAwareExtractor.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 ValueExtractorModifierConstructorDescriptionAbstractCompositeExtractor(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) ConstructChainedFragmentExtractorinstance.CollectionExtractor(ValueExtractor<T, E> extractor) Construct a CollectionExtractor based on the specifiedValueExtractor.CollectionExtractor(ValueExtractor<T, E> extractor, int nTarget) Construct a CollectionExtractor based on the specifiedValueExtractor.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) ConstructFragmentExtractorinstance.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 ValueExtractorModifier and TypeFieldDescriptionprotected ValueExtractor<? super T, ? extends E> ExtractorFilter.m_extractorThe ValueExtractor used by this filter.protected ValueExtractor<? super V, ? extends E> ValueChangeEventFilter.m_extractorMethods in com.tangosol.util.filter that return ValueExtractorModifier and TypeMethodDescriptionBetweenFilter.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 ValueExtractorModifier and TypeMethodDescriptionprotected static <T> voidAbstractQueryRecorderFilter.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 ValueExtractorModifier 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.intIndexAwareFilter.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 ValueExtractorModifierConstructorDescriptionBetweenFilter(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
Methods in com.tangosol.util.function with parameters of type ValueExtractorModifier and TypeMethodDescriptionstatic <T,E extends Comparable<? super E>>
Remote.Comparator<T> Remote.comparator(ValueExtractor<? super T, ? extends E> extractor) CreateRemote.Comparatorfor the specified extractor that returns aComparablevalue.static <T,E extends Comparable<? super E>>
Remote.BinaryOperator<T> Remote.BinaryOperator.maxBy(ValueExtractor<? super T, ? extends E> comparable) Returns aRemote.BinaryOperatorwhich returns the greater of two elements according to the specifiedComparablevalue.static <T,E extends Comparable<? super E>>
Remote.BinaryOperator<T> Remote.BinaryOperator.minBy(ValueExtractor<? super T, ? extends E> comparable) Returns aRemote.BinaryOperatorwhich returns the lesser of two elements according to the specifiedComparablevalue. -
Uses of ValueExtractor in com.tangosol.util.processor
Fields in com.tangosol.util.processor declared as ValueExtractorModifier and TypeFieldDescriptionprotected ValueExtractor<? super T, ? extends E> ExtractorProcessor.m_extractorThe underlying value extractor.protected ValueExtractor<V, R> PropertyManipulator.m_extractorThe underlying ValueExtractor.Methods in com.tangosol.util.processor that return ValueExtractorModifier and TypeMethodDescriptionPropertyManipulator.getExtractor()Retrieve the underlying ValueExtractor reference.Constructors in com.tangosol.util.processor with parameters of type ValueExtractorModifierConstructorDescriptionExtractorProcessor(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 ValueExtractorModifier and TypeMethodDescriptionstatic <T,U> RemoteCollector <T, ?, Double> RemoteCollectors.averagingDouble(ValueExtractor<? super U, ? extends Number> extractor) Returns aCollectorthat 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 aCollectorthat 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 aCollectorthat 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 aCollectorimplementing 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 aCollectorimplementing 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 aCollectorimplementing 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 RemoteDoubleStreamRemoteStream.mapToDouble(ValueExtractor<? super T, ? extends Number> mapper) Returns anDoubleStreamconsisting of the results of applying the given extractor to the elements of this stream.default RemoteIntStreamRemoteStream.mapToInt(ValueExtractor<? super T, ? extends Number> mapper) Returns anIntStreamconsisting of the results of applying the given extractor to the elements of this stream.default RemoteLongStreamRemoteStream.mapToLong(ValueExtractor<? super T, ? extends Number> mapper) Returns anLongStreamconsisting 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 aCollectorthat produces the maximal element according to a givenComparableattribute, 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 aCollectorthat produces the minimal element according to a givenComparableattribute, 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 aCollectorwhich 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 aCollectorwhich 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 aCollectorwhich 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 aCollectorthat 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 aCollectorthat 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 aCollectorthat 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 concurrentCollectorthat accumulates elements into aConcurrentMapwhose 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 concurrentCollectorthat accumulates elements into aConcurrentMapwhose 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 aCollectorthat accumulates elements into aMapwhose 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 aCollectorthat accumulates elements into aMapwhose 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 aCollectorthat accumulates elements into aMapwhose 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 aCollectorthat 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 aCollectorthat 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 aCollectorthat 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 aCollectorthat 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
Methods in com.tangosol.util.transformer that return ValueExtractorModifier 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.Constructors in com.tangosol.util.transformer with parameters of type ValueExtractorModifierConstructorDescriptionExtractorEventTransformer(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.
Extractors.chained(String...)which usesUniversalExtractor