MCPcopy Create free account
hub / github.com/BlazingDB/blazingsql / get_progress

Method get_progress

engine/src/execution_graph/graph.cpp:379–389  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

377 }
378
379 graph_progress graph::get_progress() {
380 graph_progress progress;
381 for (int i = 0; i < ordered_kernel_ids.size() - 1; i++){ // want to iterate over all the kernels except the last one which is OutputKernel
382 auto kernel_id = ordered_kernel_ids[i];
383 kernel * kernel = get_node(kernel_id);
384 progress.kernel_descriptions.push_back(std::to_string(kernel_id) + "-" + kernel->kernel_name());
385 progress.finished.push_back(kernel->output_.all_finished());
386 progress.batches_completed.push_back(kernel->output_.total_batches_added());
387 }
388 return progress;
389 }
390
391} // namespace cache
392} // namespace ral

Callers 2

getQueryProgressFunction · 0.80

Calls 4

sizeMethod · 0.80
all_finishedMethod · 0.80
total_batches_addedMethod · 0.80
kernel_nameMethod · 0.45

Tested by

no test coverage detected