Flex  0.17.9
Namespaces | Functions
loading_config.cc File Reference
#include "flex/storages/rt_mutable_graph/loading_config.h"
#include <yaml-cpp/yaml.h>
#include <filesystem>
#include <iostream>
#include <sstream>
#include <string>
#include <tuple>
#include "flex/engines/hqps_db/core/utils/hqps_utils.h"
#include "flex/utils/exception.h"
Include dependency graph for loading_config.cc:

Namespaces

 gs
 
 gs::config_parsing
 

Functions

static bool gs::config_parsing::access_file (const std::string data_location, std::string &file_path)
 
static bool gs::config_parsing::fetch_src_dst_column_mapping (const Schema &schema, YAML::Node node, label_t label_id, const std::string &key, std::vector< std::pair< std::string, size_t >> &columns)
 
uint64_t gs::config_parsing::parse_block_size (const std::string &memorySizeStr)
 
template<typename FUNC >
static bool gs::config_parsing::parse_column_mappings (YAML::Node node, const Schema &schema, const std::string &label_name, std::vector< std::tuple< size_t, std::string, std::string >> &column_mappings, FUNC condition)
 
static void gs::config_parsing::set_default_csv_loading_config (std::unordered_map< std::string, std::string > &metadata)
 
static Status gs::config_parsing::parse_vertex_files (YAML::Node node, const Schema &schema, const std::string &scheme, const std::string &data_location, std::unordered_map< label_t, std::vector< std::string >> &files, std::unordered_map< label_t, std::vector< std::tuple< size_t, std::string, std::string >>> &vertex_mapping)
 
static Status gs::config_parsing::parse_vertices_files_schema (YAML::Node node, const Schema &schema, const std::string &scheme, const std::string &data_location, std::unordered_map< label_t, std::vector< std::string >> &files, std::unordered_map< label_t, std::vector< std::tuple< size_t, std::string, std::string >>> &column_mappings)
 
static Status gs::config_parsing::parse_edge_files (YAML::Node node, const Schema &schema, const std::string &scheme, const std::string &data_location, std::unordered_map< std::tuple< label_t, label_t, label_t >, std::vector< std::string >, boost::hash< std::tuple< label_t, label_t, label_t >>> &files, std::unordered_map< typename LoadingConfig::edge_triplet_type, std::vector< std::tuple< size_t, std::string, std::string >>, boost::hash< typename LoadingConfig::edge_triplet_type >> &edge_mapping, std::unordered_map< typename LoadingConfig::edge_triplet_type, std::pair< std::vector< std::pair< std::string, size_t >>, std::vector< std::pair< std::string, size_t >>>, boost::hash< typename LoadingConfig::edge_triplet_type >> &edge_src_dst_col)
 
static Status gs::config_parsing::parse_edges_files_schema (YAML::Node node, const Schema &schema, const std::string &scheme, const std::string &data_location, std::unordered_map< std::tuple< label_t, label_t, label_t >, std::vector< std::string >, boost::hash< std::tuple< label_t, label_t, label_t >>> &files, std::unordered_map< typename LoadingConfig::edge_triplet_type, std::vector< std::tuple< size_t, std::string, std::string >>, boost::hash< typename LoadingConfig::edge_triplet_type >> &edge_mapping, std::unordered_map< std::tuple< label_t, label_t, label_t >, std::pair< std::vector< std::pair< std::string, size_t >>, std::vector< std::pair< std::string, size_t >>>, boost::hash< typename LoadingConfig::edge_triplet_type >> &edge_src_dst_col)
 
Status gs::config_parsing::parse_bulk_load_config_file (const std::string &config_file, const Schema &schema, LoadingConfig &load_config)
 
Status gs::config_parsing::parse_bulk_load_method (const YAML::Node &node, BulkLoadMethod &method)
 
Status gs::config_parsing::parse_bulk_load_config_yaml (const YAML::Node &root, const Schema &schema, LoadingConfig &load_config)