analyze_implementation()

template<ComputeData InputType = std::vector<Kakshya::DataVariant>, ComputeData OutputType = Eigen::VectorXd>

output_type MayaFlux::Yantra::EnergyAnalyzer< InputType, OutputType >::analyze_implementation ( const input_type &  input )

inlineoverrideprotectedvirtual

Core analysis implementation - creates analysis result AND pipeline output.

Parameters

input

Input data wrapped in Datum container

Returns

Pipeline output (data flow for chaining operations)

Implements MayaFlux::Yantra::UniversalAnalyzer< InputType, OutputType >.

Definition at line 308 of file EnergyAnalyzer.hpp.

    {
        try {
            auto [data_span, structure_info] = OperationHelper::extract_structured_double(
                const_cast<input_type&>(input));
 
            std::vector<std::span<const double>> channel_spans;
            for (auto& span : data_span)
                channel_spans.emplace_back(span.data(), span.size());
 
            for (const auto& channel_span : channel_spans) {
                if (channel_span.size() < m_window_size) {
                    error<std::runtime_error>(Journal::Component::Yantra, Journal::Context::ComputeMatrix, std::source_location::current(), "One or more channels in input data are smaller than window size ({} samples)", m_window_size);
                }
            }
 
            std::vector<std::vector<double>> energy_values;
            energy_values.reserve(channel_spans.size());
            for (const auto& channel_span : channel_spans) {
                energy_values.push_back(compute_energy_values(channel_span, m_method));
            }
 
            EnergyAnalysis analysis_result = create_analysis_result(
                energy_values, channel_spans, structure_info);
 
            this->store_current_analysis(analysis_result);
 
            return create_pipeline_output(input, analysis_result, structure_info);
        } catch (const std::exception& e) {
            MF_ERROR(Journal::Component::Yantra, Journal::Context::ComputeMatrix, "Energy analysis failed: {}", e.what());
            output_type error_result;
            error_result.metadata = input.metadata;
            error_result.metadata["error"] = std::string("Analysis failed: ") + e.what();
            return error_result;
        }
    }

References MayaFlux::Yantra::Datum< T >::metadata, and MF_ERROR.