OmniSciDB
b24e664e58
|
#include "StreamingTopN.h"
#include "RelAlgExecutor.h"
#include "Shared/checked_alloc.h"
#include "TopKSort.h"
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) |
bool | use_streaming_top_n (const RelAlgExecutionUnit &ra_exe_unit, const bool output_columnar) |
size_t | get_heap_key_slot_index (const std::vector< Analyzer::Expr * > &target_exprs, const size_t target_idx) |
size_t get_heap_key_slot_index | ( | const std::vector< Analyzer::Expr * > & | target_exprs, |
const size_t | target_idx | ||
) |
Definition at line 81 of file StreamingTopN.cpp.
References advance_slot(), g_bigint_count, and get_target_info().
Referenced by GroupByAndAggregate::codegenOutputSlot().
bool use_streaming_top_n | ( | const RelAlgExecutionUnit & | ra_exe_unit, |
const bool | output_columnar | ||
) |
Definition at line 46 of file StreamingTopN.cpp.
References SortInfo::algorithm, CHECK_GT, CHECK_LE, g_cluster, SortInfo::limit, SortInfo::offset, SortInfo::order_entries, RelAlgExecutionUnit::sort_info, StreamingTopN, and RelAlgExecutionUnit::target_exprs.
Referenced by GroupByAndAggregate::codegen(), GroupByAndAggregate::codegenOutputSlot(), QueryMemoryInitializer::copyGroupByBuffersFromGpu(), QueryMemoryDescriptor::getBufferSizeBytes(), QueryExecutionContext::launchCpuCode(), QueryExecutionContext::launchGpuCode(), and QueryMemoryInitializer::QueryMemoryInitializer().