| Package | Description | 
|---|---|
| com.tangosol.coherence.jcache.partitionedcache | 
 Contains classes related to partitioned cache implementation of Coherence JCache. 
 | 
| com.tangosol.coherence.servlet | 
 Contains classes related to the HTTP Session Replication Module. 
 | 
| com.tangosol.io.nio | 
 Contains classes related to J2SE 1.4 NIO functionality. 
 | 
| com.tangosol.net | 
 Contains basic cluster interfaces and factories. 
 | 
| com.tangosol.net.cache | 
 Contains classes providing various caching strategies. 
 | 
| com.tangosol.net.partition | 
 Contains interfaces and classes related to partitioned services. 
 | 
| com.tangosol.run.xml | 
 Contains classes providing basic XML related functionality. 
 | 
| com.tangosol.util | 
 Contains various generic utilities. 
 | 
| com.tangosol.util.aggregator | 
 Contains concrete  
InvocableMap.EntryAggregator
implementations. | 
| 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. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
boolean | 
PartitionedJCacheStatistics.PartitionedCacheStatisticsAggregator.accumulate(InvocableMap.Entry entry)  | 
boolean | 
PartitionedJCacheStatistics.PartitionedCacheStatisticsClear.accumulate(InvocableMap.Entry entry)  | 
| Modifier and Type | Method and Description | 
|---|---|
Integer | 
GetElasticMaxValueSizeProcessor.process(InvocableMap.Entry entry)  | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
BinaryMap.Entry
A map entry (key-value pair). 
 | 
| Modifier and Type | Method and Description | 
|---|---|
InvocableMap.Entry | 
BackingMapContext.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. 
 | 
InvocableMap.Entry | 
BackingMapContext.getReadOnlyEntry(Object oKey)
Return a read-only InvocableMap.Entry for the specified key (in its internal
 format) from the associated cache. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
BackingMapBinaryEntry
An implementation of the BinaryEntry interface that is based on specified
 binary key, binary value and BackingMapManagerContext. 
 | 
class  | 
ReadWriteBackingMap.Entry
A queue entry that is scheduled to come out of the front of the
 queue no earlier than some specific point in time. 
 | 
class  | 
SerializationCache.EntrySet.Entry
A Cache Entry implementation. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Object | 
ContinuousQueryCache.ConverterAsynchronousProcessor.process(InvocableMap.Entry entry)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ObservableSplittingBackingCache.EntrySet.Entry
A Cache Entry implementation. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
SimpleElement.AttributeMap.Entry
An implementation of Entry that supports keeping them in a list. 
 | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
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 Type | Class and Description | 
|---|---|
protected class  | 
AbstractKeyBasedMap.EntrySet.Entry
A Map Entry implementation that defers its value acquisition from
 the containing map (via  
Map.get(Object)) if the Entry is
 constructed with a null value. | 
protected class  | 
ConverterCollections.ConverterMapEvent.ConverterMapEventBinaryEntry
ConverterMapEventBinaryEntry provides both the Map Entry and the
 BinaryEntry interfaces to the information encapsulated inside the
 ConverterMapEvent. 
 | 
protected static class  | 
InvocableMapHelper.RoutingBinaryEntry
BinaryEntry wrapper that routes the getValue()/getBinaryValue()
 calls onto getOriginalValue()/getOriginalBinaryValue(). 
 | 
protected static class  | 
InvocableMapHelper.RoutingMapTriggerEntry
MapTrigger.Entry wrapper that routes the getValue() call onto
 getOriginalValue(). 
 | 
static class  | 
InvocableMapHelper.SimpleEntry<K,V>
Simple implementation of the InvocableMap.Entry interface. 
 | 
protected class  | 
OpenHashMap.EntrySet.Entry
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 Type | Field and Description | 
|---|---|
protected InvocableMap.Entry | 
InvocableMapHelper.RoutingMapTriggerEntry.m_entry
The underlying entry. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static <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 of  
InvocableMap.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>> | 
InvocableMap.stream(Collection<? extends K> collKeys)
Return a stream of entries with the specified keys. 
 | 
default RemoteStream<InvocableMap.Entry<K,V>> | 
InvocableMap.stream(Filter filter)
Return a filtered stream of entries in this map. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
boolean | 
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. 
 | 
Object | 
NullImplementation.NullEntryProcessor.process(InvocableMap.Entry entry)
Process a Map.Entry object. 
 | 
R | 
InvocableMap.EntryProcessor.process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
default boolean | 
InvocableMap.StreamingAggregator.accumulate(Streamer<? extends InvocableMap.Entry<? extends K,? extends V>> streamer)
Accumulate multiple entries into the result. 
 | 
R | 
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. 
 | 
