Class graph

Nested Relationships

Nested Types

Class Documentation

class ral::cache::graph

A class that represents the execution graph in a taskflow scheme. The taskflow scheme is basically implemeted by the execution graph and the kernels associated to each node in the graph.

Public Functions

inline graph()
inline ~graph()
graph(const graph&) = default
graph &operator=(const graph&) = default
int32_t get_context_token()
void set_context_token(int32_t token)
void addPair(kpair p)
void check_and_complete_work_flow()
void start_execute(const std::size_t max_kernel_run_threads)
void finish_execute()
void show()
void show_from_kernel(int32_t id)
std::pair<bool, uint64_t> get_estimated_input_rows_to_kernel(int32_t id)
std::pair<bool, uint64_t> get_estimated_input_rows_to_cache(int32_t id, const std::string &port_name)
std::shared_ptr<kernel> get_last_kernel()
bool query_is_complete()
graph_progress get_progress()
size_t num_nodes() const
size_t add_node(std::shared_ptr<kernel> k)
void add_edge(std::shared_ptr<kernel> source, std::shared_ptr<kernel> target, std::string source_port, std::string target_port, const cache_settings &config)
kernel *get_node(size_t id)
std::shared_ptr<ral::cache::CacheMachine> get_kernel_output_cache(size_t kernel_id, std::string cache_id = "")
void set_input_and_output_caches(std::shared_ptr<ral::cache::CacheMachine> input_cache, std::shared_ptr<ral::cache::CacheMachine> output_cache)
std::shared_ptr<ral::cache::CacheMachine> get_input_message_cache()
std::shared_ptr<ral::cache::CacheMachine> get_output_message_cache()
std::set<Edge> get_neighbours(kernel *from)
std::set<Edge> get_neighbours(int32_t id)
std::set<Edge> get_reverse_neighbours(kernel *from)
std::set<Edge> get_reverse_neighbours(int32_t id)
void set_kernels_order()
void check_for_simple_scan_with_limit_query()
void set_memory_monitor(std::shared_ptr<ral::MemoryMonitor> mem_monitor)
void clear_kernels()
struct Edge

Public Functions

inline bool operator<(const Edge &e) const
inline bool operator==(const Edge &e) const
inline void print() const

Public Members

std::int32_t source
std::int32_t target
std::string source_port_name
std::string target_port_name