_ageDimension | CBMAggregatorLibPQXXWriter | private |
_classifierNames | CBMAggregatorLibPQXXWriter | private |
_connectionString | CBMAggregatorLibPQXXWriter | private |
_disturbanceDimension | CBMAggregatorLibPQXXWriter | private |
_dropSchema | CBMAggregatorLibPQXXWriter | private |
_errorDimension | CBMAggregatorLibPQXXWriter | private |
_fluxDimension | CBMAggregatorLibPQXXWriter | private |
_isPrimaryAggregator | CBMAggregatorLibPQXXWriter | private |
_jobId | CBMAggregatorLibPQXXWriter | private |
_poolDimension | CBMAggregatorLibPQXXWriter | private |
_schema | CBMAggregatorLibPQXXWriter | private |
_spatialLocationInfo | CBMAggregatorLibPQXXWriter | private |
CBMAggregatorLibPQXXWriter(std::shared_ptr< flint::RecordAccumulatorWithMutex2< std::string, FlatFluxRecord >> fluxDimension, std::shared_ptr< flint::RecordAccumulatorWithMutex2< std::string, FlatPoolRecord >> poolDimension, std::shared_ptr< flint::RecordAccumulatorWithMutex2< std::string, FlatErrorRecord >> errorDimension, std::shared_ptr< flint::RecordAccumulatorWithMutex2< std::string, FlatAgeAreaRecord >> ageDimension, std::shared_ptr< flint::RecordAccumulatorWithMutex2< std::string, FlatDisturbanceRecord >> disturbanceDimension, std::shared_ptr< std::vector< std::string >> classifierNames, bool isPrimary=false) | CBMAggregatorLibPQXXWriter | |
configure(const DynamicObject &config) override | CBMAggregatorLibPQXXWriter | |
doDisturbanceEvent(DynamicVar) | CBMModuleBase | virtual |
doError(std::string msg) | CBMModuleBase | virtual |
doIsolated(pqxx::connection_base &conn, std::string sql, bool optional=false) | CBMAggregatorLibPQXXWriter | private |
doIsolated(pqxx::connection_base &conn, std::vector< std::string > sql, bool optional=false) | CBMAggregatorLibPQXXWriter | private |
doLocalDomainInit() override | CBMAggregatorLibPQXXWriter | virtual |
doLocalDomainProcessingUnitInit() | CBMModuleBase | virtual |
doLocalDomainProcessingUnitShutdown() | CBMModuleBase | virtual |
doLocalDomainShutdown() | CBMModuleBase | virtual |
doOutputStep() | CBMModuleBase | virtual |
doPostDisturbanceEvent() | CBMModuleBase | virtual |
doPostDisturbanceEvent2() | CBMModuleBase | virtual |
doPostNotification(short preMessageSignal) | CBMModuleBase | virtual |
doPrePostDisturbanceEvent() | CBMModuleBase | virtual |
doPreTimingSequence() | CBMModuleBase | virtual |
doSystemInit() override | CBMAggregatorLibPQXXWriter | virtual |
doSystemShutdown() override | CBMAggregatorLibPQXXWriter | virtual |
doTimingEndStep() | CBMModuleBase | virtual |
doTimingInit() | CBMModuleBase | virtual |
doTimingPostInit() | CBMModuleBase | virtual |
doTimingPostInit2() | CBMModuleBase | virtual |
doTimingPostStep() | CBMModuleBase | virtual |
doTimingPreEndStep() | CBMModuleBase | virtual |
doTimingPrePostInit() | CBMModuleBase | virtual |
doTimingShutdown() | CBMModuleBase | virtual |
doTimingStep() | CBMModuleBase | virtual |
doWithHandling(const std::function< void()> &fn) | CBMModuleBase | private |
load(pqxx::work &tx, Int64 jobId, const std::string &table, std::shared_ptr< TAccumulator > dataDimension) | CBMAggregatorLibPQXXWriter | private |
moduleType() override | CBMAggregatorLibPQXXWriter | |
onDisturbanceEvent(DynamicVar e) override | CBMModuleBase | |
onError(std::string msg) override | CBMModuleBase | |
onLocalDomainInit() override | CBMModuleBase | |
onLocalDomainProcessingUnitInit() override | CBMModuleBase | |
onLocalDomainProcessingUnitShutdown() override | CBMModuleBase | |
onLocalDomainShutdown() override | CBMModuleBase | |
onOutputStep() override | CBMModuleBase | |
onPostDisturbanceEvent() override | CBMModuleBase | |
onPostDisturbanceEvent2() override | CBMModuleBase | |
onPostNotification(short preMessageSignal) override | CBMModuleBase | |
onPrePostDisturbanceEvent() override | CBMModuleBase | |
onPreTimingSequence() override | CBMModuleBase | |
onSystemInit() override | CBMModuleBase | |
onSystemShutdown() override | CBMModuleBase | |
onTimingEndStep() override | CBMModuleBase | |
onTimingInit() override | CBMModuleBase | |
onTimingPostInit() override | CBMModuleBase | |
onTimingPostInit2() override | CBMModuleBase | |
onTimingPostStep() override | CBMModuleBase | |
onTimingPreEndStep() override | CBMModuleBase | |
onTimingPrePostInit() override | CBMModuleBase | |
onTimingShutdown() override | CBMModuleBase | |
onTimingStep() override | CBMModuleBase | |
raiseModuleError(moja::Exception &e) | CBMModuleBase | private |
raiseModuleError(boost::exception &e) | CBMModuleBase | private |
raiseModuleError(std::exception &e) | CBMModuleBase | private |
subscribe(NotificationCenter ¬ificationCenter) override | CBMAggregatorLibPQXXWriter | |
~CBMAggregatorLibPQXXWriter()=default | CBMAggregatorLibPQXXWriter | virtual |
~CBMModuleBase()=default | CBMModuleBase | virtual |