foreign_storage::anonymous_namespace{LogFileBufferParser.cpp} Namespace Reference

Functions
std::string	remove_quotes (const std::string &value)
std::map< std::string, std::string >	create_map_from_arrays (const std::string &keys_array, const std::string &values_array)
std::string	get_node_name ()
void	add_column_value (std::vector< std::string > &parsed_columns_str, std::vector< std::string_view > &parsed_columns_sv, const std::string &value, size_t count=1)
void	add_nonce_values (std::vector< std::string > &parsed_columns_str, std::vector< std::string_view > &parsed_columns_sv, const std::string &nonce, int32_t table_id, int32_t db_id)

Function Documentation

void foreign_storage::anonymous_namespace{LogFileBufferParser.cpp}::add_column_value	(	std::vector< std::string > &	parsed_columns_str,
		std::vector< std::string_view > &	parsed_columns_sv,
		const std::string &	value,
		size_t	count = 1
	)

Definition at line 59 of file LogFileBufferParser.cpp.

Referenced by add_nonce_values(), and foreign_storage::LogFileBufferParser::regexMatchColumns().

                                        {
  for (size_t i = 0; i < count; i++) {
    parsed_columns_str.emplace_back(value);
    parsed_columns_sv.emplace_back(parsed_columns_str.back());
  }
}

Here is the caller graph for this function:

void foreign_storage::anonymous_namespace{LogFileBufferParser.cpp}::add_nonce_values	(	std::vector< std::string > &	parsed_columns_str,
		std::vector< std::string_view > &	parsed_columns_sv,
		const std::string &	nonce,
		int32_t	table_id,
		int32_t	db_id
	)

Definition at line 69 of file LogFileBufferParser.cpp.

References add_column_value(), CHECK, CHECK_GT, CHECK_LE, Catalog_Namespace::SysCatalog::getCatalog(), Catalog_Namespace::SysCatalog::instance(), and split().

Referenced by foreign_storage::LogFileBufferParser::regexMatchColumns().

                                     {
  // Nonce has the following format: "{dashboard id}/{chart id}-{layer id}"
  auto dashboard_and_chart_id = split(nonce, "/");
  if (dashboard_and_chart_id.size() == 2) {
    auto dashboard_id_str = dashboard_and_chart_id[0];
    int32_t dashboard_id{0};
    if (dashboard_id_str == "null" ||
        !(dashboard_id = std::atoi(dashboard_id_str.c_str()))) {
      dashboard_id_str = "";
    }
    add_column_value(parsed_columns_str, parsed_columns_sv, dashboard_id_str);

    // Get dashboard name from dashboard id.
    std::string dashboard_name;
    if (dashboard_id > 0) {
      // Get dashboard database name.
      auto info_schema_catalog =
          Catalog_Namespace::SysCatalog::instance().getCatalog(db_id);
      CHECK(info_schema_catalog);
      auto db_name_column =
          info_schema_catalog->getMetadataForColumn(table_id, "database_name");
      CHECK(db_name_column);
      CHECK_GT(db_name_column->columnId, 0);
      CHECK_LE(size_t(db_name_column->columnId), parsed_columns_str.size());
      const auto& db_name = parsed_columns_str[db_name_column->columnId - 1];

      // Get dashboard metadata.
      Catalog_Namespace::DBMetadata db_metadata;
      auto& sys_catalog = Catalog_Namespace::SysCatalog::instance();
      if (sys_catalog.getMetadataForDB(db_name, db_metadata)) {
        auto catalog = sys_catalog.getCatalog(db_metadata, false);
        auto dashboard = catalog->getMetadataForDashboard(dashboard_id);
        if (dashboard) {
          dashboard_name = dashboard->dashboardName;
        } else {
          dashboard_name = "<DELETED>";
        }
      }
      add_column_value(parsed_columns_str, parsed_columns_sv, dashboard_name);

      auto chart_and_layer_id = split(dashboard_and_chart_id[1], "-");
      add_column_value(parsed_columns_str, parsed_columns_sv, chart_and_layer_id[0]);
    } else {
      // Null dashboard name and chart id.
      add_column_value(parsed_columns_str, parsed_columns_sv, "", 2);
    }
  } else {
    // Null dashboard id, dashboard name, and chart id.
    add_column_value(parsed_columns_str, parsed_columns_sv, "", 3);
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

std::map<std::string, std::string> foreign_storage::anonymous_namespace{LogFileBufferParser.cpp}::create_map_from_arrays	(	const std::string &	keys_array,
		const std::string &	values_array
	)

Definition at line 31 of file LogFileBufferParser.cpp.

References import_export::delimited_parser::parse_string_array(), and remove_quotes().

Referenced by foreign_storage::LogFileBufferParser::regexMatchColumns().

                                   {
  std::vector<std::string> keys;
  import_export::delimited_parser::parse_string_array(keys_array, {}, keys, true);
  std::vector<std::string> values;
  import_export::delimited_parser::parse_string_array(values_array, {}, values, true);
  if (keys.size() == values.size()) {
    std::map<std::string, std::string> values_map;
    for (size_t i = 0; i < keys.size(); i++) {
      values_map[remove_quotes(keys[i])] = remove_quotes(values[i]);
    }
    return values_map;
  } else {
    return {};
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

std::string foreign_storage::anonymous_namespace{LogFileBufferParser.cpp}::get_node_name

(

)

Definition at line 49 of file LogFileBufferParser.cpp.

References g_distributed_leaf_idx, dist::is_leaf_node(), and to_string().

Referenced by foreign_storage::LogFileBufferParser::regexMatchColumns().

                          {
  std::string node_name;
  if (dist::is_leaf_node()) {
    node_name = "Leaf " + to_string(g_distributed_leaf_idx);
  } else {
    node_name = "Server";
  }
  return node_name;
}

Here is the call graph for this function:

Here is the caller graph for this function:

std::string foreign_storage::anonymous_namespace{LogFileBufferParser.cpp}::remove_quotes

(

const std::string &

value

)

Definition at line 24 of file LogFileBufferParser.cpp.

Referenced by create_map_from_arrays(), and main().

                                                {
  if (value.length() > 1 && value[0] == '"' && value[value.length() - 1] == '"') {
    return value.substr(1, value.length() - 2);
  }
  return value;
}

Here is the caller graph for this function: