25 #ifndef QUERYENGINE_STREAMINGTOPN_H
26 #define QUERYENGINE_STREAMINGTOPN_H
32 namespace streaming_top_n {
34 size_t get_heap_size(
const size_t row_size,
const size_t n,
const size_t thread_count);
39 const size_t heaps_size,
41 const size_t thread_count);
54 const size_t target_idx);
57 namespace Data_Namespace {
64 std::vector<int8_t> pick_top_n_rows_from_dev_heaps(
66 const int64_t* dev_heaps,
69 const size_t thread_count,
72 #endif // QUERYENGINE_STREAMINGTOPN_H
size_t get_rows_offset_of_heaps(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)
std::vector< int8_t > 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_size(const size_t row_size, const size_t n, const size_t thread_count)