analyze_implementation()

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

output_type MayaFlux::Yantra::StatisticalAnalyzer< 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 354 of file StatisticalAnalyzer.hpp.

    {
        if constexpr (requires { input.data.empty(); }) {
            if (input.data.empty()) {
                error<std::runtime_error>(Journal::Component::Yantra, Journal::Context::ComputeMatrix, std::source_location::current(), "Input is empty");
            }
        } else if constexpr (std::is_same_v<InputType, Kakshya::RegionGroup>) {
            if (input.data.regions.empty()) {
                error<std::runtime_error>(Journal::Component::Yantra, Journal::Context::ComputeMatrix, std::source_location::current(), "Input is empty");
            }
        }
        try {
            auto [data_span, structure_info] = OperationHelper::extract_structured_double(
                const_cast<input_type&>(input));
 
            std::vector<std::span<const double>> channel_spans;
            for (const auto& span : data_span)
                channel_spans.emplace_back(span.data(), span.size());
 
            std::vector<std::vector<double>> stat_values;
            stat_values.reserve(channel_spans.size());
            for (const auto& ch_span : channel_spans) {
                stat_values.push_back(compute_statistical_values(ch_span, m_method));
            }
 
            StatisticalAnalysis analysis_result = create_analysis_result(
                stat_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, "Statistical 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::StatisticalAnalyzer< InputType, OutputType >::compute_statistical_values(), MayaFlux::Journal::ComputeMatrix, MayaFlux::Yantra::StatisticalAnalyzer< InputType, OutputType >::create_analysis_result(), MayaFlux::Yantra::StatisticalAnalyzer< InputType, OutputType >::create_pipeline_output(), MayaFlux::Yantra::OperationHelper::extract_structured_double(), input, MayaFlux::Yantra::StatisticalAnalyzer< InputType, OutputType >::m_method, MayaFlux::Yantra::Datum< T >::metadata, MF_ERROR, MayaFlux::Yantra::UniversalAnalyzer< InputType, OutputType >::store_current_analysis(), and MayaFlux::Journal::Yantra.

Here is the call graph for this function: