Method process

engine/src/execution_kernels/kernel.cpp:76–104

}

ral::execution::task_result kernel::process(std::vector<std::unique_ptr<ral::frame::BlazingTable>>  inputs,
		std::shared_ptr<ral::cache::CacheMachine> output,
		cudaStream_t stream,
    const std::map<std::string, std::string>& args){

    if(inputs.size()==0){
        return {ral::execution::task_status::SUCCESS, std::string(), std::vector< std::unique_ptr<ral::frame::BlazingTable> > ()};
    }

    size_t bytes = 0;
    size_t rows = 0;
    for(auto & input : inputs){
        bytes += input->sizeInBytes();
        rows += input->num_rows();
    }
    auto result = do_process(std::move(inputs), output, stream, args);
    if(result.status == ral::execution::SUCCESS){
         // increment these AFTER its been processed successfully
        total_input_bytes_processed += bytes;
        total_input_rows_processed += rows;
    } else {
        auto logger = spdlog::get("batch_logger");
        if (logger) {
            logger->error("|||{info}|||||",
                    "info"_a="ERROR in kernel::process trying to do do_process. Kernel name is: " + this->kernel_name() + " Kernel id is: " + std::to_string(this->kernel_id));
        }
    }
    return std::move(result);
}

void kernel::add_task(size_t task_id){
    std::lock_guard<std::mutex> lock(kernel_mutex);