system_validator Namespace Reference

Classes
class	DistributedValidate
	Driver for running distributed validation on metadata across cluster. DistributedValidate provides functions for running a validation on system metadata across a cluster, with options to remove broken objects that have been identified. More...
class	SingleNodeValidator
	Driver for running validation on a single node. More...

Functions
bool	should_validate_epoch (const TableDescriptor *table_descriptor)
std::string	validate_table_epochs (const std::vector< Catalog_Namespace::TableEpochInfo > &table_epochs, const std::string &table_name, const bool is_cluster_validation)

Function Documentation

bool system_validator::should_validate_epoch

(

const TableDescriptor *

table_descriptor

)

Definition at line 38 of file SystemValidator.cpp.

References TableDescriptor::isForeignTable(), TableDescriptor::isTemporaryTable(), TableDescriptor::isView, and TableDescriptor::shard.

Referenced by system_validator::SingleNodeValidator::validate().

                                                                    {
  // Epoch validation only applies to persisted local tables. Validation uses the logical
  // table id to validate epoch consistency across shards.
  return (table_descriptor->shard == -1 && !table_descriptor->isForeignTable() &&
          !table_descriptor->isTemporaryTable() && !table_descriptor->isView);
}

Here is the call graph for this function:

Here is the caller graph for this function:

std::string system_validator::validate_table_epochs	(	const std::vector< Catalog_Namespace::TableEpochInfo > &	table_epochs,
		const std::string &	table_name,
		const bool	is_cluster_validation
	)

Definition at line 45 of file SystemValidator.cpp.

References CHECK, and to_string().

Referenced by system_validator::SingleNodeValidator::validate().

                                      {
  std::ostringstream validation_result;
  CHECK(!table_epochs.empty());
  bool epochs_are_inconsistent{false};
  auto first_epoch = table_epochs[0].table_epoch;
  for (const auto& table_epoch : table_epochs) {
    if (first_epoch != table_epoch.table_epoch) {
      epochs_are_inconsistent = true;
      break;
    }
  }

  if (epochs_are_inconsistent) {
    validation_result << "\nEpoch values for table \"" << table_name
                      << "\" are inconsistent:\n"
                      << std::left;
    // Only add "Node" header for cluster validation
    if (is_cluster_validation) {
      validation_result << std::setw(10) << "Node";
    }
    validation_result << std::setw(10) << "Table Id" << std::setw(10) << "Epoch"
                      << "\n========= ========= ";
    // Add separator for "Node" header if this is a cluster validation
    if (is_cluster_validation) {
      validation_result << "========= ";
    }
    for (const auto& table_epoch : table_epochs) {
      validation_result << "\n";
      // Only add leaf index for cluster validation
      if (is_cluster_validation) {
        validation_result << std::setw(10)
                          << ("Leaf " + std::to_string(table_epoch.leaf_index));
      }
      validation_result << std::setw(10) << table_epoch.table_id << std::setw(10)
                        << table_epoch.table_epoch;
    }
    validation_result << "\n";
  } else if (first_epoch < 0) {
    validation_result << "\nNegative epoch value found for table \"" << table_name
                      << "\". Epoch: " << first_epoch << ".";
  }

  return validation_result.str();
}

Here is the call graph for this function:

Here is the caller graph for this function: