Package | Description |
---|---|
com.tangosol.coherence.jcache.partitionedcache |
Contains classes related to partitioned cache implementation of Coherence JCache.
|
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 | 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 an 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 |
AbstractAggregator.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) |
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 Type | Method and Description |
---|---|
boolean |
AbstractAggregator.accumulate(Streamer<? extends InvocableMap.Entry<? extends K,? extends V>> streamer) |
boolean |
DistinctValues.accumulate(Streamer<? extends InvocableMap.Entry<? extends K,? extends V>> streamer) |
boolean |
Count.accumulate(Streamer<? extends InvocableMap.Entry<? extends K,? extends V>> streamer) |
boolean |
QueryRecorder.accumulate(Streamer<? extends InvocableMap.Entry<? extends K,? extends V>> streamer) |
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.
|
R |
AbstractAsynchronousAggregator.aggregate(Set<? extends InvocableMap.Entry<? extends K,? extends V>> setEntries)
Not supported.
|
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) |
R |
ScriptProcessor.process(InvocableMap.Entry<K,V> entry) |
R |
AbstractEvolvableProcessor.process(InvocableMap.Entry<K,V> entry) |
V |
ConditionalRemove.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 |
ConditionalPut.process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object.
|
T |
PriorityProcessor.process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object.
|
N |
NumberMultiplier.process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object.
|
Boolean |
UpdaterProcessor.process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object.
|
R |
AbstractAsynchronousProcessor.process(InvocableMap.Entry<K,V> entry)
Not supported.
|
V |
VersionedPut.process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object.
|
V |
ConditionalPutAll.process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object.
|
Object |
CompositeProcessor.process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object.
|
V |
PreloadRequest.process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object.
|
R |
MethodInvocationProcessor.process(InvocableMap.Entry<K,V> entry) |
E |
ExtractorProcessor.process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object.
|
T |
ConditionalProcessor.process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object if it satisfies the underlying filter.
|
N |
NumberIncrementor.process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object.
|
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,R> |
AbstractEvolvableProcessor.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> |
VersionedPutAll.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,T> |
PriorityProcessor.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> |
VersionedPut.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,V> |
PreloadRequest.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.
|
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.
|