Uses of Interface
com.tangosol.util.ValueExtractor
-
Packages that use ValueExtractor Package Description com.oracle.coherence.cdi Coherence CDI provides support for CDI (Contexts and Dependency Injection) within Coherence cluster members.com.oracle.coherence.grpc.proxy The Coherence gRPC server implementation.com.oracle.coherence.repository Contains classes to enable Repository-like access to Coherence data.com.tangosol.coherence.config.scheme Defines the Coherence configuration object model classes and interfaces for Caching and Service Schemes.com.tangosol.coherence.dslquery Contains packages and classes supporting the Coherence CohQL command line tool.com.tangosol.coherence.dslquery.function This package contains builders for the various CohQL functions.com.tangosol.coherence.dslquery.operator This package contains implementations of theBaseOperatorinterface.com.tangosol.coherence.dslquery.statement This package containsStatementBuilderimplementations.com.tangosol.coherence.federation Contains Federation conflict resolution interfaces.com.tangosol.coherence.jcache.partitionedcache Contains classes related to partitioned cache implementation of Coherence JCache.com.tangosol.coherence.rest Contains classes related to the Coherence REST API.com.tangosol.coherence.rest.query Contains classes related to the Coherence REST pluggable query engine.com.tangosol.coherence.rest.util Contains packages and classes related to the Coherence REST API utilities.com.tangosol.coherence.rest.util.aggregator Contains classes related to REST-based aggregation.com.tangosol.coherence.rest.util.extractor Contains classes related to REST-based extractor.com.tangosol.net Contains basic cluster interfaces and factories.com.tangosol.net.cache Contains classes providing various caching strategies.com.tangosol.net.topic Contains classes that providing topic entities for publish/subscribe messaging.com.tangosol.util Contains various generic utilities.com.tangosol.util.aggregator Contains concreteInvocableMap.EntryAggregatorimplementations.com.tangosol.util.comparator Contains concreteComparatorimplementations and related interfaces.com.tangosol.util.extractor ContainsValueExtractorandValueUpdaterrelated classes.com.tangosol.util.filter Contains concreteFilterimplementations and related interfaces.com.tangosol.util.function Contains Functional interfaces allowing remote execution of lambda expressions and method references.com.tangosol.util.processor Contains concreteInvocableMap.EntryProcessorimplementations.com.tangosol.util.stream Contains classes to support functional-style operations on remote streams of elements, such as map-reduce transformations on collections.com.tangosol.util.transformer Contains concreteMapEventTransformerimplementations. -
-
Uses of ValueExtractor in com.oracle.coherence.cdi
Methods in com.oracle.coherence.cdi that return ValueExtractor Modifier and Type Method Description ValueExtractor<T,E>ExtractorFactory. create(A annotation)Create aValueExtractorinstance.ValueExtractor<Object,Object>ExtractorProducer.ChainedExtractorsSupplier. create(ChainedExtractor.Extractors annotation)ValueExtractor<Object,Object>ExtractorProducer.ChainedExtractorSupplier. create(ChainedExtractor annotation)ValueExtractor<Object,Object>ExtractorProducer.PofExtractorsSupplier. create(PofExtractor.Extractors annotation)ValueExtractor<Object,Object>ExtractorProducer.PofExtractorSupplier. create(PofExtractor annotation)ValueExtractor<Object,Object>ExtractorProducer.UniversalExtractorsSupplier. create(PropertyExtractor.Extractors annotation)ValueExtractor<Object,Object>ExtractorProducer.UniversalExtractorSupplier. create(PropertyExtractor annotation)<T,E>
ValueExtractor<T,E>ExtractorProducer. getValueExtractor(javax.enterprise.inject.spi.InjectionPoint injectionPoint)Create an instance of aValueExtractorbased on injection point metadata. -
Uses of ValueExtractor in com.oracle.coherence.grpc.proxy
Methods in com.oracle.coherence.grpc.proxy that return ValueExtractor Modifier and Type Method Description ValueExtractor<?,?>NamedCacheServiceImpl. ensureValueExtractor(com.google.protobuf.ByteString bytes, Serializer serializer)Obtain aValueExtractorfrom the serialized data in aByteString. -
Uses of ValueExtractor in com.oracle.coherence.repository
Methods in com.oracle.coherence.repository with parameters of type ValueExtractor Modifier and Type Method Description <R> CompletableFuture<Collection<? extends R>>AbstractAsyncRepository. distinct(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor)Return the set of distinct values for the specified extractor.<R> CompletableFuture<Collection<? extends R>>AbstractAsyncRepository. distinct(ValueExtractor<? super T,? extends R> extractor)Return the set of distinct values for the specified extractor.<R> Collection<? extends R>AbstractRepository. distinct(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor)Return the set of distinct values for the specified extractor.<R> Collection<? extends R>AbstractRepository. distinct(ValueExtractor<? super T,? extends R> extractor)Return the set of distinct values for the specified extractor.<R> CompletableFuture<R>AbstractAsyncRepository. get(ID id, ValueExtractor<? super T,? extends R> extractor)Return the value extracted from an entity with a given identifier.<R> 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.<R> Map<ID,R>AbstractRepository. getAll(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor)Return a map of values extracted from a set of entities based on the specified criteria.<R> Map<ID,R>AbstractRepository. getAll(ValueExtractor<? super T,? extends R> extractor)Return a map of values extracted from all entities in the repository.<R> Map<ID,R>AbstractRepository. getAll(Collection<? extends ID> colIds, ValueExtractor<? super T,? extends R> extractor)Return a map of values extracted from a set of entities with the given identifiers.<R extends Comparable<? super R>>
CompletableFuture<Collection<T>>AbstractAsyncRepository. getAllOrderedBy(Filter<?> filter, ValueExtractor<? super T,? extends R> orderBy)Return all entities that satisfy the specified criteria, sorted using 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.<K> Map<K,Set<T>>AbstractRepository. groupBy(Filter<?> filter, ValueExtractor<? super T,? extends K> extractor)Return the grouping of entities by the specified extractor.<K> Map<K,SortedSet<T>>AbstractRepository. groupBy(Filter<?> filter, ValueExtractor<? super T,? extends K> extractor, Remote.Comparator<? super T> orderBy)Return the grouping of entities by the specified extractor, ordered by the specified attribute within each group.<K,A,R,M extends Map<K,R>>
MAbstractRepository. groupBy(Filter<?> filter, ValueExtractor<? super T,? extends K> extractor, Remote.Supplier<M> mapFactory, RemoteCollector<? super T,A,R> collector)Return the grouping of entities by the specified extractor.<K,A,R>
Map<K,R>AbstractRepository. groupBy(Filter<?> filter, ValueExtractor<? super T,? extends K> extractor, RemoteCollector<? super T,A,R> collector)Return the grouping of entities by the specified extractor.<K> Map<K,Set<T>>AbstractRepository. groupBy(ValueExtractor<? super T,? extends K> extractor)Return the grouping of entities by the specified extractor.<K> Map<K,SortedSet<T>>AbstractRepository. groupBy(ValueExtractor<? super T,? extends K> extractor, Remote.Comparator<? super T> orderBy)Return the grouping of entities by the specified extractor, ordered by the specified attribute within each group.<K,A,R,M extends Map<K,R>>
MAbstractRepository. groupBy(ValueExtractor<? super T,? extends K> extractor, Remote.Supplier<M> mapFactory, RemoteCollector<? super T,A,R> collector)Return the grouping of entities by the specified extractor.<K,A,R>
Map<K,R>AbstractRepository. groupBy(ValueExtractor<? super T,? extends K> extractor, RemoteCollector<? super T,A,R> collector)Return the grouping of entities by the specified extractor.<R extends Comparable<? super R>>
CompletableFuture<Optional<T>>AbstractAsyncRepository. maxBy(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor)Return the entity with the maximum value of the specified function.<R extends Comparable<? super R>>
CompletableFuture<Optional<T>>AbstractAsyncRepository. maxBy(ValueExtractor<? super T,? extends R> extractor)Return the entity with the maximum value of the specified function.<R extends Comparable<? super R>>
Optional<T>AbstractRepository. maxBy(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor)Return the entity with the maximum value of the specified function.<R extends Comparable<? super R>>
Optional<T>AbstractRepository. maxBy(ValueExtractor<? super T,? extends R> extractor)Return the entity with the maximum value of the specified function.<R extends Comparable<? super R>>
CompletableFuture<Optional<T>>AbstractAsyncRepository. minBy(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor)Return the entity with the minimum value of the specified function.<R extends Comparable<? super R>>
CompletableFuture<Optional<T>>AbstractAsyncRepository. minBy(ValueExtractor<? super T,? extends R> extractor)Return the entity with the minimum value of the specified function.<R extends Comparable<? super R>>
Optional<T>AbstractRepository. minBy(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor)Return the entity with the minimum value of the specified function.<R extends Comparable<? super R>>
Optional<T>AbstractRepository. minBy(ValueExtractor<? super T,? extends R> extractor)Return the entity with the minimum value of the specified function.<R extends Comparable<? super R>>
CompletableFuture<List<R>>AbstractAsyncRepository. top(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor, int cResults)Return the top N highest values for the specified extractor.<R> CompletableFuture<List<R>>AbstractAsyncRepository. top(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor, Remote.Comparator<? super R> comparator, int cResults)Return the top N highest values for the specified extractor.<R extends Comparable<? super R>>
CompletableFuture<List<R>>AbstractAsyncRepository. top(ValueExtractor<? super T,? extends R> extractor, int cResults)Return the top N highest values for the specified extractor.<R> CompletableFuture<List<R>>AbstractAsyncRepository. top(ValueExtractor<? super T,? extends R> extractor, Remote.Comparator<? super R> comparator, int cResults)Return the top N highest values for the specified extractor.<R extends Comparable<? super R>>
List<R>AbstractRepository. top(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor, int cResults)Return the top N highest values for the specified extractor.<R> List<R>AbstractRepository. top(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor, Remote.Comparator<? super R> comparator, int cResults)Return the top N highest values for the specified extractor.<R extends Comparable<? super R>>
List<R>AbstractRepository. top(ValueExtractor<? super T,? extends R> extractor, int cResults)Return the top N highest values for the specified extractor.<R> List<R>AbstractRepository. top(ValueExtractor<? super T,? extends R> extractor, Remote.Comparator<? super R> comparator, int cResults)Return the top N highest values for the specified extractor.<R extends Comparable<? super R>>
CompletableFuture<List<T>>AbstractAsyncRepository. topBy(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor, int cResults)Return the top N entities with the highest values for the specified extractor.<R extends Comparable<? super R>>
CompletableFuture<List<T>>AbstractAsyncRepository. topBy(ValueExtractor<? super T,? extends R> extractor, int cResults)Return the top N entities with the highest values for the specified extractor.<R extends Comparable<? super R>>
List<T>AbstractRepository. topBy(Filter<?> filter, ValueExtractor<? super T,? extends R> extractor, int cResults)Return the top N entities with the highest values for the specified extractor.<R extends Comparable<? super R>>
List<T>AbstractRepository. topBy(ValueExtractor<? super T,? extends R> extractor, int cResults)Return the top N entities with the highest values for the specified extractor. -
Uses of ValueExtractor in com.tangosol.coherence.config.scheme
Methods in com.tangosol.coherence.config.scheme that return types with arguments of type ValueExtractor Modifier and Type Method Description ParameterizedBuilder<ValueExtractor>ContinuousQueryCacheScheme. getTransformerBuilder()Return theParameterizedBuilderused to construct theValueExtractorto be used as a transformer by theContinuousQueryCache.Method parameters in com.tangosol.coherence.config.scheme with type arguments of type ValueExtractor Modifier and Type Method Description voidContinuousQueryCacheScheme. 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 ValueExtractor Modifier and Type Method Description ValueExtractorFilterBuilder. makeExtractor(NodeTerm term)Process the AST Tree using the given Term that represents getter.ValueExtractorChainedExtractorBuilder. realize(String sCacheName, int nTarget, String sProperties)Call the realize(String, int, String) method on eachExtractorBuilderin the chain returning the result of the first ExtractorBuilder to return a non-null value.ValueExtractorExtractorBuilder. realize(String sCacheName, int nTarget, String sProperties)Create aValueExtractorfor the given cache name, target and property chain.ValueExtractorReflectionExtractorBuilder. realize(String sCacheName, int nTarget, String sProperties)ValueExtractorUniversalExtractorBuilder. realize(String sCacheName, int nTarget, String sProperties) -
Uses of ValueExtractor in com.tangosol.coherence.dslquery.function
Fields in com.tangosol.coherence.dslquery.function with type parameters of type ValueExtractor Modifier and Type Field Description static ParameterizedBuilder<ValueExtractor>FunctionBuilders. KEY_FUNCTION_BUILDERThisParameterizedBuilderhandles the key() function. -
Uses of ValueExtractor in com.tangosol.coherence.dslquery.operator
Methods in com.tangosol.coherence.dslquery.operator that return ValueExtractor Modifier and Type Method Description ValueExtractorBaseOperator. makeExtractor(Term termLeft, Term termRight, TermWalker walker)ValueExtractorBaseOperator. 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 ValueExtractor Modifier and Type Field Description protected ValueExtractorCreateIndexStatementBuilder.CreateIndexStatement. f_extractorTheValueExtractorto be used to create the index.protected ValueExtractorDropIndexStatementBuilder.DropIndexStatement. f_extractorTheValueExtractorto be used to create the index.Constructors in com.tangosol.coherence.dslquery.statement with parameters of type ValueExtractor Constructor Description CreateIndexStatement(String sCache, ValueExtractor extractor)Construct a CreateIndexStatement that will create an index on the specified cache using the specifiedValueExtractor.DropIndexStatement(String sCacheName, ValueExtractor extractor)Construct a DropIndexStatement that will drop the index created with the specifiedValueExtractorfrom the cache with the specified name. -
Uses of ValueExtractor in com.tangosol.coherence.federation
Methods in com.tangosol.coherence.federation with parameters of type ValueExtractor Modifier and Type Method Description <T> TChangeRecord.Entry. extract(ValueExtractor<V,T> extractor)Extract a value from the entry value using theValueExtractor. -
Uses of ValueExtractor in com.tangosol.coherence.jcache.partitionedcache
Classes in com.tangosol.coherence.jcache.partitionedcache that implement ValueExtractor Modifier and Type Class Description static classPartitionedJCacheStatistics.CacheStatisticsExtractorGet CacheStatistics from binEntry's context for JCache id.Constructors in com.tangosol.coherence.jcache.partitionedcache with parameters of type ValueExtractor Constructor Description PartitionedCacheStatisticsAggregator(JCacheIdentifier id, ValueExtractor valueExtractor)Constructs an aggregator to aggregate JCache Cache Statistics from all storage-enabled servers for a JCache implemented as a Partitioned Cache.PartitionedCacheStatisticsClear(JCacheIdentifier id, ValueExtractor valueExtractor)Constructs an aggregator to aggregate JCache Cache Statistics from all storage-enabled servers for a JCache implemented as a Partitioned Cache. -
Uses of ValueExtractor in com.tangosol.coherence.rest
Methods in com.tangosol.coherence.rest with parameters of type ValueExtractor Modifier and Type Method Description protected 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(javax.ws.rs.core.UriInfo uriInfo, ValueExtractor<Map.Entry,?> extractor, int nStart, int cResults, String sSort)Returns a collection of extracted values for cache entries that satisfy the criteria expressed by the query. -
Uses of ValueExtractor in com.tangosol.coherence.rest.query
Methods in com.tangosol.coherence.rest.query with parameters of type ValueExtractor Modifier and Type Method Description <E> Collection<E>Query. execute(NamedCache cache, ValueExtractor<Map.Entry,? extends E> extractor, String sOrder, int nStart, int cResults)Return the values that satisfy this query. -
Uses of ValueExtractor in com.tangosol.coherence.rest.util
Classes in com.tangosol.coherence.rest.util that implement ValueExtractor Modifier and Type Class Description classPropertySet<T>Represents a set of named properties and allows the extraction of those properties from a target object.Fields in com.tangosol.coherence.rest.util declared as ValueExtractor Modifier and Type Field Description protected ValueExtractorMvelManipulator. m_extractorThe underlying ValueExtractor.protected ValueExtractorPropertySpec. m_extractorAn extractor that can extract value of this property from a target object.Methods in com.tangosol.coherence.rest.util that return ValueExtractor Modifier and Type Method Description protected ValueExtractorComparatorBuilder. createExtractor(String sExpr)Create expression extractor.ValueExtractorMvelManipulator. getExtractor()Retrieve the underlying ValueExtractor reference.protected ValueExtractorPropertySpec. getExtractor()Return extractor for this property.Methods in com.tangosol.coherence.rest.util with parameters of type ValueExtractor Modifier and Type Method Description ComparatorBuilderComparatorBuilder. asc(ValueExtractor extractor)Add comparator to this builder.protected ComparatorComparatorBuilder. createComparator(ValueExtractor extractor)Create extractor comparator.ComparatorBuilderComparatorBuilder. desc(ValueExtractor extractor)Add comparator to this builder. -
Uses of ValueExtractor in com.tangosol.coherence.rest.util.aggregator
Methods in com.tangosol.coherence.rest.util.aggregator with parameters of type ValueExtractor Modifier and Type Method Description protected InvocableMap.EntryAggregatorDefaultAggregatorFactory. createAggregator(ValueExtractor extractor)Create and initialize a new aggregator instance. -
Uses of ValueExtractor in com.tangosol.coherence.rest.util.extractor
Classes in com.tangosol.coherence.rest.util.extractor that implement ValueExtractor Modifier and Type Class Description classMvelExtractorMVEL-based ValueExtractor implementation. -
Uses of ValueExtractor in com.tangosol.net
Fields in com.tangosol.net declared as ValueExtractor Modifier and Type Field Description protected ValueExtractor<? super V,?>MapViewBuilder. m_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 ValueExtractor Modifier and Type Method Description Map<ValueExtractor,MapIndex>BackingMapContext. 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.Map<ValueExtractor,MapIndex>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 ValueExtractor Modifier and Type Method Description default longPagedTopicService. ensureSubscriberGroup(String sTopicName, String sGroupName, Filter<?> filter, ValueExtractor<?,?> extractor)Ensure the specified subscriber group 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)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 ValueExtractor Modifier and Type Field Description protected 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 ValueExtractor Modifier and Type Method Description ValueExtractor<? 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 ValueExtractor Modifier and Type Method Description <T,E>
voidContinuousQueryCache. addIndex(ValueExtractor<? super T,? extends E> extractor, boolean fOrdered, Comparator<? super E> comparator)IfContinuousQueryCache.isCacheValues()istrue, the index will be created locally as well as on theNamedCachethisContinuousQueryCachewraps, otherwise, the index will be created on the wrappedNamedCacheonly.<T,E>
voidNearCache. addIndex(ValueExtractor<? super T,? extends E> extractor, boolean fOrdered, Comparator<? super E> comparator)Add an index to this QueryMap.<T,E>
voidWrapperNamedCache. addIndex(ValueExtractor<? super T,? extends E> extractor, boolean fOrdered, Comparator<? super E> comparator)Add an index to this QueryMap.ObjectBackingMapBinaryEntry. 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>
voidContinuousQueryCache. removeIndex(ValueExtractor<? super T,? extends E> extractor)IfContinuousQueryCache.isCacheValues()istrue, the index will be removed locally, however, this call will not cause the index on theNamedCachethisContinuousQueryCachewraps.<T,E>
voidNearCache. removeIndex(ValueExtractor<? super T,? extends E> extractor)Remove an index from this QueryMap.<T,E>
voidWrapperNamedCache. removeIndex(ValueExtractor<? super T,? extends E> extractor)Remove an index from this QueryMap.protected Map<K,V_FRONT>ContinuousQueryCache. transform(Set<Map.Entry<K,V_BACK>> setIn, ValueExtractor<? super V_BACK,? extends V_FRONT> transformer)Transform a set of entries.Constructors in com.tangosol.net.cache with parameters of type ValueExtractor Constructor Description ContinuousQueryCache(NamedCache<K,V_BACK> cache, Filter filter, boolean fCacheValues, MapListener<? super K,? super V_FRONT> listener, ValueExtractor<? super V_BACK,? extends V_FRONT> transformer)Construct the ContinuousQueryCache.ContinuousQueryCache(NamedCache<K,V_BACK> cache, Filter filter, MapListener<? super K,? super V_FRONT> listener, ValueExtractor<? super V_BACK,? extends V_FRONT> transformer)Create a materialized view of 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 ValueExtractor Modifier and Type Method Description ValueExtractor<? super V,U>Subscriber.Convert. getExtractor()Return the option's converter function.Methods in com.tangosol.net.topic with parameters of type ValueExtractor Modifier and Type Method Description voidNamedTopic. ensureSubscriberGroup(String sGroup, Filter<?> filter, ValueExtractor<?,?> extractor)Ensure that the specified subscriber group exists for this topic.static <V,U>
Subscriber.Convert<V,U>Subscriber.Convert. using(ValueExtractor<? super V,U> extractor)Return a Convert option with the specified extractor.static <V,U>
Subscriber.Convert<V,U>Subscriber. withConverter(ValueExtractor<? super V,U> extractor)Return a Convert option with the specified extractor.Constructors in com.tangosol.net.topic with parameters of type ValueExtractor Constructor Description Convert(ValueExtractor<? super V,U> extractor) -
Uses of ValueExtractor in com.tangosol.util
Classes in com.tangosol.util that implement ValueExtractor Modifier and Type Class Description static classNullImplementation.NullValueExtractorA ValueExtractor that always results in the passed-in value.Fields in com.tangosol.util declared as ValueExtractor Modifier and Type Field Description protected 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.Methods in com.tangosol.util that return ValueExtractor Modifier and Type Method Description default <V> ValueExtractor<T,V>ValueExtractor. andThen(ValueExtractor<? super E,? extends V> after)Returns a composed extractor that first applies this extractor to its input, and then applies 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>Extractors. chained(String... fields)Returns an extractor that extracts the specified fields where extraction occurs in a chain where the result of each field extraction is the input to the next extractor.default <V> ValueExtractor<V,E>ValueExtractor. compose(ValueExtractor<? super V,? extends T> before)Returns a composed extractor that first applies 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>Extractors. extract(String from)Returns an extractor that extracts the value of the specified field.static <T,E>
ValueExtractor<T,E>Extractors. extract(String from, Object... aoParam)Returns an extractor that extracts the value of the specified field.static <T,E>
ValueExtractor<T,E>ValueExtractor. forMethod(Method method)Return aValueExtractorfor the specifiedMethod.static <T> ValueExtractor<T,Fragment<T>>Extractors. fragment(ValueExtractor<? super T,?>... aExtractors)Return aValueExtractorthat extracts aFragmentfrom a target object.static <T,E>
ValueExtractor<T,Fragment<E>>Extractors. fragment(ValueExtractor<? super T,E> from, ValueExtractor<? super E,?>... aExtractors)Return aValueExtractorthat extracts a nestedFragmentfrom a property of the target object.default ValueExtractor<T,E>ValueExtractor. fromKey()Obtain a version of thisValueExtractorthat targets an entry's key.static <T> ValueExtractor<T,?>Extractors. fromPof(int... indexes)Returns an extractor that extracts the value of the specified index(es) from a POF encoded binary value.static <T,E>
ValueExtractor<T,E>Extractors. fromPof(Class<E> cls, int... indexes)Returns an extractor that extracts the value of the specified index(es) from a POF encoded binary value.static <T,E>
ValueExtractor<T,E>Extractors. fromPof(Class<E> cls, PofNavigator navigator)Returns an extractor that extracts the value of the specified index(es) from a POF encoded binary value.static <T,E>
ValueExtractor<T,E>Extractors. fromPof(Class<E> cls, String sPath)Returns an extractor that extracts the value of the specified index(es) from a POF encoded@PortableType.ValueExtractor<T,V>ValueManipulator. getExtractor()Retrieve the underlying ValueExtractor reference.ValueExtractorForwardOnlyMapIndex. getValueExtractor()Obtain the ValueExtractor object that the MapIndex uses to extract an indexable Object from a value stored in the indexed Map.ValueExtractor<V,E>MapIndex. getValueExtractor()Obtain the ValueExtractor object that the MapIndex uses to extract an indexable Object from a value stored in the indexed Map.static <T,E>
ValueExtractor<T,E>NullImplementation. getValueExtractor()Factory method: Obtain a null implementation of a ValueExtractor.ValueExtractorSimpleMapIndex. 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 specifiedValueExtractors and returns the extracted values in aList.static <T> ValueExtractor<T,List<?>>Extractors. multi(String... fields)Returns an extractor that extracts the specified fields and returns the extracted values in aList.static <T,E>
ValueExtractor<T,E>ValueExtractor. of(ValueExtractor<T,E> extractor)Helper method to allow composition/chaining of extractors.static <T,E>
ValueExtractor<T,E>Extractors. script(String sLanguage, String sScriptPath, Object... aoArgs)Instantiate aValueExtractorthat is implemented using the specified language.Methods in com.tangosol.util that return types with arguments of type ValueExtractor Modifier and Type Method Description default Map<ValueExtractor,MapIndex>BinaryEntry. getIndexMap()Return a map of indexes defined for the partition of thecachethat this BinaryEntry belongs to.Methods in com.tangosol.util with parameters of type ValueExtractor Modifier and Type Method Description <T,E>
voidConverterCollections.ConverterNamedCache. addIndex(ValueExtractor<? super T,? extends E> extractor, boolean fOrdered, Comparator<? super E> comparator)Add an index to this QueryMap.<T,E>
voidConverterCollections.ConverterQueryMap. addIndex(ValueExtractor<? super T,? extends E> extractor, boolean fOrdered, Comparator<? super E> comparator)Add an index to this QueryMap.static 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>
voidQueryMap. addIndex(ValueExtractor<? super T,? extends E> extractor)Add an unordered index to this QueryMap.<T,E>
voidQueryMap. addIndex(ValueExtractor<? super T,? extends E> extractor, boolean fOrdered, Comparator<? super E> comparator)Add an index to this QueryMap.default <V> ValueExtractor<T,V>ValueExtractor. andThen(ValueExtractor<? super E,? extends V> after)Returns a composed extractor that first applies this extractor to its input, and then applies theafterextractor 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 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>>
Filter<T>Filters. contains(ValueExtractor<T,C> extractor, E value)Return a filter that tests if the extracted collection contains the specified value.static <T,E,C extends Collection<? extends E>>
Filter<T>Filters. containsAll(ValueExtractor<T,C> extractor, E... values)Return a filter that tests if the extracted collection contains all of the specified values.static <T,E,C extends Collection<? extends E>>
Filter<T>Filters. containsAll(ValueExtractor<T,C> extractor, Set<? extends E> setValues)Return a filter that tests if the extracted collection contains all of the specified values.static <T,E,C extends Collection<? extends E>>
Filter<T>Filters. containsAny(ValueExtractor<T,C> extractor, E... values)Return a filter that tests if the extracted collection contains any of the specified values.static <T,E,C extends Collection<? extends E>>
Filter<T>Filters. containsAny(ValueExtractor<T,C> extractor, Set<? extends E> setValues)Return a filter that tests if the extracted collection contains any of the specified values.static <K,V,T,R>
InvocableMap.StreamingAggregator<K,V,?,Collection<R>>Aggregators. distinctValues(ValueExtractor<? super T,? extends R> extractor)Return an aggregator that calculates the set of distinct values extracted from the entries in a Map.static <K,V,T>
InvocableMap.StreamingAggregator<K,V,?,Double>Aggregators. doubleMax(ValueExtractor<? super T,? extends Number> extractor)Return an aggregator that calculates a maximum of the numeric values extracted from a set of entries in a Map.static <K,V,T>
InvocableMap.StreamingAggregator<K,V,?,Double>Aggregators. doubleMin(ValueExtractor<? super T,? extends Number> extractor)Return an aggregator that calculates a minimum of the numeric values extracted from a set of entries in a Map.static <K,V,T>
InvocableMap.StreamingAggregator<K,V,?,Double>Aggregators. doubleSum(ValueExtractor<? super T,? extends Number> extractor)Return an aggregator that calculates a sum of the numeric values extracted from a set of entries in a Map.static <T,E>
Filter<T>Filters. equal(ValueExtractor<T,? extends E> extractor, E value)Return a filter that tests for equality.<T,E>
EConverterCollections.ConverterMapEvent.ConverterMapEventBinaryEntry. extract(ValueExtractor<T,E> extractor)Depending upon the type of the ValueExtractor route the call to the appropriate extract method.ObjectInvocableMapHelper.RoutingMapTriggerEntry. extract(ValueExtractor extractor)Extract a value out of the Entry's key or value.static <K,V,T,R>
InvocableMap.EntryProcessor<K,V,R>Processors. extract(ValueExtractor<? super T,? extends R> extractor)Construct an extract processor based on the specifiedValueExtractor.<T,E>
EQueryMap.Entry. extract(ValueExtractor<T,E> extractor)Extract a value out of the Entry's key or value.<T,E>
ESimpleMapEntry. extract(ValueExtractor<T,E> extractor)Extract a value out of the Entry's key or value.static <T,E,K,V>
EInvocableMapHelper. extractFromEntry(ValueExtractor<? super T,? extends E> extractor, Map.Entry<? extends K,? extends V> entry)Extract a value from the specified entry using the specified extractor.default <E> 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> ValueExtractor<T,Fragment<T>>Extractors. fragment(ValueExtractor<? super T,?>... aExtractors)Return aValueExtractorthat extracts aFragmentfrom a target object.static <T,E>
ValueExtractor<T,Fragment<E>>Extractors. fragment(ValueExtractor<? super T,E> from, ValueExtractor<? super E,?>... aExtractors)Return aValueExtractorthat extracts a nestedFragmentfrom a property of the target object.<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>>
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 specifiedValueExtractors 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.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>>
InvocableMap.StreamingAggregator<K,V,?,Map<K,R>>Aggregators. reduce(ValueExtractor<? super T,? extends R> extractor)Return an aggregator that will return the extracted value for each entry in the map.static <T,E>
Filter<T>Filters. regex(ValueExtractor<T,E> extractor, String sRegex)Return a RegexFilter for pattern match.<T,E>
voidConverterCollections.ConverterNamedCache. removeIndex(ValueExtractor<? super T,? extends E> extractor)Remove an index from this QueryMap.<T,E>
voidConverterCollections.ConverterQueryMap. removeIndex(ValueExtractor<? super T,? extends E> extractor)Remove an index from this QueryMap.static voidInvocableMapHelper. removeIndex(ValueExtractor extractor, ObservableMap map, Map mapIndex)Remove the index keyed by the given extractor from the given map of indexes.<T,E>
voidQueryMap. removeIndex(ValueExtractor<? super T,? extends E> extractor)Remove an index from this QueryMap.default <T,E>
RemoteStream<E>InvocableMap. stream(Filter filter, ValueExtractor<T,? extends E> extractor)Return a stream of values extracted from all the entries that satisfy the specified filter.default <T,E>
RemoteStream<E>InvocableMap. stream(ValueExtractor<T,? extends E> extractor)Return a stream of values extracted from the entries of this map.default <T,E>
RemoteStream<E>InvocableMap. stream(Collection<? extends K> collKeys, ValueExtractor<T,? extends E> extractor)Return a stream of values extracted from the entries with the specified keys.static <K,V,T,R extends Comparable<? super R>>
InvocableMap.StreamingAggregator<K,V,?,R[]>Aggregators. topN(ValueExtractor<? super T,? extends R> extractor, int cResults)Return an aggregator that calculates the top n of theComparablevalues extracted from a set of entries in a Map.static <K,V,T,R>
InvocableMap.StreamingAggregator<K,V,?,R[]>Aggregators. topN(ValueExtractor<? super T,? extends R> extractor, Comparator<? super R> comparator, int cResults)Return an aggregator that calculates the top n of the values extracted from a set of entries in a Map.Constructors in com.tangosol.util with parameters of type ValueExtractor Constructor Description ConditionalIndex(Filter filter, ValueExtractor extractor, boolean fOrdered, Comparator comparator, boolean fForwardIndex, BackingMapContext ctx)Construct a ConditionalIndex.ForwardOnlyMapIndex(ValueExtractor extractor, BackingMapContext ctx, boolean fOnDemand)Construct an index for the given map.IndexLookupRecord(ValueExtractor extractor, MapIndex index)Construct an IndexLookupRecord.SimpleMapIndex(ValueExtractor extractor, boolean fOrdered, Comparator comparator, boolean fInit, BackingMapContext ctx)Construct an index for the given map.SimpleMapIndex(ValueExtractor extractor, boolean fOrdered, Comparator comparator, BackingMapContext ctx)Construct an index for the given map. -
Uses of ValueExtractor in com.tangosol.util.aggregator
Fields in com.tangosol.util.aggregator declared as ValueExtractor Modifier and Type Field Description protected ValueExtractor<? super T,? extends E>GroupAggregator. m_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 ValueExtractor Modifier and Type Method Description ValueExtractor<?,? extends E>GroupAggregator. getExtractor()Obtain the underlying ValueExtractor.ValueExtractor<? super T,? extends E>AbstractAggregator. getValueExtractor()Determine the ValueExtractor whose values this aggregator is aggregating.Methods in com.tangosol.util.aggregator with parameters of type ValueExtractor Modifier and Type Method Description static <K,V,T,E,R>
GroupAggregator<K,V,T,E,R>GroupAggregator. createInstance(ValueExtractor<? super T,? extends E> extractor, InvocableMap.EntryAggregator<? super K,? super V,R> aggregator, Filter filter)Create an instance of GroupAggregator based on a specified extractor and 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 ValueExtractor Constructor Description AbstractAggregator(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.GroupAggregator(ValueExtractor<? super T,? extends E> extractor, InvocableMap.EntryAggregator<? super K,? super V,R> aggregator, Filter filter)Construct a GroupAggregator based on a specified ValueExtractor and underlying EntryAggregator.LongMax(ValueExtractor<? super T,? extends Number> extractor)Construct a LongMax aggregator.LongMin(ValueExtractor<? super T,? extends Number> extractor)Construct a LongMin aggregator.LongSum(ValueExtractor<? super T,? extends Number> extractor)Construct a LongSum aggregator.Parallel(ValueExtractor<? super T,? extends E> extractor, InvocableMap.EntryAggregator<? super K,? super V,R> aggregator, Filter<?> filter)Deprecated.Construct a Parallel aggregator based on a specified ValueExtractor and underlying ParallelAwareAggregator.ReducerAggregator(ValueExtractor<? super T,? extends E> extractor)Construct a ReducerAggregator based on the specified extractor.TopNAggregator(ValueExtractor<? super T,? extends E> extractor, Comparator<? super E> comparator, int cResults)Construct a TopNAggregator that will aggregate the top extracted values, as determined by the specified comparator. -
Uses of ValueExtractor in com.tangosol.util.comparator
Methods in com.tangosol.util.comparator that return ValueExtractor Modifier and Type Method Description ValueExtractor<? super T,? extends Comparable>ExtractorComparator. getExtractor()Returns theValueExtractorto extract value(s) to be used in comparison.Constructors in com.tangosol.util.comparator with parameters of type ValueExtractor Constructor Description ExtractorComparator(ValueExtractor<? super T,? extends E> extractor)Construct a ExtractorComparator with the specified extractor. -
Uses of ValueExtractor in com.tangosol.util.extractor
Subinterfaces of ValueExtractor in com.tangosol.util.extractor Modifier and Type Interface Description interfaceIndexAwareExtractor<T,E>IndexAwareExtractor is an extension to theValueExtractorinterface that supports the creation and destruction of anindex.Classes in com.tangosol.util.extractor that implement ValueExtractor Modifier and Type Class Description classAbstractCompositeExtractor<T,E>Abstract 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.classChainedFragmentExtractor<T,E>AValueExtractorthat extracts aFragmentfrom a nested property of the target object.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.classDeserializationAcceleratorDeserializationAccelerator is anIndexAwareExtractorimplementation that is used to create aForwardOnlyMapIndex, which in turn is used for deserialization optimization.classEntryExtractorThe EntryExtractor is a base abstract class for special purpose custom ValueExtractor implementations.classFragmentExtractor<T>AValueExtractorthat is used to extract aFragmentfrom an object.classIdentityExtractor<T>Trivial 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.classMultiExtractorComposite 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 ValueExtractor Modifier and Type Field Description protected ValueExtractor[]AbstractCompositeExtractor. m_aExtractorThe ValueExtractor array.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 ValueExtractor Modifier and Type Method Description <V> ValueExtractor<T,V>ChainedExtractor. andThen(ValueExtractor<? super E,? extends V> after)<V> ValueExtractor<V,E>ChainedExtractor. compose(ValueExtractor<? super V,? extends T> before)static <T,E>
ValueExtractor<T,E>UniversalExtractor. createExtractor(String sNames)Return a ValueExtractor representing dot separated list of property and/or method names.static ValueExtractor[]ChainedExtractor. createExtractors(String sName)Parse a dot-delimited sequence of method names and instantiate a corresponding array ofReflectionExtractorobjects.static ValueExtractor[]MultiExtractor. createExtractors(String sNames)Parse a comma-delimited sequence of method names and instantiate a corresponding array ofValueExtractorobjects.ValueExtractorCompositeUpdater. getExtractor()Retrieve the ValueExtractor part.ValueExtractorConditionalExtractor. 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.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 ValueExtractor Modifier and Type Method Description <V> ValueExtractor<T,V>ChainedExtractor. andThen(ValueExtractor<? super E,? extends V> after)<V> ValueExtractor<V,E>ChainedExtractor. compose(ValueExtractor<? super V,? extends T> before)protected static ValueExtractor[]ChainedExtractor. merge(ValueExtractor[] aHead, ValueExtractor[] aTail)Return 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 ValueExtractor Modifier and Type Method Description MapIndexConditionalExtractor. createIndex(boolean fOrdered, Comparator comparator, Map<ValueExtractor<T,E>,MapIndex> mapIndex, BackingMapContext ctx)Create an index and associate it with the corresponding extractor.MapIndexIndexAwareExtractor. createIndex(boolean fOrdered, Comparator comparator, Map<ValueExtractor<T,E>,MapIndex> mapIndex, BackingMapContext ctx)Create an index and associate it with the corresponding extractor.MapIndexConditionalExtractor. destroyIndex(Map<ValueExtractor<T,E>,MapIndex> mapIndex)Destroy an existing index and remove it from the given map of indexes.MapIndexIndexAwareExtractor. 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 ValueExtractor Constructor Description AbstractCompositeExtractor(ValueExtractor[] aExtractor)Construct a AbstractCompositeExtractor based on the specified ValueExtractor array.ChainedExtractor(ValueExtractor[] aExtractor)Construct a ChainedExtractor based on a specified ValueExtractor array.ChainedExtractor(ValueExtractor<? super T,? extends U> extractor1, ValueExtractor<? super U,? extends E> extractor2)Construct a ChainedExtractor based on two extractors.ChainedFragmentExtractor(ValueExtractor<? super T,? extends E> from, ValueExtractor<? super E,?>... aExtractors)ConstructChainedFragmentExtractorinstance.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 ValueExtractor Modifier and Type Field Description protected 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 ValueExtractor Modifier and Type Method Description ValueExtractorBetweenFilter. getValueExtractor()Obtain the ValueExtractor used by this filter.ValueExtractor<? super T,? extends E>ExtractorFilter. getValueExtractor()Obtain the ValueExtractor used by this filter.Methods in com.tangosol.util.filter with parameters of type ValueExtractor Modifier and Type Method Description protected static <T> 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 ValueExtractor Modifier and Type Method Description Filter<?>IndexAwareFilter. applyIndex(Map<? extends ValueExtractor<? extends V,?>,? extends MapIndex<? extends K,? extends V,?>> mapIndexes, Set<? extends K> setKeys)Filter remaining keys using a Map of available indexes.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 ValueExtractor Constructor Description BetweenFilter(ValueExtractor<? super T,? extends E> extractor, E from, E to)Construct a BetweenFilter for testing "Between" condition.BetweenFilter(ValueExtractor<? super T,? extends E> extractor, E lowerBound, E upperBound, boolean fIncludeLowerBound, boolean fIncludeUpperBound)Construct a BetweenFilter for testing "Between" condition.ComparisonFilter(ValueExtractor<? super T,? extends E> extractor, C value)Construct a ComparisonFilter.ContainsAllFilter(ValueExtractor<? super T,? extends E> extractor, Set<?> setValues)Construct an ContainsAllFilter for testing containment of the given Set of values.ContainsAnyFilter(ValueExtractor<? super T,? extends E> extractor, Set<?> setValues)Construct an ContainsAnyFilter for testing containment of any value in the given Set.ContainsFilter(ValueExtractor<? super T,? extends E> extractor, E value)Construct an ContainsFilter for testing containment of the given object.EqualsFilter(ValueExtractor<? super T,? extends E> extractor, E value)Construct an EqualsFilter for testing equality.ExtractorFilter(ValueExtractor<? super T,? extends E> extractor)Construct a ExtractorFilter for a given ValueExtractor.GreaterEqualsFilter(ValueExtractor<? super T,? extends E> extractor, E value)Construct a GreaterEqualFilter for testing "Greater or Equal" condition.GreaterFilter(ValueExtractor<? super T,? extends E> extractor, E value)Construct a GreaterFilter for testing "Greater" condition.InFilter(ValueExtractor<? super T,? extends E> extractor, Set<? extends E> setValues)Construct an InFilter for testing "In" condition.IsNotNullFilter(ValueExtractor<? super T,? extends E> extractor)Construct a IsNotNullFilter for testing inequality to null.IsNullFilter(ValueExtractor<? super T,? extends E> extractor)Construct a IsNullFilter for testing equality to null.LessEqualsFilter(ValueExtractor<? super T,? extends E> extractor, E value)Construct a LessEqualsFilter for testing "Less or Equals" condition.LessFilter(ValueExtractor<? super T,? extends E> extractor, E value)Construct a LessFilter for testing "Less" condition.LikeFilter(ValueExtractor<? super T,? extends E> extractor, String sPattern)Construct a LikeFilter for pattern match.LikeFilter(ValueExtractor<? super T,? extends E> extractor, String sPattern, char chEscape, boolean fIgnoreCase)Construct a LikeFilter for pattern match.NotEqualsFilter(ValueExtractor<? super T,? extends E> extractor, E value)Construct a NotEqualsFilter for testing inequality.PredicateFilter(ValueExtractor<? super T,? extends E> extractor, Predicate<? super E> predicate)Constructs aPredicateFilter.RegexFilter(ValueExtractor<? super T,? extends E> extractor, String sRegex)Construct a RegexFilter for testing pattern matching.ValueChangeEventFilter(ValueExtractor<? super V,? extends E> extractor)Construct a ValueChangeEventFilter that evaluates MapEvent values based on the specified extractor. -
Uses of ValueExtractor in com.tangosol.util.function
Methods in com.tangosol.util.function with parameters of type ValueExtractor Modifier and Type Method Description static <T,E extends Comparable<? super E>>
Remote.Comparator<T>Remote. comparator(ValueExtractor<? super T,? extends E> extractor)CreateRemote.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 ValueExtractor Modifier and Type Field Description protected 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 ValueExtractor Modifier and Type Method Description ValueExtractor<V,R>PropertyManipulator. getExtractor()Retrieve the underlying ValueExtractor reference.Constructors in com.tangosol.util.processor with parameters of type ValueExtractor Constructor Description ExtractorProcessor(ValueExtractor<? super T,? extends E> extractor)Construct an ExtractorProcessor based on the specified ValueExtractor. -
Uses of ValueExtractor in com.tangosol.util.stream
Methods in com.tangosol.util.stream with parameters of type ValueExtractor Modifier and Type Method Description static <T,U>
RemoteCollector<T,?,Double>RemoteCollectors. averagingDouble(ValueExtractor<? super U,? extends Number> extractor)Returns 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.default <U> Optional<T>RemoteStream. max(ValueExtractor<? super U,? extends Comparable> extractor)Returns the maximum element of this stream according to the attribute extracted by the providedValueExtractor.static <T,E extends Comparable<? super E>>
RemoteCollector<T,?,Optional<T>>RemoteCollectors. maxBy(ValueExtractor<? super T,? extends E> comparable)Returns aCollectorthat produces the maximal element according to a givenComparableattribute, described as anOptional<T>.default <U> Optional<T>RemoteStream. min(ValueExtractor<? super U,? extends Comparable> extractor)Returns the minimum element of this stream according to the attribute extracted by the providedValueExtractor.static <T,E extends Comparable<? super E>>
RemoteCollector<T,?,Optional<T>>RemoteCollectors. minBy(ValueExtractor<? super T,? extends E> comparable)Returns 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,?,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. -
Uses of ValueExtractor in com.tangosol.util.transformer
Methods in com.tangosol.util.transformer that return ValueExtractor Modifier and Type Method Description ValueExtractorExtractorEventTransformer. getNewValueExtractor()Return a ValueExtractor used to transfrom the event's NewValue.ValueExtractorExtractorEventTransformer. getOldValueExtractor()Return a ValueExtractor used to transfrom the event's OldValue.Constructors in com.tangosol.util.transformer with parameters of type ValueExtractor Constructor Description ExtractorEventTransformer(ValueExtractor<? super V,? extends E> extractor)Construct a ExtractorEventTransformer that transforms MapEvent values based on the specified extractor.ExtractorEventTransformer(ValueExtractor<? super V,? extends E> extractorOld, ValueExtractor<? super V,? extends E> extractorNew)Construct a ExtractorEventTransformer that transforms MapEvent values based on the specified extractors.
-