/* * ProcessSumIntoTableIndexes.cc * * Created on: Mar 26, 2019 * Author: AKKA IS */ #include #include #include #include "DicError.hh" #include "AMDA_exception.hh" #include "Operation.hh" #include "ParameterManager.hh" #include "ProcessSumIntoTableIndexes.hh" #include "SumIntoTableIndexesCreator.hh" #include "ParamMgr.hh" #include "ParameterCreatorFromExpression.hh" using namespace std; using namespace boost; using namespace log4cxx; namespace AMDA { namespace Parameters { ProcessSumIntoTableIndexes::ProcessSumIntoTableIndexes(Parameter ¶meter) : SingleParamProcess_CRTP(parameter) { } ProcessSumIntoTableIndexes::ProcessSumIntoTableIndexes(const ProcessSumIntoTableIndexes& pProcess, Parameter ¶meter) : SingleParamProcess_CRTP(pProcess,parameter) { } ProcessSumIntoTableIndexes::~ProcessSumIntoTableIndexes() { } TimeStamp ProcessSumIntoTableIndexes::init() { if (_attributList.size() < 3) { BOOST_THROW_EXCEPTION(AMDA::AMDA_exception() << AMDA::errno_code(AMDA_PROCESS_ERR) << AMDA::ex_msg(std::string("ProcessSumIntoTableIndexes::init required at least 3 attributes'"))); } int relatedDim = atoi(_attributList[0].c_str()); int minIndex1 = atoi(_attributList[1].c_str()); int maxIndex1 = atoi(_attributList[2].c_str()); int minIndex2 = -1; int maxIndex2 = -1; if (_attributList.size() == 5) { minIndex2 = atoi(_attributList[3].c_str()); maxIndex2 = atoi(_attributList[4].c_str()); } TimeStamp timeStamp = _parameterInput->init( this, _timeIntervalList); _paramInput = _parameterInput->getParamData(this).get(); SumIntoTableIndexesCreator lSumIntoTableIndexesCreator(*this, *_paramInput, minIndex1, maxIndex1, relatedDim, minIndex2, maxIndex2); _operation = lSumIntoTableIndexesCreator.getOperation(); _paramData = ParamDataSPtr(_operation->getParamOutput()); _paramData->setMinSampling(_paramInput->getMinSampling()); return timeStamp; } } /* namespace Parameters */ } /* namespace AMDA */