Uses of Interface
com.tangosol.util.InvocableMap.Entry
Package
Description
Contains classes related to partitioned cache implementation of Coherence JCache.
Contains classes related to J2SE 1.4 NIO functionality.
Contains basic cluster interfaces and factories.
Contains classes providing various caching strategies.
Contains interfaces and classes related to partitioned services.
Contains classes providing basic XML related functionality.
Contains various generic utilities.
Contains concrete
InvocableMap.EntryAggregator
implementations.Contains concrete
InvocableMap.EntryProcessor
implementations.Contains classes to support functional-style operations on remote streams of elements,
such as map-reduce transformations on collections.
-
Uses of InvocableMap.Entry in com.tangosol.coherence.jcache.partitionedcache
Modifier and TypeMethodDescriptionboolean
PartitionedJCacheStatistics.PartitionedCacheStatisticsAggregator.accumulate
(InvocableMap.Entry entry) boolean
PartitionedJCacheStatistics.PartitionedCacheStatisticsClear.accumulate
(InvocableMap.Entry entry) -
Uses of InvocableMap.Entry in com.tangosol.io.nio
-
Uses of InvocableMap.Entry in com.tangosol.net
Modifier and TypeMethodDescriptionBackingMapContext.getBackingMapEntry
(Object oKey) Return an InvocableMap.Entry for the specified key (in its internal format) from the associated cache, obtaining exclusive access to that cache entry.BackingMapContext.getReadOnlyEntry
(Object oKey) Return a read-only InvocableMap.Entry for the specified key (in its internal format) from the associated cache. -
Uses of InvocableMap.Entry in com.tangosol.net.cache
Modifier and TypeClassDescriptionclass
An implementation of the BinaryEntry interface that is based on specified binary key, binary value and BackingMapManagerContext.class
A queue entry that is scheduled to come out of the front of the queue no earlier than some specific point in time.class
A Cache Entry implementation.Modifier and TypeMethodDescriptionContinuousQueryCache.ConverterAsynchronousProcessor.process
(InvocableMap.Entry entry) -
Uses of InvocableMap.Entry in com.tangosol.net.partition
Modifier and TypeClassDescriptionclass
A Cache Entry implementation. -
Uses of InvocableMap.Entry in com.tangosol.run.xml
Modifier and TypeClassDescriptionclass
An implementation of Entry that supports keeping them in a list. -
Uses of InvocableMap.Entry in com.tangosol.util
Modifier and TypeInterfaceDescriptioninterface
BinaryEntry<K,
V> Map.Entry that internally stores both key and value in a Binary format and uses an underlying Serializer to convert it to and from an Object view.static interface
MapTrigger.Entry<K,
V> A MapTrigger Entry represents a pending change to an Entry that is about to committed to the underlying Map.Modifier and TypeClassDescriptionprotected class
A Map Entry implementation that defers its value acquisition from the containing map (viaMap.get(Object)
) if the Entry is constructed with a null value.protected class
ConverterMapEventBinaryEntry provides both the Map Entry and the BinaryEntry interfaces to the information encapsulated inside the ConverterMapEvent.protected static class
BinaryEntry wrapper that routes the getValue()/getBinaryValue() calls onto getOriginalValue()/getOriginalBinaryValue().protected static class
MapTrigger.Entry wrapper that routes the getValue() call onto getOriginalValue().static class
Simple implementation of the InvocableMap.Entry interface.protected class
An Entry implementation that is augmented to allow an Entry instance to be re-used, which means that the same Entry instance can represent different map entries over time.class
SimpleMapEntry<K,
V> A map entry (key-value pair).Modifier and TypeFieldDescriptionprotected InvocableMap.Entry
InvocableMapHelper.RoutingMapTriggerEntry.m_entry
The underlying entry.Modifier and TypeMethodDescriptionstatic <K,
V> Set <InvocableMap.Entry<K, V>> InvocableMapHelper.duplicateEntrySet
(Map<K, V> map, Collection<? extends Map.Entry<K, V>> collEntries, boolean fReadOnly) Create a set ofInvocableMap.Entry
objects using the specified collection of Map.Entry objects.static <K,
V> Set <InvocableMap.Entry<K, V>> InvocableMapHelper.makeEntrySet
(Collection<? extends Map.Entry<K, V>> collEntries) Create a set of read-only SimpleEntry objects for the specified collection of Map.Entry objects.static <K,
V> Set <InvocableMap.Entry<K, V>> InvocableMapHelper.makeEntrySet
(Map<K, V> map, Collection<? extends K> collKeys, boolean fReadOnly) Create a set of SimpleEntry objects for the specified map and the key collection.default RemoteStream
<InvocableMap.Entry<K, V>> InvocableMap.stream()
Return a stream of all entries in this map.default RemoteStream
<InvocableMap.Entry<K, V>> Return a filtered stream of entries in this map.default RemoteStream
<InvocableMap.Entry<K, V>> InvocableMap.stream
(Collection<? extends K> collKeys) Return a stream of entries with the specified keys.Modifier and TypeMethodDescriptionboolean
InvocableMap.StreamingAggregator.accumulate
(InvocableMap.Entry<? extends K, ? extends V> entry) Accumulate one entry into the result.static <K,
V, R> R InvocableMapHelper.invokeLocked
(ConcurrentMap<K, V> map, InvocableMap.Entry<K, V> entry, InvocableMap.EntryProcessor<K, V, R> agent) Invoke the passed EntryProcessor against the specified Entry.InvocableMap.EntryProcessor.process
(InvocableMap.Entry<K, V> entry) Process a Map.Entry object.NullImplementation.NullEntryProcessor.process
(InvocableMap.Entry entry) Process a Map.Entry object.Modifier and TypeMethodDescriptiondefault boolean
InvocableMap.StreamingAggregator.accumulate
(Streamer<? extends InvocableMap.Entry<? extends K, ? extends V>> streamer) Accumulate multiple entries into the result.InvocableMap.EntryAggregator.aggregate
(Set<? extends InvocableMap.Entry<? extends K, ? extends V>> setEntries) Process a set of InvocableMap.Entry objects in order to produce an aggregated result.default R
InvocableMap.StreamingAggregator.aggregate
(Set<? extends InvocableMap.Entry<? extends K, ? extends V>> setEntries) static <K,
V, R> Map <K, R> InvocableMapHelper.invokeAllLocked
(ConcurrentMap<K, V> map, Set<? extends InvocableMap.Entry<K, V>> setEntries, InvocableMap.EntryProcessor<K, V, R> agent) Invoke the passed EntryProcessor against the entries specified by the passed map and entries.InvocableMap.EntryProcessor.processAll
(Set<? extends InvocableMap.Entry<K, V>> setEntries) Process a Set of InvocableMap.Entry objects. -
Uses of InvocableMap.Entry in com.tangosol.util.aggregator
Modifier and TypeMethodDescriptionboolean
AbstractAggregator.accumulate
(InvocableMap.Entry<? extends K, ? extends V> entry) boolean
CompositeAggregator.accumulate
(InvocableMap.Entry entry) boolean
Count.accumulate
(InvocableMap.Entry<? extends K, ? extends V> entry) boolean
GroupAggregator.accumulate
(InvocableMap.Entry<? extends K, ? extends V> entry) boolean
PriorityAggregator.accumulate
(InvocableMap.Entry<? extends K, ? extends V> entry) boolean
QueryRecorder.accumulate
(InvocableMap.Entry<? extends K, ? extends V> entry) boolean
ScriptAggregator.accumulate
(InvocableMap.Entry<? extends K, ? extends V> entry) boolean
TopNAggregator.accumulate
(InvocableMap.Entry<? extends K, ? extends V> entry) protected void
AbstractAggregator.processEntry
(InvocableMap.Entry<? extends K, ? extends V> entry) Incorporate one aggregatable entry into the result.void
ReducerAggregator.processEntry
(InvocableMap.Entry<? extends K, ? extends V> entry) Incorporate one aggregatable entry into the result.Modifier and TypeMethodDescriptionboolean
AbstractAggregator.accumulate
(Streamer<? extends InvocableMap.Entry<? extends K, ? extends V>> streamer) boolean
Count.accumulate
(Streamer<? extends InvocableMap.Entry<? extends K, ? extends V>> streamer) boolean
DistinctValues.accumulate
(Streamer<? extends InvocableMap.Entry<? extends K, ? extends V>> streamer) boolean
QueryRecorder.accumulate
(Streamer<? extends InvocableMap.Entry<? extends K, ? extends V>> streamer) AbstractAsynchronousAggregator.aggregate
(Set<? extends InvocableMap.Entry<? extends K, ? extends V>> setEntries) Not supported.PriorityAggregator.aggregate
(Set<? extends InvocableMap.Entry<? extends K, ? extends V>> setEntries) Process a set of InvocableMap.Entry objects in order to produce an aggregated result.QueryRecorder.aggregate
(Set<? extends InvocableMap.Entry<? extends K, ? extends V>> setEntries) Process a set of InvocableMap.Entry objects in order to produce an aggregated result. -
Uses of InvocableMap.Entry in com.tangosol.util.processor
Modifier and TypeMethodDescriptionprotected R
PropertyProcessor.get
(InvocableMap.Entry<K, V> entry) Get the property value from the passed Entry object.AbstractAsynchronousProcessor.process
(InvocableMap.Entry<K, V> entry) Not supported.AbstractEvolvableProcessor.process
(InvocableMap.Entry<K, V> entry) CompositeProcessor.process
(InvocableMap.Entry<K, V> entry) Process a Map.Entry object.ConditionalProcessor.process
(InvocableMap.Entry<K, V> entry) Process a Map.Entry object if it satisfies the underlying filter.ConditionalPut.process
(InvocableMap.Entry<K, V> entry) Process a Map.Entry object.ConditionalPutAll.process
(InvocableMap.Entry<K, V> entry) Process a Map.Entry object.ConditionalRemove.process
(InvocableMap.Entry<K, V> entry) Process a Map.Entry object.ExtractorProcessor.process
(InvocableMap.Entry<K, V> entry) Process a Map.Entry object.MethodInvocationProcessor.process
(InvocableMap.Entry<K, V> entry) NumberIncrementor.process
(InvocableMap.Entry<K, V> entry) Process a Map.Entry object.NumberMultiplier.process
(InvocableMap.Entry<K, V> entry) Process a Map.Entry object.PreloadRequest.process
(InvocableMap.Entry<K, V> entry) Process a Map.Entry object.PriorityProcessor.process
(InvocableMap.Entry<K, V> entry) Process a Map.Entry object.ScriptProcessor.process
(InvocableMap.Entry<K, V> entry) TouchProcessor.process
(InvocableMap.Entry entry) UpdaterProcessor.process
(InvocableMap.Entry<K, V> entry) Process a Map.Entry object.VersionedPut.process
(InvocableMap.Entry<K, V> entry) Process a Map.Entry object.VersionedPutAll.process
(InvocableMap.Entry<K, V> entry) Process a Map.Entry object.protected Object
VersionedPut.processEntry
(InvocableMap.Entry<K, V> entry, V oValueNew, boolean fInsert, boolean fReturn) Process the given entry.protected Object
VersionedPutAll.processEntry
(InvocableMap.Entry<K, V> entry, Map<? extends K, ? extends V> mapAll, boolean fInsert, boolean fReturn) Process the given entry.protected void
PropertyProcessor.set
(InvocableMap.Entry<K, V> entry, R oValue) Set the property value into the passed Entry object.Modifier and TypeMethodDescriptionAbstractAsynchronousProcessor.processAll
(Set<? extends InvocableMap.Entry<K, V>> setEntries) Not supported.AbstractEvolvableProcessor.processAll
(Set<? extends InvocableMap.Entry<K, V>> setEntries) Process a Set of InvocableMap.Entry objects.AbstractProcessor.processAll
(Set<? extends InvocableMap.Entry<K, V>> setEntries) Process a Set of InvocableMap.Entry objects.ConditionalProcessor.processAll
(Set<? extends InvocableMap.Entry<K, V>> setEntries) Process a Set of InvocableMap.Entry objects.ConditionalPut.processAll
(Set<? extends InvocableMap.Entry<K, V>> setEntries) Process a Set of InvocableMap.Entry objects.ConditionalPutAll.processAll
(Set<? extends InvocableMap.Entry<K, V>> setEntries) Process a Set of InvocableMap.Entry objects.ConditionalRemove.processAll
(Set<? extends InvocableMap.Entry<K, V>> setEntries) Process a Set of InvocableMap.Entry objects.PreloadRequest.processAll
(Set<? extends InvocableMap.Entry<K, V>> setEntries) Process a Set of InvocableMap.Entry objects.PriorityProcessor.processAll
(Set<? extends InvocableMap.Entry<K, V>> setEntries) Process a Set of InvocableMap.Entry objects.VersionedPut.processAll
(Set<? extends InvocableMap.Entry<K, V>> setEntries) Process a Set of InvocableMap.Entry objects.VersionedPutAll.processAll
(Set<? extends InvocableMap.Entry<K, V>> setEntries) Process a Set of InvocableMap.Entry objects. -
Uses of InvocableMap.Entry in com.tangosol.util.stream
Modifier and TypeMethodDescriptionstatic <K,
V> RemoteStream <InvocableMap.Entry<K, V>> RemoteStream.entrySet
(InvocableMap<K, V> map) Create aRemoteStream
of specified map's entries.Modifier and TypeMethodDescription<K,
V> S_OUT RemotePipeline.evaluate
(Stream<? extends InvocableMap.Entry<? extends K, ? extends V>> stream) Evaluate this pipeline against the specified stream of InvocableMap.Entry objects.