ResultSetRecyclerHolder Class Reference

#include <ResultSetRecyclerHolder.h>

Public Member Functions
const ResultSetPtr	getCachedQueryResultSet (const size_t key)
std::optional< std::vector < TargetMetaInfo > >	getOutputMetaInfo (QueryPlanHash key)
bool	hasCachedQueryResultSet (const size_t key)
void	putQueryResultSetToCache (const size_t key, const std::unordered_set< size_t > &input_table_keys, const ResultSetPtr query_result, size_t resultset_size, std::vector< std::shared_ptr< Analyzer::Expr >> &target_exprs)
std::optional< ChunkMetadataMap >	getCachedChunkMetadata (const size_t key)
void	putChunkMetadataToCache (const size_t key, const std::unordered_set< size_t > &input_table_keys, const ChunkMetadataMap &chunk_metadata)
std::vector< std::shared_ptr < Analyzer::Expr > > &	getTargetExprs (QueryPlanHash key) const

Static Public Member Functions
static auto	invalidateCache ()
static auto	markCachedItemAsDirty (size_t table_key)
static ResultSetRecycler *	getResultSetRecycler ()
static ChunkMetadataRecycler *	getChunkMetadataRecycler ()

Static Private Attributes
static std::unique_ptr < ResultSetRecycler >	query_resultset_cache_
static std::unique_ptr < ChunkMetadataRecycler >	chunk_metadata_cache_

Detailed Description

Definition at line 22 of file ResultSetRecyclerHolder.h.

Member Function Documentation

std::optional< ChunkMetadataMap > ResultSetRecyclerHolder::getCachedChunkMetadata

(

const size_t

key

)

Definition at line 59 of file ResultSetRecyclerHolder.cpp.

References CHUNK_METADATA, chunk_metadata_cache_, and CHUNK_METADATA_CACHE_DEVICE_IDENTIFIER.

                      {
  return chunk_metadata_cache_->getItemFromCache(
      key, CacheItemType::CHUNK_METADATA, CHUNK_METADATA_CACHE_DEVICE_IDENTIFIER);
}

const ResultSetPtr ResultSetRecyclerHolder::getCachedQueryResultSet

(

const size_t

key

)

Definition at line 30 of file ResultSetRecyclerHolder.cpp.

References DataRecyclerUtil::CPU_DEVICE_IDENTIFIER, QUERY_RESULTSET, and query_resultset_cache_.

                                                                                    {
  return query_resultset_cache_->getItemFromCache(key,
                                                  CacheItemType::QUERY_RESULTSET,
                                                  DataRecyclerUtil::CPU_DEVICE_IDENTIFIER,
                                                  std::nullopt);
}

static ChunkMetadataRecycler* ResultSetRecyclerHolder::getChunkMetadataRecycler ( )

inlinestatic

Definition at line 59 of file ResultSetRecyclerHolder.h.

References chunk_metadata_cache_.

                                                           {
    return chunk_metadata_cache_.get();
  }

std::optional< std::vector< TargetMetaInfo > > ResultSetRecyclerHolder::getOutputMetaInfo

(

QueryPlanHash

key

)

Definition at line 37 of file ResultSetRecyclerHolder.cpp.

References query_resultset_cache_.

                       {
  return query_resultset_cache_->getOutputMetaInfo(key);
}

static ResultSetRecycler* ResultSetRecyclerHolder::getResultSetRecycler ( )

inlinestatic

Definition at line 55 of file ResultSetRecyclerHolder.h.

References query_resultset_cache_.

                                                   {
    return query_resultset_cache_.get();
  }

std::vector< std::shared_ptr< Analyzer::Expr > > & ResultSetRecyclerHolder::getTargetExprs

(

QueryPlanHash

key

)

const

Definition at line 81 of file ResultSetRecyclerHolder.cpp.

References query_resultset_cache_.

                             {
  return query_resultset_cache_->getTargetExprs(key);
}

bool ResultSetRecyclerHolder::hasCachedQueryResultSet

(

const size_t

key

)

Definition at line 26 of file ResultSetRecyclerHolder.cpp.

References query_resultset_cache_.

                                                                      {
  return query_resultset_cache_->hasItemInCache(key);
}

static auto ResultSetRecyclerHolder::invalidateCache ( )

inlinestatic

Definition at line 24 of file ResultSetRecyclerHolder.h.

References CHECK, chunk_metadata_cache_, and query_resultset_cache_.

                                {
    CHECK(query_resultset_cache_);
    query_resultset_cache_->clearCache();

    CHECK(chunk_metadata_cache_);
    chunk_metadata_cache_->clearCache();
  }

