FRAMES NO FRAMES | |||||||
| |||||||
SUMMARY: IMPORT | CONSTANT | MEMBER | ACTION | DETAIL: IMPORT | CONSTANT | MEMBER | ACTION |
Member summary | |
---|---|
integer | sessionId
The session ID of this aggregator instance; used to label all messages output from this object. |
sequence<com.apama.session.SessionInfo> | componentSources
The list of component sources making up this aggregated data feed. |
context | mainContext
The context to address "external" events to (i.e. session control events, output aggregated data events, etc.). |
com.apama.md.agg.AggregatorHelper | aggHelper
The helper event which does the aggregation. |
Action summary | |
---|---|
void |
create(context mainContext, string sessionName, sequence<com.apama.session.SessionInfo> underlyingSessions, action<dictionary<string, com.apama.session.SessionInfo>> onSuccess, action<sequence<string>> onFailure)
Creates an aggregator Session, including creating the underlying source. |
void |
requestSourceDisable(integer underlyingSessionId)
Called to request temporary removal of a source, across all symbols. |
void |
requestSourcePartialDisable(integer underlyingSessionId, sequence<string> symbols)
Called to request temporary removal of a source. |
void |
requestSourcePartialReinstate(integer underlyingSessionId, sequence<string> symbols)
Called to reinstate a previously disabled source, applied to selected symbols. If no connection was made to data on that symbol, no action will be taken. |
void |
requestSourceReinstate(integer source)
Called to reinstate a previously disabled source, applied to all symbols. If no connection was made to data on that symbol, no action will be taken. |
boolean |
temporaryBookAdjustment(integer underlyingSessionId, string underlyingSymbol, boolean isBid, float price, string uniqueId, integer quantity)
Temporarily override an individual input entry until the next update. |
boolean |
temporaryRemoveAllLiquidity(integer underlyingSessionId, string underlyingSymbol)
Temporarily remove all current aggregated entries for a source and symbol until the next update. |
Member detail |
---|
com.apama.md.agg.AggregatorHelper aggHelperThe helper event which does the aggregation.
sequence<com.apama.session.SessionInfo> componentSourcesThe list of component sources making up this aggregated data feed.
context mainContextThe context to address "external" events to (i.e. session control events, output aggregated data events, etc.).
integer sessionIdThe session ID of this aggregator instance; used to label all messages output from this object.
Action detail |
---|
void create(context mainContext, string sessionName, sequence<com.apama.session.SessionInfo> underlyingSessions, action<dictionary<string, com.apama.session.SessionInfo>> onSuccess, action<sequence<string>> onFailure)Creates an aggregator Session, including creating the underlying source.
void requestSourceDisable(integer underlyingSessionId)Called to request temporary removal of a source, across all symbols.
void requestSourcePartialDisable(integer underlyingSessionId, sequence<string> symbols)Called to request temporary removal of a source.
void requestSourcePartialReinstate(integer underlyingSessionId, sequence<string> symbols)Called to reinstate a previously disabled source, applied to selected symbols. If no connection was made to data on that symbol, no action will be taken.
void requestSourceReinstate(integer source)Called to reinstate a previously disabled source, applied to all symbols. If no connection was made to data on that symbol, no action will be taken.
boolean temporaryBookAdjustment(integer underlyingSessionId, string underlyingSymbol, boolean isBid, float price, string uniqueId, integer quantity)Temporarily override an individual input entry until the next update.
boolean temporaryRemoveAllLiquidity(integer underlyingSessionId, string underlyingSymbol)Temporarily remove all current aggregated entries for a source and symbol until the next update.
FRAMES NO FRAMES | |||||||
| |||||||
SUMMARY: IMPORT | CONSTANT | MEMBER | ACTION | DETAIL: IMPORT | CONSTANT | MEMBER | ACTION |