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
 TimeFormatPlugintimeMgr
 
Member Summary
 com.apama.md.constants.Constantsconstants
 com.apama.md.DatastreamConstantsdsc
 com.apama.md.agg.AggregatorHelperParamsparams
 integersessionId

The session ID of this aggregator instance; used to label all messages output from this object.
 integernumSources
 sequence<com.apama.session.SessionInfo >componentSources

The list of component sources making up this aggregated data feed.
 dictionary<string, com.apama.md.agg.AggregatorDataForX >dataBySymbolX

Cache of data, one entry per symbol being aggregated.
 dictionary<string, com.apama.md.agg.AggregatorDataForBBA >dataBySymbolBBA
 dictionary<integer, boolean >disabledFromSessionError
 com.apama.md.agg.DepthConvertordepthConvertor
 com.apama.md.agg.OrderBookConvertororderBookConvertor
 com.apama.md.agg.XBookConvertorxBookConvertor
 com.apama.md.agg.QuoteBookConvertorquoteBookConvertor
 com.apama.md.XDemptyDelta
 action< >userSetupSymbolConversionTable
 
Action Summary
 voidapplyAndSendDeltaUpdateCommon(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)
 voidapplyDeltaUpdateToSnapshotCommon(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)
 voidconnectX(com.apama.md.adapter.ConnectDatastream cd, action<com.apama.md.adapter.ConnectionKey, integer, string > success)
 stringgetPublishSymbol(string outputSymbol, integer sessionId)
 sequence<string >getUnderlyingSymbol(string outputSymbol, integer sessionId)
 voidhandleESD(com.apama.md.ESD input, string datastreamType)
 booleanhandleFatalErrorPerSymbol(string symbol, com.apama.md.agg.AggregatorDataCommon aggDataCommon, com.apama.session.SessionError err)
 voidhandleXESD(com.apama.md.XESD input, string datastreamType)
 voidsetup(integer sessionId, sequence<com.apama.session.SessionInfo > componentSources, com.apama.md.adapter.GenericSourceInterface sourceHelper, action< > setupSuccess)

Sets up Aggregator.
 voidstartSendingBBA(com.apama.md.adapter.StartSendingData ssd, action<com.apama.md.adapter.ConnectionKey, integer, string > success)
 voidstartSendingData(com.apama.md.adapter.StartSendingData ssd, action<com.apama.md.adapter.ConnectionKey, integer, string > success)
 voidstartSendingX(com.apama.md.adapter.StartSendingData ssd, action<com.apama.md.adapter.ConnectionKey, integer, string > success)
 
Import Detail

timeMgr

TimeFormatPlugin timeMgr

Member Detail

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

Action Detail

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