OmniSciDB  72c90bc290
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
anonymous_namespace{ColumnFetcher.cpp} Namespace Reference

Functions

const ColumnarResultscolumnarize_result (std::shared_ptr< RowSetMemoryOwner > row_set_mem_owner, const ResultSetPtr &result, const size_t thread_idx, const size_t executor_id, const int frag_id)
 
std::string getMemoryLevelString (Data_Namespace::MemoryLevel memoryLevel)
 

Function Documentation

const ColumnarResults* anonymous_namespace{ColumnFetcher.cpp}::columnarize_result ( std::shared_ptr< RowSetMemoryOwner row_set_mem_owner,
const ResultSetPtr result,
const size_t  thread_idx,
const size_t  executor_id,
const int  frag_id 
)
inline

Definition at line 30 of file ColumnFetcher.cpp.

References CHECK_EQ, get_logical_type_info(), and INJECT_TIMER.

Referenced by ColumnFetcher::getOneColumnFragment(), and ColumnFetcher::getResultSetColumn().

35  {
37  CHECK_EQ(0, frag_id);
38 
39  std::vector<SQLTypeInfo> col_types;
40  for (size_t i = 0; i < result->colCount(); ++i) {
41  const auto& src_ti = result->getColType(i);
42  CHECK_EQ(result->checkSlotUsesFlatBufferFormat(i), src_ti.usesFlatBuffer());
43  auto ti = get_logical_type_info(src_ti);
44  ti.setUsesFlatBuffer(src_ti.supportsFlatBuffer());
45  col_types.push_back(ti);
46  }
47  return new ColumnarResults(
48  row_set_mem_owner, *result, result->colCount(), col_types, executor_id, thread_idx);
49 }
#define CHECK_EQ(x, y)
Definition: Logger.h:301
SQLTypeInfo get_logical_type_info(const SQLTypeInfo &type_info)
Definition: sqltypes.h:1470
const ColumnarResults * columnarize_result(std::shared_ptr< RowSetMemoryOwner > row_set_mem_owner, const ResultSetPtr &result, const size_t thread_idx, const size_t executor_id, const int frag_id)
#define INJECT_TIMER(DESC)
Definition: measure.h:96

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

std::string anonymous_namespace{ColumnFetcher.cpp}::getMemoryLevelString ( Data_Namespace::MemoryLevel  memoryLevel)

Definition at line 51 of file ColumnFetcher.cpp.

References Data_Namespace::CPU_LEVEL, Data_Namespace::DISK_LEVEL, and Data_Namespace::GPU_LEVEL.

Referenced by ColumnFetcher::linearizeColumnFragments(), ColumnFetcher::linearizeFixedLenArrayColFrags(), and ColumnFetcher::linearizeVarLenArrayColFrags().

51  {
52  switch (memoryLevel) {
53  case DISK_LEVEL:
54  return "DISK_LEVEL";
55  case GPU_LEVEL:
56  return "GPU_LEVEL";
57  case CPU_LEVEL:
58  return "CPU_LEVEL";
59  default:
60  return "UNKNOWN";
61  }
62 }

+ Here is the caller graph for this function: