MayaFlux 0.1.0
Digital-First Multimedia Processing Framework
Loading...
Searching...
No Matches

◆ 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
inputInput data wrapped in IO container
Returns
Pipeline output (data flow for chaining operations)

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

Definition at line 350 of file StatisticalAnalyzer.hpp.

351 {
352 if (input.data.empty()) {
353 throw std::runtime_error("Input is empty");
354 }
355 try {
356 auto [data_span, structure_info] = OperationHelper::extract_structured_double(
357 const_cast<input_type&>(input));
358
359 std::vector<std::span<const double>> channel_spans;
360 for (const auto& span : data_span)
361 channel_spans.emplace_back(span.data(), span.size());
362
363 std::vector<std::vector<double>> stat_values;
364 stat_values.reserve(channel_spans.size());
365 for (const auto& ch_span : channel_spans) {
366 stat_values.push_back(compute_statistical_values(ch_span, m_method));
367 }
368
369 StatisticalAnalysis analysis_result = create_analysis_result(
370 stat_values, channel_spans, structure_info);
371
372 this->store_current_analysis(analysis_result);
373 return create_pipeline_output(input, analysis_result, structure_info);
374 } catch (const std::exception& e) {
375 std::cerr << "Energy analysis failed: " << e.what() << '\n';
376 output_type error_result;
377 error_result.metadata = input.metadata;
378 error_result.metadata["error"] = std::string("Analysis failed: ") + e.what();
379 return error_result;
380 }
381 }
static std::tuple< std::vector< std::span< double > >, DataStructureInfo > extract_structured_double(T &compute_data)
Extract structured double data from IO container or direct ComputeData with automatic container handl...
StatisticalAnalysis create_analysis_result(const std::vector< std::vector< double > > &stat_values, std::vector< std::span< const double > > original_data, const auto &) const
Create comprehensive analysis result.
std::vector< double > compute_statistical_values(std::span< const double > data, StatisticalMethod method) const
Compute statistical values using span (zero-copy processing)
output_type create_pipeline_output(const input_type &input, const StatisticalAnalysis &analysis_result, DataStructureInfo &info)
Create pipeline output for operation chaining.
void store_current_analysis(AnalysisResultType &&result) const
std::unordered_map< std::string, std::any > metadata
Associated metadata.
Definition DataIO.hpp:28

References MayaFlux::Yantra::IO< T >::data, and MayaFlux::Yantra::IO< T >::metadata.