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