Impala
Impalaistheopensource,nativeanalyticdatabaseforApacheHadoop.
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
impala::PartitionedAggregationNode Member List

This is the complete list of members for impala::PartitionedAggregationNode, including all inherited members.

AddExprCtxsToFree(const std::vector< ExprContext * > &ctxs)impala::ExecNodeprotected
AddExprCtxsToFree(const SortExecExprs &sort_exec_exprs)impala::ExecNodeprotected
AddExprCtxToFree(ExprContext *ctx)impala::ExecNodeinlineprotected
AddRuntimeExecOption(const std::string &option)impala::ExecNodeprotected
agg_fn_ctxs_impala::PartitionedAggregationNodeprivate
agg_fn_pool_impala::PartitionedAggregationNodeprivate
aggregate_evaluators_impala::PartitionedAggregationNodeprivate
aggregated_partitions_impala::PartitionedAggregationNodeprivate
block_mgr_client_impala::PartitionedAggregationNodeprivate
build_expr_ctxs_impala::PartitionedAggregationNodeprivate
build_timer_impala::PartitionedAggregationNodeprivate
child(int i)impala::ExecNodeinlineprotected
children_impala::ExecNodeprotected
CleanupHashTbl(const std::vector< impala_udf::FunctionContext * > &fn_ctxs, HashTable::Iterator it)impala::PartitionedAggregationNodeprivate
Close(RuntimeState *state)impala::PartitionedAggregationNodevirtual
CodegenEvalConjuncts(RuntimeState *state, const std::vector< ExprContext * > &conjunct_ctxs, const char *name="EvalConjuncts")impala::ExecNodestatic
CodegenProcessBatch()impala::PartitionedAggregationNodeprivate
CodegenUpdateSlot(AggFnEvaluator *evaluator, SlotDescriptor *slot_desc)impala::PartitionedAggregationNodeprivate
CodegenUpdateTuple()impala::PartitionedAggregationNodeprivate
CollectNodes(TPlanNodeType::type node_type, std::vector< ExecNode * > *nodes)impala::ExecNode
CollectScanNodes(std::vector< ExecNode * > *nodes)impala::ExecNode
conjunct_ctxs() const impala::ExecNodeinline
conjunct_ctxs_impala::ExecNodeprotected
ConstructIntermediateTuple(const std::vector< impala_udf::FunctionContext * > &agg_fn_ctxs, MemPool *pool, BufferedTupleStream *stream)impala::PartitionedAggregationNodeprivate
contains_var_len_grouping_exprs_impala::PartitionedAggregationNodeprivate
CreateHashPartitions(int level)impala::PartitionedAggregationNodeprivate
CreateNode(ObjectPool *pool, const TPlanNode &tnode, const DescriptorTbl &descs, ExecNode **node)impala::ExecNodeprotectedstatic
CreateTree(ObjectPool *pool, const TPlan &plan, const DescriptorTbl &descs, ExecNode **root)impala::ExecNodestatic
CreateTreeHelper(ObjectPool *pool, const std::vector< TPlanNode > &tnodes, const DescriptorTbl &descs, ExecNode *parent, int *node_idx, ExecNode **root)impala::ExecNodeprotectedstatic
debug_action_impala::ExecNodeprotected
debug_phase_impala::ExecNodeprotected
DebugString(int indentation_level, std::stringstream *out) const impala::PartitionedAggregationNodeprotectedvirtual
impala::ExecNode::DebugString() const impala::ExecNode
EvalConjuncts(ExprContext *const *ctxs, int num_ctxs, TupleRow *row)impala::ExecNodestatic
exec_options_lock_impala::ExecNodeprotected
ExecDebugAction(TExecNodePhase::type phase, RuntimeState *state)impala::ExecNodeprotected
ExecNode(ObjectPool *pool, const TPlanNode &tnode, const DescriptorTbl &descs)impala::ExecNode
expr_mem_tracker()impala::ExecNodeinline
expr_mem_tracker_impala::ExecNodeprotected
get_results_timer_impala::PartitionedAggregationNodeprivate
GetNext(RuntimeState *state, RowBatch *row_batch, bool *eos)impala::PartitionedAggregationNodevirtual
GetNodeIdFromProfile(RuntimeProfile *p)impala::ExecNodestatic
GetOutputTuple(const std::vector< impala_udf::FunctionContext * > &agg_fn_ctxs, Tuple *tuple, MemPool *pool)impala::PartitionedAggregationNodeprivate
hash_partitions_impala::PartitionedAggregationNodeprivate
ht_ctx_impala::PartitionedAggregationNodeprivate
ht_resize_timer_impala::PartitionedAggregationNodeprivate
id() const impala::ExecNodeinline
id_impala::ExecNodeprotected
Init(const TPlanNode &tnode)impala::PartitionedAggregationNodevirtual
InitRuntimeProfile(const std::string &name)impala::ExecNodeprotected
intermediate_row_desc_impala::PartitionedAggregationNodeprivate
intermediate_tuple_desc_impala::PartitionedAggregationNodeprivate
intermediate_tuple_id_impala::PartitionedAggregationNodeprivate
is_closed()impala::ExecNodeinlineprotected
IsScanNode() const impala::ExecNodeinlineprotectedvirtual
largest_partition_percent_impala::PartitionedAggregationNodeprivate
LargestSpilledPartition() const impala::PartitionedAggregationNodeprivate
limit() const impala::ExecNodeinline
limit_impala::ExecNodeprotected
LLVM_CLASS_NAMEimpala::PartitionedAggregationNodestatic
MAX_PARTITION_DEPTHimpala::PartitionedAggregationNodeprivatestatic
max_partition_level_impala::PartitionedAggregationNodeprivate
mem_pool_impala::PartitionedAggregationNodeprivate
mem_tracker()impala::ExecNodeinline
mem_tracker_impala::ExecNodeprotected
MinRequiredBuffers() const impala::PartitionedAggregationNodeinlineprivate
MoveHashPartitions(int64_t input_rows)impala::PartitionedAggregationNodeprivate
needs_finalize_impala::PartitionedAggregationNodeprivate
needs_serialize_impala::PartitionedAggregationNodeprivate
NextPartition()impala::PartitionedAggregationNodeprivate
num_hash_buckets_impala::PartitionedAggregationNodeprivate
NUM_PARTITIONING_BITSimpala::PartitionedAggregationNodeprivatestatic
num_repartitions_impala::PartitionedAggregationNodeprivate
num_row_repartitioned_impala::PartitionedAggregationNodeprivate
num_rows_returned_impala::ExecNodeprotected
num_spilled_partitions_impala::PartitionedAggregationNodeprivate
Open(RuntimeState *state)impala::PartitionedAggregationNodevirtual
output_iterator_impala::PartitionedAggregationNodeprivate
output_partition_impala::PartitionedAggregationNodeprivate
output_tuple_desc_impala::PartitionedAggregationNodeprivate
output_tuple_id_impala::PartitionedAggregationNodeprivate
PARTITION_FANOUTimpala::PartitionedAggregationNodeprivatestatic
PartitionedAggregationNode(ObjectPool *pool, const TPlanNode &tnode, const DescriptorTbl &descs)impala::PartitionedAggregationNode
partitions_created_impala::PartitionedAggregationNodeprivate
pool_impala::ExecNodeprotected
Prepare(RuntimeState *state)impala::PartitionedAggregationNodevirtual
probe_expr_ctxs_impala::PartitionedAggregationNodeprivate
process_row_batch_fn_impala::PartitionedAggregationNodeprivate
ProcessBatch(RowBatch *batch, HashTableCtx *ht_ctx)impala::PartitionedAggregationNodeprivate
ProcessBatch(RowBatch *batch, HashTableCtx *ht_ctx)impala::PartitionedAggregationNode
ProcessBatch_false(RowBatch *batch, HashTableCtx *ht_ctx)impala::PartitionedAggregationNodeprivate
ProcessBatch_true(RowBatch *batch, HashTableCtx *ht_ctx)impala::PartitionedAggregationNodeprivate
ProcessBatchNoGrouping(RowBatch *batch, HashTableCtx *ht_ctx=NULL)impala::PartitionedAggregationNodeprivate
ProcessRowBatchFn typedefimpala::PartitionedAggregationNodeprivate
ProcessStream(BufferedTupleStream *input_stream)impala::PartitionedAggregationNodeprivate
QueryMaintenance(RuntimeState *state)impala::PartitionedAggregationNodeprotectedvirtual
ReachedLimit()impala::ExecNodeinline
Reset(RuntimeState *state)impala::PartitionedAggregationNodevirtual
row_desc() const impala::ExecNodeinline
row_descriptor_impala::ExecNodeprotected
ROW_THROUGHPUT_COUNTERimpala::ExecNodestatic
rows_returned() const impala::ExecNodeinline
rows_returned_counter_impala::ExecNodeprotected
rows_returned_rate_impala::ExecNodeprotected
runtime_exec_options_impala::ExecNodeprotected
runtime_profile()impala::ExecNodeinline
runtime_profile_impala::ExecNodeprotected
serialize_stream_impala::PartitionedAggregationNodeprivate
SetDebugOptions(int node_id, TExecNodePhase::type phase, TDebugAction::type action, ExecNode *tree)impala::ExecNodestatic
singleton_output_tuple_impala::PartitionedAggregationNodeprivate
singleton_output_tuple_returned_impala::PartitionedAggregationNodeprivate
spilled_partitions_impala::PartitionedAggregationNodeprivate
SpillPartition(Partition *curr_partition=NULL, Tuple *curr_intermediate_tuple=NULL)impala::PartitionedAggregationNodeprivate
state_impala::PartitionedAggregationNodeprivate
type() const impala::ExecNodeinline
type_impala::ExecNodeprotected
UpdateTuple(impala_udf::FunctionContext **agg_fn_ctxs, Tuple *tuple, TupleRow *row, bool is_merge=false)impala::PartitionedAggregationNodeprivate
using_small_buffers_impala::PartitionedAggregationNodeprivate
~ExecNode()impala::ExecNodevirtual