default Map<K,R> | 
InvocableMap.EntryProcessor.processAll(Set<? extends InvocableMap.Entry<K,V>> setEntries)
Process a Set of InvocableMap.Entry objects. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
boolean | 
CompositeAggregator.accumulate(InvocableMap.Entry entry)  | 
boolean | 
ScriptAggregator.accumulate(InvocableMap.Entry<? extends K,? extends V> entry)  | 
boolean | 
PriorityAggregator.accumulate(InvocableMap.Entry<? extends K,? extends V> entry)  | 
boolean | 
TopNAggregator.accumulate(InvocableMap.Entry<? extends K,? extends V> entry)  | 
boolean | 
GroupAggregator.accumulate(InvocableMap.Entry<? extends K,? extends V> entry)  | 
boolean | 
Count.accumulate(InvocableMap.Entry<? extends K,? extends V> entry)  | 
boolean | 
QueryRecorder.accumulate(InvocableMap.Entry<? extends K,? extends V> entry)  | 
boolean | 
AbstractAggregator.accumulate(InvocableMap.Entry<? extends K,? extends V> entry)  | 
void | 
ReducerAggregator.processEntry(InvocableMap.Entry<? extends K,? extends V> entry)
Incorporate one aggregatable entry into the result. 
 | 
protected void | 
AbstractAggregator.processEntry(InvocableMap.Entry<? extends K,? extends V> entry)
Incorporate one aggregatable entry into the result. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
boolean | 
Count.accumulate(Streamer<? extends InvocableMap.Entry<? extends K,? extends V>> streamer)  | 
boolean | 
QueryRecorder.accumulate(Streamer<? extends InvocableMap.Entry<? extends K,? extends V>> streamer)  | 
boolean | 
AbstractAggregator.accumulate(Streamer<? extends InvocableMap.Entry<? extends K,? extends V>> streamer)  | 
boolean | 
DistinctValues.accumulate(Streamer<? extends InvocableMap.Entry<? extends K,? extends V>> streamer)  | 
R | 
AbstractAsynchronousAggregator.aggregate(Set<? extends InvocableMap.Entry<? extends K,? extends V>> setEntries)
Not supported. 
 | 
R | 
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. 
 | 
QueryRecord | 
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. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected R | 
PropertyProcessor.get(InvocableMap.Entry<K,V> entry)
Get the property value from the passed Entry object. 
 | 
Object | 
TouchProcessor.process(InvocableMap.Entry entry)  | 
V | 
ConditionalPutAll.process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object. 
 | 
N | 
NumberIncrementor.process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object. 
 | 
Object | 
CompositeProcessor.process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object. 
 | 
R | 
MethodInvocationProcessor.process(InvocableMap.Entry<K,V> entry)  | 
T | 
ConditionalProcessor.process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object if it satisfies the underlying filter. 
 | 
V | 
ConditionalPut.process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object. 
 | 
V | 
VersionedPutAll.process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object. 
 | 
V | 
ConditionalRemove.process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object. 
 | 
V | 
VersionedPut.process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object. 
 | 
R | 
AbstractAsynchronousProcessor.process(InvocableMap.Entry<K,V> entry)
Not supported. 
 | 
N | 
NumberMultiplier.process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object. 
 | 
E | 
ExtractorProcessor.process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object. 
 | 
Boolean | 
UpdaterProcessor.process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object. 
 | 
V | 
PreloadRequest.process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object. 
 | 
T | 
PriorityProcessor.process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object. 
 | 
R | 
AbstractEvolvableProcessor.process(InvocableMap.Entry<K,V> entry)  | 
R | 
ScriptProcessor.process(InvocableMap.Entry<K,V> 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 Object | 
VersionedPut.processEntry(InvocableMap.Entry<K,V> entry,
            V oValueNew,
            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 Type | Method and Description | 
|---|---|
Map<K,R> | 
AbstractProcessor.processAll(Set<? extends InvocableMap.Entry<K,V>> setEntries)
Process a Set of InvocableMap.Entry objects. 
 | 
Map<K,V> | 
ConditionalPutAll.processAll(Set<? extends InvocableMap.Entry<K,V>> setEntries)
Process a Set of InvocableMap.Entry objects. 
 | 
Map<K,T> | 
ConditionalProcessor.processAll(Set<? extends InvocableMap.Entry<K,V>> setEntries)
Process a Set of InvocableMap.Entry objects. 
 | 
Map<K,V> | 
ConditionalPut.processAll(Set<? extends InvocableMap.Entry<K,V>> setEntries)
Process a Set of InvocableMap.Entry objects. 
 | 
Map<K,V> | 
VersionedPutAll.processAll(Set<? extends InvocableMap.Entry<K,V>> setEntries)
Process a Set of InvocableMap.Entry objects. 
 | 
Map<K,V> | 
ConditionalRemove.processAll(Set<? extends InvocableMap.Entry<K,V>> setEntries)
Process a Set of InvocableMap.Entry objects. 
 | 
Map<K,V> | 
VersionedPut.processAll(Set<? extends InvocableMap.Entry<K,V>> setEntries)
Process a Set of InvocableMap.Entry objects. 
 | 
Map<K,R> | 
AbstractAsynchronousProcessor.processAll(Set<? extends InvocableMap.Entry<K,V>> setEntries)
Not supported. 
 | 
Map<K,V> | 
PreloadRequest.processAll(Set<? extends InvocableMap.Entry<K,V>> setEntries)
Process a Set of InvocableMap.Entry objects. 
 | 
Map<K,T> | 
PriorityProcessor.processAll(Set<? extends InvocableMap.Entry<K,V>> setEntries)
Process a Set of InvocableMap.Entry objects. 
 | 
Map<K,R> | 
AbstractEvolvableProcessor.processAll(Set<? extends InvocableMap.Entry<K,V>> setEntries)
Process a Set of InvocableMap.Entry objects. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
<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. 
 |