anonymous_namespace{TableOptimizer.cpp} Namespace Reference

Functions
template<typename T >
T	read_scalar_target_value (const TargetValue &tv)
bool	set_metadata_from_results (ChunkMetadata &chunk_metadata, const std::vector< TargetValue > &row, const SQLTypeInfo &ti, const bool has_nulls)
RelAlgExecutionUnit	build_ra_exe_unit (const std::shared_ptr< const InputColDescriptor > input_col_desc, const std::vector< Analyzer::Expr * > &target_exprs)
CompilationOptions	get_compilation_options (const ExecutorDeviceType &device_type)
ExecutionOptions	get_execution_options ()
std::set< ChunkKey >	get_uncached_cpu_chunk_keys (const Catalog_Namespace::Catalog &catalog, int32_t table_id, int32_t fragment_id)
void	delete_cpu_chunks (const Catalog_Namespace::Catalog &catalog, const std::set< ChunkKey > &cpu_chunks_to_delete)

Function Documentation

RelAlgExecutionUnit anonymous_namespace{TableOptimizer.cpp}::build_ra_exe_unit	(	const std::shared_ptr< const InputColDescriptor >	input_col_desc,
		const std::vector< Analyzer::Expr * > &	target_exprs
	)

Definition at line 94 of file TableOptimizer.cpp.

Referenced by TableOptimizer::getDeletedColumnStats(), and TableOptimizer::recomputeColumnMetadata().

                                                  {
  return RelAlgExecutionUnit{{input_col_desc->getScanDesc()},
                             {input_col_desc},
                             {},
                             {},
                             {},
                             {},
                             target_exprs,
                             {},
                             nullptr,
                             SortInfo(),
                             0};
}

Here is the caller graph for this function:

void anonymous_namespace{TableOptimizer.cpp}::delete_cpu_chunks	(	const Catalog_Namespace::Catalog &	catalog,
		const std::set< ChunkKey > &	cpu_chunks_to_delete
	)

Definition at line 489 of file TableOptimizer.cpp.

References Data_Namespace::CPU_LEVEL, Data_Namespace::DataMgr::deleteChunksWithPrefix(), and Catalog_Namespace::Catalog::getDataMgr().

