addColumnBufferForWindowFunctionExpression(const int8_t *column, const std::vector< std::shared_ptr< Chunk_NS::Chunk >> &chunks_owner) | WindowFunctionContext | |
addOrderColumn(const int8_t *column, const SQLTypeInfo &ti, const std::vector< std::shared_ptr< Chunk_NS::Chunk >> &chunks_owner) | WindowFunctionContext | |
aggregate_state_ | WindowFunctionContext | private |
aggregate_trees_ | WindowFunctionContext | private |
aggregate_trees_depth_ | WindowFunctionContext | private |
aggregate_trees_fan_out_ | WindowFunctionContext | private |
aggregateState() const | WindowFunctionContext | |
aggregateStateCount() const | WindowFunctionContext | |
aggregateStatePendingOutputs() const | WindowFunctionContext | |
buildAggregationTreeForPartition(SqlWindowFunctionKind agg_type, size_t partition_idx, size_t partition_size, const int32_t *original_rowid_buf, const int64_t *ordered_rowid_buf, const SQLTypeInfo &input_col_ti) | WindowFunctionContext | private |
Comparator typedef | WindowFunctionContext | |
compute(std::unordered_map< QueryPlanHash, size_t > &sorted_partition_key_ref_count_map, std::unordered_map< QueryPlanHash, std::shared_ptr< std::vector< int64_t >>> &sorted_partition_cache, std::unordered_map< QueryPlanHash, AggregateTreeForWindowFraming > &aggregate_tree_map) | WindowFunctionContext | |
computeAggregateTreeCacheKey() const | WindowFunctionContext | private |
computeNullRangeOfSortedPartition(const SQLTypeInfo &order_col_ti, size_t partition_idx, const int32_t *original_col_idx_buf, const int64_t *ordered_col_idx_buf) | WindowFunctionContext | private |
computePartitionBuffer(const size_t partition_idx, int64_t *output_for_partition_buff, const Analyzer::WindowFunction *window_func) | WindowFunctionContext | private |
counts() const | WindowFunctionContext | |
createComparator(size_t partition_idx) | WindowFunctionContext | |
device_type_ | WindowFunctionContext | private |
dummy_count_ | WindowFunctionContext | private |
dummy_offset_ | WindowFunctionContext | private |
dummy_payload_ | WindowFunctionContext | private |
elem_count_ | WindowFunctionContext | private |
elementCount() const | WindowFunctionContext | |
fillPartitionEnd() | WindowFunctionContext | private |
fillPartitionStart() | WindowFunctionContext | private |
getAggregateTreeDepth() const | WindowFunctionContext | |
getAggregateTreeFanout() const | WindowFunctionContext | |
getAggregationTreesForDoubleTypeWindowExpr() const | WindowFunctionContext | |
getAggregationTreesForIntegerTypeWindowExpr() const | WindowFunctionContext | |
getColumnBufferForWindowFunctionExpressions() const | WindowFunctionContext | |
getDerivedAggregationTreesForDoubleTypeWindowExpr() const | WindowFunctionContext | |
getDerivedAggregationTreesForIntegerTypeWindowExpr() const | WindowFunctionContext | |
getNullValueEndPos() const | WindowFunctionContext | |
getNullValueStartPos() const | WindowFunctionContext | |
getOrderKeyColumnBuffers() const | WindowFunctionContext | |
getOrderKeyColumnBufferTypes() const | WindowFunctionContext | |
getWindowFunction() const | WindowFunctionContext | |
makeComparator(const Analyzer::ColumnVar *col_var, const int8_t *partition_values, const int32_t *partition_indices, const bool asc_ordering, const bool nulls_first) | WindowFunctionContext | privatestatic |
needsToBuildAggregateTree() const | WindowFunctionContext | |
NUM_EXECUTION_DEVICES | WindowFunctionContext | static |
offsets() const | WindowFunctionContext | |
operator=(const WindowFunctionContext &)=delete | WindowFunctionContext | |
order_columns_ | WindowFunctionContext | private |
order_columns_owner_ | WindowFunctionContext | private |
order_columns_ti_ | WindowFunctionContext | private |
ordered_partition_null_end_pos_ | WindowFunctionContext | private |
ordered_partition_null_start_pos_ | WindowFunctionContext | private |
output() const | WindowFunctionContext | |
output_ | WindowFunctionContext | private |
partition_cache_key_ | WindowFunctionContext | private |
partition_end_ | WindowFunctionContext | private |
partition_start_ | WindowFunctionContext | private |
partition_start_offset_ | WindowFunctionContext | private |
partitionCount() const | WindowFunctionContext | |
partitionEnd() const | WindowFunctionContext | |
partitionNumCountBuf() const | WindowFunctionContext | |
partitions_ | WindowFunctionContext | private |
partitionStart() const | WindowFunctionContext | |
partitionStartOffset() const | WindowFunctionContext | |
payload() const | WindowFunctionContext | |
resizeStorageForWindowFraming(bool const for_reuse=false) | WindowFunctionContext | private |
row_set_mem_owner_ | WindowFunctionContext | private |
segment_trees_owned_ | WindowFunctionContext | private |
setSortedPartitionCacheKey(QueryPlanHash cache_key) | WindowFunctionContext | |
sorted_partition_buf_ | WindowFunctionContext | private |
sorted_partition_cache_key_ | WindowFunctionContext | private |
sortedPartition() const | WindowFunctionContext | |
sortPartition(const size_t partition_idx, int64_t *output_for_partition_buff, bool should_parallelize) | WindowFunctionContext | private |
window_func_ | WindowFunctionContext | private |
window_func_expr_columns_ | WindowFunctionContext | private |
window_func_expr_columns_owner_ | WindowFunctionContext | private |
WindowComparatorResult enum name | WindowFunctionContext | |
WindowFunctionContext(const Analyzer::WindowFunction *window_func, const size_t elem_count, const ExecutorDeviceType device_type, std::shared_ptr< RowSetMemoryOwner > row_set_mem_owner) | WindowFunctionContext | |
WindowFunctionContext(const Analyzer::WindowFunction *window_func, QueryPlanHash cache_key, const std::shared_ptr< HashJoin > &partitions, const size_t elem_count, const ExecutorDeviceType device_type, std::shared_ptr< RowSetMemoryOwner > row_set_mem_owner, size_t aggregation_tree_fan_out=g_window_function_aggregation_tree_fanout) | WindowFunctionContext | |
WindowFunctionContext(const WindowFunctionContext &)=delete | WindowFunctionContext | |
~WindowFunctionContext() | WindowFunctionContext | |