com.apama.md.agg
Event AggregatorHelper
-
Routes:
-
com.apama.md.BBA -
-
com.apama.session.DataSourceError -
-
com.apama.md.WrappedBBA -
-
com.apama.md.WrappedX -
-
com.apama.md.WrappedXES -
-
com.apama.md.X -
-
com.apama.md.XD -
-
com.apama.md.XES -
-
com.apama.md.XESD -
-
Sends:
-
com.apama.md.BBA -
-
com.apama.md.WrappedBBA -
-
com.apama.md.WrappedX -
-
com.apama.md.WrappedXES -
-
com.apama.md.X -
-
com.apama.md.XD -
-
com.apama.md.XES -
-
com.apama.md.XESD -
-
Listens:
-
com.apama.md.BBA -
-
com.apama.md.D -
-
com.apama.md.DD -
-
com.apama.md.ES -
-
com.apama.md.ESD -
-
com.apama.md.O -
-
com.apama.md.OD -
-
com.apama.md.QB -
-
com.apama.md.QBD -
-
com.apama.md.WrappedBBA -
-
com.apama.md.WrappedD -
-
com.apama.md.WrappedES -
-
com.apama.md.WrappedO -
-
com.apama.md.WrappedQB -
-
com.apama.md.WrappedX -
-
com.apama.md.WrappedXES -
-
com.apama.md.X -
-
com.apama.md.XD -
-
com.apama.md.XES -
-
com.apama.md.XESD -
Import summary |
TimeFormatPlugin | timeMgr
|
Action summary |
void |
applyAndSendDeltaUpdateCommon(string publishSymbol, integer connectionId, com.apama.md.agg.SessionSymbolKey sessionSymbolKey, dictionary<com.apama.md.XEPKey, dictionary<string, string>> epSourceValues, dictionary<integer, float> __timestamps, com.apama.md.agg.DatastreamConverterInterface converterInterface)
|
void |
applyDeltaUpdateToSnapshotCommon(string publishSymbol, integer connectionId, com.apama.md.agg.SessionSymbolKey sessionSymbolKey, dictionary<com.apama.md.XEPKey, dictionary<string, string>> epSourceValues, dictionary<integer, float> __timestamps, com.apama.md.agg.DatastreamConverterInterface converterInterface, boolean updatePriorityIndexes, com.apama.md.XD delta)
|
void |
connectX(com.apama.md.adapter.ConnectDatastream cd, action<com.apama.md.adapter.ConnectionKey, integer, string> success)
|
string |
getPublishSymbol(string outputSymbol, integer sessionId)
|
sequence<string> |
getUnderlyingSymbol(string outputSymbol, integer sessionId)
|
void |
handleESD(com.apama.md.ESD input, string datastreamType)
|
boolean |
handleFatalErrorPerSymbol(string symbol, com.apama.md.agg.AggregatorDataCommon aggDataCommon, com.apama.session.SessionError err)
|
void |
handleXESD(com.apama.md.XESD input, string datastreamType)
|
void |
setup(integer sessionId, sequence<com.apama.session.SessionInfo> componentSources, com.apama.md.adapter.GenericSourceInterface sourceHelper, action<> setupSuccess)
Sets up Aggregator. |
void |
startSendingBBA(com.apama.md.adapter.StartSendingData ssd, action<com.apama.md.adapter.ConnectionKey, integer, string> success)
|
void |
startSendingData(com.apama.md.adapter.StartSendingData ssd, action<com.apama.md.adapter.ConnectionKey, integer, string> success)
|
void |
startSendingX(com.apama.md.adapter.StartSendingData ssd, action<com.apama.md.adapter.ConnectionKey, integer, string> success)
|
timeMgr
TimeFormatPlugin timeMgr
componentSources
sequence<com.apama.session.SessionInfo> componentSources
The list of component sources making up this aggregated data feed.
constants
com.apama.md.constants.Constants constants
dataBySymbolBBA
dictionary<string, com.apama.md.agg.AggregatorDataForBBA> dataBySymbolBBA
dataBySymbolX
dictionary<string, com.apama.md.agg.AggregatorDataForX> dataBySymbolX
Cache of data, one entry per symbol being aggregated.
depthConvertor
com.apama.md.agg.DepthConvertor depthConvertor
disabledFromSessionError
dictionary<integer, boolean> disabledFromSessionError
dsc
com.apama.md.DatastreamConstants dsc
emptyDelta
com.apama.md.XD emptyDelta
numSources
integer numSources
orderBookConvertor
com.apama.md.agg.OrderBookConvertor orderBookConvertor
params
com.apama.md.agg.AggregatorHelperParams params
quoteBookConvertor
com.apama.md.agg.QuoteBookConvertor quoteBookConvertor
sessionId
integer sessionId
The session ID of this aggregator instance; used to label all messages output from this object.
userSetupSymbolConversionTable
action<> userSetupSymbolConversionTable
xBookConvertor
com.apama.md.agg.XBookConvertor xBookConvertor
applyAndSendDeltaUpdateCommon
void applyAndSendDeltaUpdateCommon(string publishSymbol, integer connectionId, com.apama.md.agg.SessionSymbolKey sessionSymbolKey, dictionary<com.apama.md.XEPKey, dictionary<string, string>> epSourceValues, dictionary<integer, float> __timestamps, com.apama.md.agg.DatastreamConverterInterface converterInterface)
-
Parameters:
-
publishSymbol
-
connectionId
-
sessionSymbolKey
-
epSourceValues
-
__timestamps
-
converterInterface
-
Routes:
-
com.apama.md.XD -
-
Sends:
-
com.apama.md.XD -
applyDeltaUpdateToSnapshotCommon
void applyDeltaUpdateToSnapshotCommon(string publishSymbol, integer connectionId, com.apama.md.agg.SessionSymbolKey sessionSymbolKey, dictionary<com.apama.md.XEPKey, dictionary<string, string>> epSourceValues, dictionary<integer, float> __timestamps, com.apama.md.agg.DatastreamConverterInterface converterInterface, boolean updatePriorityIndexes, com.apama.md.XD delta)
-
Parameters:
-
publishSymbol
-
connectionId
-
sessionSymbolKey
-
epSourceValues
-
__timestamps
-
converterInterface
-
updatePriorityIndexes
-
delta
connectX
void connectX(com.apama.md.adapter.ConnectDatastream cd, action<com.apama.md.adapter.ConnectionKey, integer, string> success)
-
Parameters:
-
cd
-
success
getPublishSymbol
string getPublishSymbol(string outputSymbol, integer sessionId)
-
Parameters:
-
outputSymbol
-
sessionId
getUnderlyingSymbol
sequence<string> getUnderlyingSymbol(string outputSymbol, integer sessionId)
-
Parameters:
-
outputSymbol
-
sessionId
handleESD
void handleESD(com.apama.md.ESD input, string datastreamType)
-
Parameters:
-
input
-
datastreamType
-
Routes:
-
com.apama.md.XESD -
-
Sends:
-
com.apama.md.XESD -
handleFatalErrorPerSymbol
boolean handleFatalErrorPerSymbol(string symbol, com.apama.md.agg.AggregatorDataCommon aggDataCommon, com.apama.session.SessionError err)
-
Parameters:
-
symbol
-
aggDataCommon
-
err
-
Routes:
-
com.apama.session.DataSourceError -
handleXESD
void handleXESD(com.apama.md.XESD input, string datastreamType)
-
Parameters:
-
input
-
datastreamType
-
Routes:
-
com.apama.md.XESD -
-
Sends:
-
com.apama.md.XESD -
setup
void setup(integer sessionId, sequence<com.apama.session.SessionInfo> componentSources, com.apama.md.adapter.GenericSourceInterface sourceHelper, action<> setupSuccess)
Sets up Aggregator.
-
Parameters:
-
sessionId - The session ID of this aggregator instance.
-
componentSources - The underlying sources.
-
sourceHelper - The Generic source interface helper.
-
setupSuccess - The setup success callback.
startSendingBBA
void startSendingBBA(com.apama.md.adapter.StartSendingData ssd, action<com.apama.md.adapter.ConnectionKey, integer, string> success)
-
Parameters:
-
ssd
-
success
startSendingData
void startSendingData(com.apama.md.adapter.StartSendingData ssd, action<com.apama.md.adapter.ConnectionKey, integer, string> success)
-
Parameters:
-
ssd
-
success
startSendingX
void startSendingX(com.apama.md.adapter.StartSendingData ssd, action<com.apama.md.adapter.ConnectionKey, integer, string> success)
-
Parameters:
-
ssd
-
success