_ageAreaDimension | CBMAggregatorPostgreSQLWriter | private |
_ageClassDimension | CBMAggregatorPostgreSQLWriter | private |
_classifierNames | CBMAggregatorPostgreSQLWriter | private |
_classifierSetDimension | CBMAggregatorPostgreSQLWriter | private |
_connectionString | CBMAggregatorPostgreSQLWriter | private |
_dateDimension | CBMAggregatorPostgreSQLWriter | private |
_disturbanceDimension | CBMAggregatorPostgreSQLWriter | private |
_disturbanceTypeDimension | CBMAggregatorPostgreSQLWriter | private |
_dropSchema | CBMAggregatorPostgreSQLWriter | private |
_errorDimension | CBMAggregatorPostgreSQLWriter | private |
_fluxDimension | CBMAggregatorPostgreSQLWriter | private |
_isPrimaryAggregator | CBMAggregatorPostgreSQLWriter | private |
_jobId | CBMAggregatorPostgreSQLWriter | private |
_landClassDimension | CBMAggregatorPostgreSQLWriter | private |
_locationDimension | CBMAggregatorPostgreSQLWriter | private |
_locationErrorDimension | CBMAggregatorPostgreSQLWriter | private |
_moduleInfoDimension | CBMAggregatorPostgreSQLWriter | private |
_poolDimension | CBMAggregatorPostgreSQLWriter | private |
_poolInfoDimension | CBMAggregatorPostgreSQLWriter | private |
_schema | CBMAggregatorPostgreSQLWriter | private |
_schemaLock | CBMAggregatorPostgreSQLWriter | private |
_spatialLocationInfo | CBMAggregatorPostgreSQLWriter | private |
CBMAggregatorPostgreSQLWriter(std::shared_ptr< flint::RecordAccumulatorWithMutex2< DateRow, DateRecord >> dateDimension, std::shared_ptr< flint::RecordAccumulatorWithMutex2< PoolInfoRow, PoolInfoRecord >> poolInfoDimension, std::shared_ptr< flint::RecordAccumulatorWithMutex2< ClassifierSetRow, ClassifierSetRecord >> classifierSetDimension, std::shared_ptr< flint::RecordAccumulatorWithMutex2< LandClassRow, LandClassRecord >> landClassDimension, std::shared_ptr< flint::RecordAccumulatorWithMutex2< TemporalLocationRow, TemporalLocationRecord >> locationDimension, std::shared_ptr< flint::RecordAccumulatorWithMutex2< ModuleInfoRow, ModuleInfoRecord >> moduleInfoDimension, std::shared_ptr< flint::RecordAccumulatorWithMutex2< DisturbanceTypeRow, DisturbanceTypeRecord >> disturbanceTypeDimension, std::shared_ptr< flint::RecordAccumulatorWithMutex2< DisturbanceRow, DisturbanceRecord >> disturbanceDimension, std::shared_ptr< std::vector< std::string >> classifierNames, std::shared_ptr< flint::RecordAccumulatorWithMutex2< PoolRow, PoolRecord >> poolDimension, std::shared_ptr< flint::RecordAccumulatorWithMutex2< FluxRow, FluxRecord >> fluxDimension, std::shared_ptr< flint::RecordAccumulatorWithMutex2< AgeClassRow, AgeClassRecord >> ageClassDimension, std::shared_ptr< flint::RecordAccumulatorWithMutex2< AgeAreaRow, AgeAreaRecord >> ageAreaDimension, std::shared_ptr< flint::RecordAccumulatorWithMutex2< ErrorRow, ErrorRecord >> errorDimension, std::shared_ptr< flint::RecordAccumulatorWithMutex2< LocationErrorRow, LocationErrorRecord >> locationErrorDimension, bool isPrimary=false) | CBMAggregatorPostgreSQLWriter | |
configure(const DynamicObject &config) override | CBMAggregatorPostgreSQLWriter | |
doDisturbanceEvent(DynamicVar) | CBMModuleBase | virtual |
doError(std::string msg) | CBMModuleBase | virtual |
doLocalDomainInit() | CBMModuleBase | 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 | CBMAggregatorPostgreSQLWriter | virtual |
doSystemShutdown() override | CBMAggregatorPostgreSQLWriter | 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(Poco::Data::Session &session, Int64 jobId, const std::string &table, std::shared_ptr< TAccumulator > dataDimension) | CBMAggregatorPostgreSQLWriter | private |
moduleType() override | CBMAggregatorPostgreSQLWriter | |
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 | CBMAggregatorPostgreSQLWriter | |
tryExecute(Poco::Data::Session &session, std::function< void(Poco::Data::Session &)> fn) | CBMAggregatorPostgreSQLWriter | privatestatic |
~CBMAggregatorPostgreSQLWriter()=default | CBMAggregatorPostgreSQLWriter | virtual |
~CBMModuleBase()=default | CBMModuleBase | virtual |