merge_chunks_to_result()

template<ComputeData InputType = Kakshya::DataVariant, ComputeData OutputType = InputType>

output_type MayaFlux::Yantra::StandardSorter< InputType, OutputType >::merge_chunks_to_result ( const std::vector< InputType > &  chunks, const input_type &  original_input, DataStructureInfo  info  )

inlineprivate

Merge chunks back to single result.

Definition at line 299 of file StandardSorter.hpp.

    {
        output_type result {};
        result.metadata = original_input.metadata;
        result.metadata["sort_type"] = "chunked_merged";
 
        if constexpr (std::same_as<InputType, OutputType>) {
            if (chunks.empty()) {
                return result;
            }
 
            try {
                std::vector<std::vector<double>> merged_channels;
 
                for (const auto& chunk : chunks) {
                    auto chunk_channels = OperationHelper::extract_numeric_data(chunk);
 
                    if (merged_channels.empty()) {
                        merged_channels.resize(chunk_channels.size());
                    }
 
                    for (size_t ch = 0; ch < chunk_channels.size() && ch < merged_channels.size(); ++ch) {
                        merged_channels[ch].insert(merged_channels[ch].end(),
                            chunk_channels[ch].begin(), chunk_channels[ch].end());
                    }
                }
 
                result = this->convert_result(merged_channels, info);
                result.metadata = original_input.metadata;
                result.metadata["sort_type"] = "chunked_merged";
 
            } catch (...) {
                result.data = chunks[0];
            }
        }
 
        return result;
    }