static auto ResultSetRecyclerHolder::markCachedItemAsDirty ( size_t  table_key )

inlinestatic

Definition at line 32 of file ResultSetRecyclerHolder.h.

References CHECK, CHUNK_METADATA, chunk_metadata_cache_, DataRecyclerUtil::CPU_DEVICE_IDENTIFIER, QUERY_RESULTSET, and query_resultset_cache_.

                                                      {
    CHECK(query_resultset_cache_);
    CHECK(chunk_metadata_cache_);
    auto resultset_cache_tbl_key =
        query_resultset_cache_->getMappedQueryPlanDagsWithTableKey(table_key);
    if (resultset_cache_tbl_key.has_value()) {
      query_resultset_cache_->markCachedItemAsDirty(
          table_key,
          *resultset_cache_tbl_key,
          CacheItemType::QUERY_RESULTSET,
          DataRecyclerUtil::CPU_DEVICE_IDENTIFIER);
    }
    auto chunk_metadata_cache_tbl_key =
        chunk_metadata_cache_->getMappedQueryPlanDagsWithTableKey(table_key);
    if (chunk_metadata_cache_tbl_key.has_value()) {
      chunk_metadata_cache_->markCachedItemAsDirty(
          table_key,
          *chunk_metadata_cache_tbl_key,
          CacheItemType::CHUNK_METADATA,
          DataRecyclerUtil::CPU_DEVICE_IDENTIFIER);
    }
  }

void ResultSetRecyclerHolder::putChunkMetadataToCache	(	const size_t	key,
		const std::unordered_set< size_t > &	input_table_keys,
		const ChunkMetadataMap &	chunk_metadata
	)

Definition at line 65 of file ResultSetRecyclerHolder.cpp.

References CHUNK_METADATA, chunk_metadata_cache_, and CHUNK_METADATA_CACHE_DEVICE_IDENTIFIER.

                                                {
  if (!chunk_metadata_map.empty()) {
    ChunkMetadataMetaInfo meta_info{input_table_keys};
    chunk_metadata_cache_->putItemToCache(key,
                                          chunk_metadata_map,
                                          CacheItemType::CHUNK_METADATA,
                                          CHUNK_METADATA_CACHE_DEVICE_IDENTIFIER,
                                          0,
                                          0,
                                          meta_info);
  }
}

void ResultSetRecyclerHolder::putQueryResultSetToCache	(	const size_t	key,
		const std::unordered_set< size_t > &	input_table_keys,
		const ResultSetPtr	query_result,
		size_t	resultset_size,
		std::vector< std::shared_ptr< Analyzer::Expr >> &	target_exprs
	)

Definition at line 42 of file ResultSetRecyclerHolder.cpp.

References DataRecyclerUtil::CPU_DEVICE_IDENTIFIER, ResultSetMetaInfo::keepTargetExprs(), QUERY_RESULTSET, and query_resultset_cache_.

                                                          {
  ResultSetMetaInfo resultset_meta_info{input_table_keys};
  resultset_meta_info.keepTargetExprs(target_exprs);
  query_resultset_cache_->putItemToCache(key,
                                         query_result,
                                         CacheItemType::QUERY_RESULTSET,
                                         DataRecyclerUtil::CPU_DEVICE_IDENTIFIER,
                                         resultset_size,
                                         query_result->getExecTime(),
                                         resultset_meta_info);
}

Here is the call graph for this function:

Member Data Documentation

std::unique_ptr< ChunkMetadataRecycler > ResultSetRecyclerHolder::chunk_metadata_cache_

staticprivate

Initial value:

=
    std::make_unique<ChunkMetadataRecycler>()

Definition at line 89 of file ResultSetRecyclerHolder.h.

Referenced by getCachedChunkMetadata(), getChunkMetadataRecycler(), invalidateCache(), markCachedItemAsDirty(), and putChunkMetadataToCache().

std::unique_ptr< ResultSetRecycler > ResultSetRecyclerHolder::query_resultset_cache_

staticprivate

Initial value:

=
    std::make_unique<ResultSetRecycler>()

Definition at line 85 of file ResultSetRecyclerHolder.h.

Referenced by getCachedQueryResultSet(), getOutputMetaInfo(), getResultSetRecycler(), getTargetExprs(), hasCachedQueryResultSet(), invalidateCache(), markCachedItemAsDirty(), and putQueryResultSetToCache().

---

The documentation for this class was generated from the following files:

• /home/jenkins-slave/workspace/core-os-doxygen/QueryEngine/ResultSetRecyclerHolder.h
• /home/jenkins-slave/workspace/core-os-doxygen/QueryEngine/ResultSetRecyclerHolder.cpp