anonymous_namespace{StorageIOFacility.h} Namespace Reference

Functions
bool	is_chunk_min_max_updated (const Fragmenter_Namespace::ChunkUpdateStats &update_stats, int64_t min, int64_t max)
bool	is_chunk_min_max_updated (const Fragmenter_Namespace::ChunkUpdateStats &update_stats, double min, double max)
bool	should_recompute_metadata (const std::optional< Fragmenter_Namespace::ChunkUpdateStats > &update_stats)

Function Documentation

bool anonymous_namespace{StorageIOFacility.h}::is_chunk_min_max_updated	(	const Fragmenter_Namespace::ChunkUpdateStats &	update_stats,
		int64_t	min,
		int64_t	max
	)

Checks to see if any of the updated values match the current min/max stat for the chunk.

Definition at line 39 of file StorageIOFacility.h.

References Fragmenter_Namespace::UpdateValuesStats::max_int64t, Fragmenter_Namespace::UpdateValuesStats::min_int64t, Fragmenter_Namespace::ChunkUpdateStats::new_values_stats, and Fragmenter_Namespace::ChunkUpdateStats::old_values_stats.

Referenced by should_recompute_metadata().

                                           {
  if (update_stats.old_values_stats.min_int64t <
          update_stats.new_values_stats.min_int64t &&
      update_stats.old_values_stats.min_int64t == min) {
    return true;
  }
  if (update_stats.old_values_stats.max_int64t >
          update_stats.new_values_stats.max_int64t &&
      update_stats.old_values_stats.max_int64t == max) {
    return true;
  }
  return false;
}

Here is the caller graph for this function:

bool anonymous_namespace{StorageIOFacility.h}::is_chunk_min_max_updated	(	const Fragmenter_Namespace::ChunkUpdateStats &	update_stats,
		double	min,
		double	max
	)

Definition at line 55 of file StorageIOFacility.h.

References Fragmenter_Namespace::UpdateValuesStats::max_double, Fragmenter_Namespace::UpdateValuesStats::min_double, Fragmenter_Namespace::ChunkUpdateStats::new_values_stats, and Fragmenter_Namespace::ChunkUpdateStats::old_values_stats.

                                          {
  if (update_stats.old_values_stats.min_double <
          update_stats.new_values_stats.min_double &&
      update_stats.old_values_stats.min_double == min) {
    return true;
  }
  if (update_stats.old_values_stats.max_double >
          update_stats.new_values_stats.max_double &&
      update_stats.old_values_stats.max_double == max) {
    return true;
  }
  return false;
}

bool anonymous_namespace{StorageIOFacility.h}::should_recompute_metadata

(

const std::optional< Fragmenter_Namespace::ChunkUpdateStats > &

update_stats

)

Definition at line 71 of file StorageIOFacility.h.

References CHECK, extract_max_stat_int_type(), extract_min_stat_int_type(), g_enable_auto_metadata_update, is_chunk_min_max_updated(), kDOUBLE, kFLOAT, and UNREACHABLE.

Referenced by StorageIOFacility::yieldUpdateCallback().

                                                                           {
  if (!g_enable_auto_metadata_update || !update_stats.has_value()) {
    return false;
  }

  CHECK(update_stats->chunk);
  CHECK(update_stats->chunk->getBuffer());
  CHECK(update_stats->chunk->getBuffer()->getEncoder());

  auto chunk_metadata = std::make_shared<ChunkMetadata>();
  update_stats->chunk->getBuffer()->getEncoder()->getMetadata(chunk_metadata);
  auto cd = update_stats.value().chunk->getColumnDesc();
  if (cd->columnType.is_fp()) {
    double min, max;
    if (cd->columnType.get_type() == kDOUBLE) {
      min = chunk_metadata->chunkStats.min.doubleval;
      max = chunk_metadata->chunkStats.max.doubleval;
    } else if (cd->columnType.get_type() == kFLOAT) {
      min = chunk_metadata->chunkStats.min.floatval;
      max = chunk_metadata->chunkStats.max.floatval;
    } else {
      min = 0;  // resolve compiler warning about uninitialized variables
      max = -1;
      UNREACHABLE();
    }
    return is_chunk_min_max_updated(update_stats.value(), min, max);
  } else {
    auto min = extract_min_stat_int_type(chunk_metadata->chunkStats, cd->columnType);
    auto max = extract_max_stat_int_type(chunk_metadata->chunkStats, cd->columnType);
    return is_chunk_min_max_updated(update_stats.value(), min, max);
  }
}

Here is the call graph for this function:

Here is the caller graph for this function: