StreamingTopN.cpp File Reference

#include "StreamingTopN.h"
#include "RelAlgExecutor.h"
#include "Shared/checked_alloc.h"
#include "TopKSort.h"

Include dependency graph for StreamingTopN.cpp:

Go to the source code of this file.

Namespaces
	streaming_top_n

Functions
size_t	streaming_top_n::get_heap_size (const size_t row_size, const size_t n, const size_t thread_count)
size_t	streaming_top_n::get_rows_offset_of_heaps (const size_t n, const size_t thread_count)
std::vector< int8_t >	streaming_top_n::get_rows_copy_from_heaps (const int64_t *heaps, const size_t heaps_size, const size_t n, const size_t thread_count)
size_t	get_heap_key_slot_index (const std::vector< Analyzer::Expr *> &target_exprs, const size_t target_idx)

Function Documentation

get_heap_key_slot_index()

size_t get_heap_key_slot_index	(	const std::vector< Analyzer::Expr *> &	target_exprs,
		const size_t	target_idx
	)

Definition at line 46 of file StreamingTopN.cpp.

References advance_slot(), QueryMemoryDescriptor::canOutputColumnar(), CHECK, CHECK_EQ, g_bigint_count, get_heap_key_slot_index(), get_target_info(), QueryMemoryDescriptor::getBufferSizeBytes(), QueryMemoryDescriptor::getColOffInBytes(), QueryMemoryDescriptor::getEffectiveKeyWidth(), QueryMemoryDescriptor::getPaddedSlotWidthBytes(), QueryMemoryDescriptor::getRowSize(), GPU, SortInfo::limit, SortInfo::offset, SortInfo::order_entries, RelAlgExecutionUnit::sort_info, RelAlgExecutionUnit::target_exprs, and PodOrderEntry::tle_no.

Referenced by GroupByAndAggregate::codegenOutputSlot(), and get_heap_key_slot_index().

                                                        {
  size_t slot_idx = 0;
  for (size_t i = 0; i < target_idx; ++i) {
    auto agg_info = get_target_info(target_exprs[i], g_bigint_count);
    slot_idx = advance_slot(slot_idx, agg_info, false);
  }
  return slot_idx;
}

Here is the call graph for this function:

Here is the caller graph for this function: