Package | Description |
---|---|
com.tangosol.net.cache |
Contains classes providing various caching strategies.
|
com.tangosol.net.topic | |
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. |
Modifier and Type | Class and Description |
---|---|
protected class |
ContinuousQueryCache.ConverterAsynchronousProcessor
Wraps an
AsynchronousProcessor to ensure the result of the EntryProcessor
execution is deserialized prior to passing to the provided AsynchronousProcessor. |
Modifier and Type | Method and Description |
---|---|
void |
ContinuousQueryCache.ConverterAsynchronousProcessor.bind(FlowControl control) |
Modifier and Type | Method and Description |
---|---|
FlowControl |
Subscriber.getFlowControl()
Return the
FlowControl object governing this subscriber. |
FlowControl |
Publisher.getFlowControl()
Return the
FlowControl object governing this publisher. |
Modifier and Type | Class and Description |
---|---|
class |
AsynchronousAgent<T>
Base class for asynchronous operations that provides a simple implementation
of the
Future interface. |
Modifier and Type | Field and Description |
---|---|
protected FlowControl |
AsynchronousAgent.m_control
The underlying FlowControl; could be null if the "automatic flow control"
is turned on.
|
Modifier and Type | Method and Description |
---|---|
void |
AsynchronousAgent.bind(FlowControl control)
Bind this agent with the specified underlying FlowControl object.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractAsynchronousAggregator<K,V,P,R>
Abstract base class for asynchronous entry aggregators.
|
class |
AsynchronousAggregator<K,V,P,R>
A marker
EntryAggregator wrapper class that allows for
an asynchronous invocation of the underlying aggregator. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractAsynchronousProcessor<K,V,R,T>
Abstract base class for asynchronous entry processors.
|
class |
AsynchronousProcessor<K,V,R>
An
EntryProcessor wrapper class that allows for
an asynchronous invocation of the underlying processor. |
class |
SingleEntryAsynchronousProcessor<K,V,R>
An
EntryProcessor wrapper class that allows for
an asynchronous invocation of the underlying processor against a single
cache entry. |
class |
StreamingAsynchronousProcessor<K,V,R>
An
EntryProcessor wrapper class that allows for
an asynchronous invocation of the underlying processor. |