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.SessionInfocomponentSources
        
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.AggregatorDataForBBAdataBySymbolBBA
        

dataBySymbolX

            dictionary<string, com.apama.md.agg.AggregatorDataForXdataBySymbolX
        
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