Referenced by TableOptimizer::vacuumFragments().

                                                                     {
  auto& data_mgr = catalog.getDataMgr();
  for (const auto& chunk_key : cpu_chunks_to_delete) {
    data_mgr.deleteChunksWithPrefix(chunk_key, Data_Namespace::MemoryLevel::CPU_LEVEL);
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

CompilationOptions anonymous_namespace{TableOptimizer.cpp}::get_compilation_options ( const ExecutorDeviceType &  device_type )

inline

Definition at line 110 of file TableOptimizer.cpp.

References Default.

Referenced by TableOptimizer::getDeletedColumnStats(), and TableOptimizer::recomputeColumnMetadata().

                                                                                         {
  return CompilationOptions{device_type, false, ExecutorOptLevel::Default, false};
}

Here is the caller graph for this function:

ExecutionOptions anonymous_namespace{TableOptimizer.cpp}::get_execution_options ( )

inline

Definition at line 114 of file TableOptimizer.cpp.

Referenced by TableOptimizer::getDeletedColumnStats(), and TableOptimizer::recomputeColumnMetadata().

                                                {
  return ExecutionOptions{false,
                          false,
                          false,
                          false,
                          false,
                          false,
                          false,
                          false,
                          false,
                          0,
                          false,
                          false,
                          0,
                          false,
                          false};
}

Here is the caller graph for this function:

std::set<ChunkKey> anonymous_namespace{TableOptimizer.cpp}::get_uncached_cpu_chunk_keys	(	const Catalog_Namespace::Catalog &	catalog,
		int32_t	table_id,
		int32_t	fragment_id
	)

Definition at line 461 of file TableOptimizer.cpp.

References Data_Namespace::CPU_LEVEL, Catalog_Namespace::Catalog::getAllColumnMetadataForTable(), Catalog_Namespace::Catalog::getDatabaseId(), and Catalog_Namespace::Catalog::getDataMgr().

Referenced by TableOptimizer::vacuumFragments().

                                                                    {
  auto& data_mgr = catalog.getDataMgr();
  std::set<ChunkKey> uncached_cpu_chunk_keys;
  for (auto cd : catalog.getAllColumnMetadataForTable(table_id, false, false, true)) {
    ChunkKey chunk_key{catalog.getDatabaseId(), table_id, cd->columnId, fragment_id};
    if (cd->columnType.is_varlen_indeed()) {
      chunk_key.emplace_back(1);
      if (!data_mgr.isBufferOnDevice(
              chunk_key, Data_Namespace::MemoryLevel::CPU_LEVEL, 0)) {
        uncached_cpu_chunk_keys.emplace(chunk_key);
      }
      chunk_key.back() = 2;
      if (!data_mgr.isBufferOnDevice(
              chunk_key, Data_Namespace::MemoryLevel::CPU_LEVEL, 0)) {
        uncached_cpu_chunk_keys.emplace(chunk_key);
      }
    } else {
      if (!data_mgr.isBufferOnDevice(
              chunk_key, Data_Namespace::MemoryLevel::CPU_LEVEL, 0)) {
        uncached_cpu_chunk_keys.emplace(chunk_key);
      }
    }
  }
  return uncached_cpu_chunk_keys;
}

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename T >

T anonymous_namespace{TableOptimizer.cpp}::read_scalar_target_value

(

const TargetValue &

tv

)

Definition at line 38 of file TableOptimizer.cpp.

References CHECK.

                                                  {
  const auto stv = boost::get<ScalarTargetValue>(&tv);
  CHECK(stv);
  const auto val_ptr = boost::get<T>(stv);
  CHECK(val_ptr);
  return *val_ptr;
}

bool anonymous_namespace{TableOptimizer.cpp}::set_metadata_from_results	(	ChunkMetadata &	chunk_metadata,
		const std::vector< TargetValue > &	row,
		const SQLTypeInfo &	ti,
		const bool	has_nulls
	)

Definition at line 46 of file TableOptimizer.cpp.

References ChunkMetadata::fillChunkStats(), SQLTypeInfo::get_compression(), SQLTypeInfo::get_type(), kBIGINT, kBOOLEAN, kCHAR, kDATE, kDECIMAL, kDOUBLE, kENCODING_DICT, kFLOAT, kINT, kNUMERIC, kSMALLINT, kTEXT, kTIME, kTIMESTAMP, kTINYINT, and kVARCHAR.

Referenced by TableOptimizer::getDeletedColumnStats(), and TableOptimizer::recomputeColumnMetadata().

                                                     {
  switch (ti.get_type()) {
    case kBOOLEAN:
    case kTINYINT:
    case kSMALLINT:
    case kINT:
    case kBIGINT:
    case kNUMERIC:
    case kDECIMAL:
    case kTIME:
    case kTIMESTAMP:
    case kDATE: {
      int64_t min_val = read_scalar_target_value<int64_t>(row[0]);
      int64_t max_val = read_scalar_target_value<int64_t>(row[1]);
      chunk_metadata.fillChunkStats(min_val, max_val, has_nulls);
      break;
    }
    case kFLOAT: {
      float min_val = read_scalar_target_value<float>(row[0]);
      float max_val = read_scalar_target_value<float>(row[1]);
      chunk_metadata.fillChunkStats(min_val, max_val, has_nulls);
      break;
    }
    case kDOUBLE: {
      double min_val = read_scalar_target_value<double>(row[0]);
      double max_val = read_scalar_target_value<double>(row[1]);
      chunk_metadata.fillChunkStats(min_val, max_val, has_nulls);
      break;
    }
    case kVARCHAR:
    case kCHAR:
    case kTEXT:
      if (ti.get_compression() == kENCODING_DICT) {
        int64_t min_val = read_scalar_target_value<int64_t>(row[0]);
        int64_t max_val = read_scalar_target_value<int64_t>(row[1]);
        chunk_metadata.fillChunkStats(min_val, max_val, has_nulls);
      }
      break;
    default: {
      return false;  // skip column
    }
  }
  return true;
}

Here is the call graph for this function:

Here is the caller graph for this function: