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 IO container

Returns

Pipeline output (data flow for chaining operations)

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

Definition at line 301 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) {
                    throw std::runtime_error("One or more channels in input data are smaller than window size (" + std::to_string(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) {
            std::cerr << "Energy analysis failed: " << e.what() << '\n';
            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::IO< T >::metadata.