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

This is the complete list of members for impala::ExchangeNode, 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
child(int i)impala::ExecNodeinlineprotected
children_impala::ExecNodeprotected
Close(RuntimeState *state)impala::ExchangeNodevirtual
CodegenEvalConjuncts(RuntimeState *state, const std::vector< ExprContext * > &conjunct_ctxs, const char *name="EvalConjuncts")impala::ExecNodestatic
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
convert_row_batch_timer_impala::ExchangeNodeprivate
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::ExchangeNodeprotectedvirtual
impala::ExecNode::DebugString() const impala::ExecNode
EvalConjuncts(ExprContext *const *ctxs, int num_ctxs, TupleRow *row)impala::ExecNodestatic
ExchangeNode(ObjectPool *pool, const TPlanNode &tnode, const DescriptorTbl &descs)impala::ExchangeNode
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
FillInputRowBatch(RuntimeState *state)impala::ExchangeNodeprivate
GetNext(RuntimeState *state, RowBatch *row_batch, bool *eos)impala::ExchangeNodevirtual
GetNextMerging(RuntimeState *state, RowBatch *output_batch, bool *eos)impala::ExchangeNodeprivate
GetNodeIdFromProfile(RuntimeProfile *p)impala::ExecNodestatic
id() const impala::ExecNodeinline
id_impala::ExecNodeprotected
Init(const TPlanNode &tnode)impala::ExchangeNodevirtual
InitRuntimeProfile(const std::string &name)impala::ExecNodeprotected
input_batch_impala::ExchangeNodeprivate
input_row_desc_impala::ExchangeNodeprivate
is_asc_order_impala::ExchangeNodeprivate
is_closed()impala::ExecNodeinlineprotected
is_merging_impala::ExchangeNodeprivate
IsScanNode() const impala::ExecNodeinlineprotectedvirtual
limit() const impala::ExecNodeinline
limit_impala::ExecNodeprotected
mem_tracker()impala::ExecNodeinline
mem_tracker_impala::ExecNodeprotected
next_row_idx_impala::ExchangeNodeprivate
nulls_first_impala::ExchangeNodeprivate
num_rows_returned_impala::ExecNodeprotected
num_rows_skipped_impala::ExchangeNodeprivate
num_senders_impala::ExchangeNodeprivate
offset_impala::ExchangeNodeprivate
Open(RuntimeState *state)impala::ExchangeNodevirtual
pool_impala::ExecNodeprotected
Prepare(RuntimeState *state)impala::ExchangeNodevirtual
QueryMaintenance(RuntimeState *state)impala::ExecNodeprotectedvirtual
ReachedLimit()impala::ExecNodeinline
Reset(RuntimeState *state)impala::ExchangeNodevirtual
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
set_num_senders(int num_senders)impala::ExchangeNodeinline
SetDebugOptions(int node_id, TExecNodePhase::type phase, TDebugAction::type action, ExecNode *tree)impala::ExecNodestatic
sort_exec_exprs_impala::ExchangeNodeprivate
stream_recvr_impala::ExchangeNodeprivate
type() const impala::ExecNodeinline
type_impala::ExecNodeprotected
~ExecNode()impala::ExecNodevirtual