AddExprCtxsToFree(const std::vector< ExprContext * > &ctxs) | impala::ExecNode | protected |
AddExprCtxsToFree(const SortExecExprs &sort_exec_exprs) | impala::ExecNode | protected |
AddExprCtxToFree(ExprContext *ctx) | impala::ExecNode | inlineprotected |
AddRuntimeExecOption(const std::string &option) | impala::ExecNode | protected |
AddToDebugString(int indentation_level, std::stringstream *out) const | impala::PartitionedHashJoinNode | protectedvirtual |
AllocateProbeFilters(RuntimeState *state) | impala::PartitionedHashJoinNode | private |
AppendRow(BufferedTupleStream *stream, TupleRow *row) | impala::PartitionedHashJoinNode | inlineprivate |
AppendRowStreamFull(BufferedTupleStream *stream, TupleRow *row) | impala::PartitionedHashJoinNode | private |
AttachProbeFilters(RuntimeState *state) | impala::PartitionedHashJoinNode | private |
block_mgr_client_ | impala::PartitionedHashJoinNode | private |
BlockingJoinNode(const std::string &node_name, const TJoinOp::type join_op, ObjectPool *pool, const TPlanNode &tnode, const DescriptorTbl &descs) | impala::BlockingJoinNode | |
build_expr_ctxs_ | impala::PartitionedHashJoinNode | private |
build_pool_ | impala::BlockingJoinNode | protected |
build_row_counter_ | impala::BlockingJoinNode | protected |
build_timer_ | impala::BlockingJoinNode | protected |
build_tuple_row_size_ | impala::BlockingJoinNode | protected |
BuildHashTables(RuntimeState *state) | impala::PartitionedHashJoinNode | private |
can_add_probe_filters_ | impala::BlockingJoinNode | protected |
child(int i) | impala::ExecNode | inlineprotected |
children_ | impala::ExecNode | protected |
CleanUpHashPartitions(RowBatch *batch) | impala::PartitionedHashJoinNode | private |
Close(RuntimeState *state) | impala::PartitionedHashJoinNode | virtual |
CodegenCreateOutputRow(LlvmCodeGen *codegen) | impala::PartitionedHashJoinNode | private |
CodegenEvalConjuncts(RuntimeState *state, const std::vector< ExprContext * > &conjunct_ctxs, const char *name="EvalConjuncts") | impala::ExecNode | static |
CodegenProcessBuildBatch(RuntimeState *state, llvm::Function *hash_fn, llvm::Function *murmur_hash_fn) | impala::PartitionedHashJoinNode | private |
CodegenProcessProbeBatch(RuntimeState *state, llvm::Function *hash_fn, llvm::Function *murmur_hash_fn) | impala::PartitionedHashJoinNode | private |
CollectNodes(TPlanNodeType::type node_type, std::vector< ExecNode * > *nodes) | impala::ExecNode | |
CollectScanNodes(std::vector< ExecNode * > *nodes) | impala::ExecNode | |
conjunct_ctxs() const | impala::ExecNode | inline |
conjunct_ctxs_ | impala::ExecNode | protected |
ConstructBuildSide(RuntimeState *state) | impala::PartitionedHashJoinNode | protectedvirtual |
CreateNode(ObjectPool *pool, const TPlanNode &tnode, const DescriptorTbl &descs, ExecNode **node) | impala::ExecNode | protectedstatic |
CreateOutputRow(TupleRow *out_row, TupleRow *probe_row, TupleRow *build_row) | impala::BlockingJoinNode | protected |
CreateTree(ObjectPool *pool, const TPlan &plan, const DescriptorTbl &descs, ExecNode **root) | impala::ExecNode | static |
CreateTreeHelper(ObjectPool *pool, const std::vector< TPlanNode > &tnodes, const DescriptorTbl &descs, ExecNode *parent, int *node_idx, ExecNode **root) | impala::ExecNode | protectedstatic |
current_probe_row_ | impala::BlockingJoinNode | protected |
debug_action_ | impala::ExecNode | protected |
debug_phase_ | impala::ExecNode | protected |
DebugString(int indentation_level, std::stringstream *out) const | impala::BlockingJoinNode | protectedvirtual |
impala::ExecNode::DebugString() const | impala::ExecNode | |
eos_ | impala::BlockingJoinNode | protected |
EvalConjuncts(ExprContext *const *ctxs, int num_ctxs, TupleRow *row) | impala::ExecNode | static |
EvaluateNullProbe(BufferedTupleStream *build) | impala::PartitionedHashJoinNode | private |
exec_options_lock_ | impala::ExecNode | protected |
ExecDebugAction(TExecNodePhase::type phase, RuntimeState *state) | impala::ExecNode | protected |
ExecNode(ObjectPool *pool, const TPlanNode &tnode, const DescriptorTbl &descs) | impala::ExecNode | |
expr_mem_tracker() | impala::ExecNode | inline |
expr_mem_tracker_ | impala::ExecNode | protected |
GetLeftChildRowString(TupleRow *row) | impala::BlockingJoinNode | protected |
GetNext(RuntimeState *state, RowBatch *row_batch, bool *eos) | impala::PartitionedHashJoinNode | virtual |
GetNodeIdFromProfile(RuntimeProfile *p) | impala::ExecNode | static |
hash_partitions_ | impala::PartitionedHashJoinNode | private |
hash_tbl_iterator_ | impala::PartitionedHashJoinNode | private |
hash_tbls_ | impala::PartitionedHashJoinNode | private |
ht_ctx_ | impala::PartitionedHashJoinNode | private |
id() const | impala::ExecNode | inline |
id_ | impala::ExecNode | protected |
Init(const TPlanNode &tnode) | impala::PartitionedHashJoinNode | virtual |
InitGetNext(TupleRow *first_probe_row) | impala::PartitionedHashJoinNode | protectedvirtual |
InitRuntimeProfile(const std::string &name) | impala::ExecNode | protected |
input_partition_ | impala::PartitionedHashJoinNode | private |
is_closed() | impala::ExecNode | inlineprotected |
IsScanNode() const | impala::ExecNode | inlineprotectedvirtual |
join_op_ | impala::BlockingJoinNode | protected |
largest_partition_percent_ | impala::PartitionedHashJoinNode | private |
LargestSpilledPartition() const | impala::PartitionedHashJoinNode | private |
limit() const | impala::ExecNode | inline |
limit_ | impala::ExecNode | protected |
LLVM_CLASS_NAME | impala::BlockingJoinNode | static |
matched_null_probe_ | impala::PartitionedHashJoinNode | private |
matched_probe_ | impala::BlockingJoinNode | protected |
MAX_IN_MEM_BUILD_TABLES | impala::PartitionedHashJoinNode | privatestatic |
MAX_PARTITION_DEPTH | impala::PartitionedHashJoinNode | privatestatic |
max_partition_level_ | impala::PartitionedHashJoinNode | private |
mem_tracker() | impala::ExecNode | inline |
mem_tracker_ | impala::ExecNode | protected |
MinRequiredBuffers() const | impala::PartitionedHashJoinNode | inlineprivate |
NextProbeRowBatch(RuntimeState *, RowBatch *out_batch) | impala::PartitionedHashJoinNode | private |
NextSpilledProbeRowBatch(RuntimeState *, RowBatch *out_batch) | impala::PartitionedHashJoinNode | private |
node_name_ | impala::BlockingJoinNode | protected |
NodeDebugString() const | impala::PartitionedHashJoinNode | private |
non_empty_build_ | impala::PartitionedHashJoinNode | private |
null_aware_eval_timer_ | impala::PartitionedHashJoinNode | private |
null_aware_partition_ | impala::PartitionedHashJoinNode | private |
null_probe_output_idx_ | impala::PartitionedHashJoinNode | private |
null_probe_rows_ | impala::PartitionedHashJoinNode | private |
nulls_build_batch_ | impala::PartitionedHashJoinNode | private |
num_build_rows_partitioned_ | impala::PartitionedHashJoinNode | private |
num_hash_buckets_ | impala::PartitionedHashJoinNode | private |
NUM_PARTITIONING_BITS | impala::PartitionedHashJoinNode | privatestatic |
num_probe_rows_partitioned_ | impala::PartitionedHashJoinNode | private |
num_repartitions_ | impala::PartitionedHashJoinNode | private |
num_rows_returned_ | impala::ExecNode | protected |
num_spilled_partitions_ | impala::PartitionedHashJoinNode | private |
Open(RuntimeState *state) | impala::BlockingJoinNode | virtual |
other_join_conjunct_ctxs_ | impala::PartitionedHashJoinNode | private |
output_build_partitions_ | impala::PartitionedHashJoinNode | private |
OutputNullAwareNullProbe(RuntimeState *state, RowBatch *out_batch) | impala::PartitionedHashJoinNode | private |
OutputNullAwareProbeRows(RuntimeState *state, RowBatch *out_batch) | impala::PartitionedHashJoinNode | private |
OutputUnmatchedBuild(RowBatch *out_batch) | impala::PartitionedHashJoinNode | private |
partition_build_timer_ | impala::PartitionedHashJoinNode | private |
PARTITION_FANOUT | impala::PartitionedHashJoinNode | privatestatic |
PartitionedHashJoinNode(ObjectPool *pool, const TPlanNode &tnode, const DescriptorTbl &descs) | impala::PartitionedHashJoinNode | |
PARTITIONING_BUILD enum value | impala::PartitionedHashJoinNode | private |
partitions_created_ | impala::PartitionedHashJoinNode | private |
pool_ | impala::ExecNode | protected |
Prepare(RuntimeState *state) | impala::PartitionedHashJoinNode | virtual |
PrepareNextPartition(RuntimeState *) | impala::PartitionedHashJoinNode | private |
PrepareNullAwareNullProbe() | impala::PartitionedHashJoinNode | private |
PrepareNullAwarePartition() | impala::PartitionedHashJoinNode | private |
PrintState() const | impala::PartitionedHashJoinNode | private |
probe_batch_ | impala::BlockingJoinNode | protected |
probe_batch_pos_ | impala::BlockingJoinNode | protected |
probe_expr_ctxs_ | impala::PartitionedHashJoinNode | private |
probe_filters_ | impala::PartitionedHashJoinNode | private |
probe_row_counter_ | impala::BlockingJoinNode | protected |
probe_side_eos_ | impala::BlockingJoinNode | protected |
probe_timer_ | impala::BlockingJoinNode | protected |
probe_tuple_row_size_ | impala::BlockingJoinNode | protected |
PROBING_SPILLED_PARTITION enum value | impala::PartitionedHashJoinNode | private |
process_build_batch_fn_ | impala::PartitionedHashJoinNode | private |
process_build_batch_fn_level0_ | impala::PartitionedHashJoinNode | private |
process_probe_batch_fn_ | impala::PartitionedHashJoinNode | private |
process_probe_batch_fn_level0_ | impala::PartitionedHashJoinNode | private |
ProcessBuildBatch(RowBatch *build_batch) | impala::PartitionedHashJoinNode | private |
ProcessBuildBatchFn typedef | impala::PartitionedHashJoinNode | private |
ProcessBuildInput(RuntimeState *state, int level) | impala::PartitionedHashJoinNode | private |
PROCESSING_PROBE enum value | impala::PartitionedHashJoinNode | private |
ProcessProbeBatch(RowBatch *out_batch, HashTableCtx *ht_ctx) | impala::PartitionedHashJoinNode | private |
ProcessProbeBatch(const TJoinOp::type join_op, RowBatch *out_batch, HashTableCtx *ht_ctx) | impala::PartitionedHashJoinNode | private |
ProcessProbeBatchFn typedef | impala::PartitionedHashJoinNode | private |
QueryMaintenance(RuntimeState *state) | impala::ExecNode | protectedvirtual |
ReachedLimit() | impala::ExecNode | inline |
REPARTITIONING enum value | impala::PartitionedHashJoinNode | private |
ReserveTupleStreamBlocks() | impala::PartitionedHashJoinNode | private |
Reset(RuntimeState *state) | impala::PartitionedHashJoinNode | virtual |
ResetForProbe() | impala::PartitionedHashJoinNode | inlineprivate |
row_desc() const | impala::ExecNode | inline |
row_descriptor_ | impala::ExecNode | protected |
ROW_THROUGHPUT_COUNTER | impala::ExecNode | static |
rows_returned() const | impala::ExecNode | inline |
rows_returned_counter_ | impala::ExecNode | protected |
rows_returned_rate_ | impala::ExecNode | protected |
runtime_exec_options_ | impala::ExecNode | protected |
runtime_profile() | impala::ExecNode | inline |
runtime_profile_ | impala::ExecNode | protected |
runtime_state_ | impala::PartitionedHashJoinNode | private |
semi_join_staging_row_ | impala::BlockingJoinNode | protected |
SetDebugOptions(int node_id, TExecNodePhase::type phase, TDebugAction::type action, ExecNode *tree) | impala::ExecNode | static |
spilled_partitions_ | impala::PartitionedHashJoinNode | private |
SpillPartition(Partition **spilled_partition) | impala::PartitionedHashJoinNode | private |
State enum name | impala::PartitionedHashJoinNode | private |
state_ | impala::PartitionedHashJoinNode | private |
status_ | impala::PartitionedHashJoinNode | private |
type() const | impala::ExecNode | inline |
type_ | impala::ExecNode | protected |
UpdateState(State s) | impala::PartitionedHashJoinNode | private |
using_small_buffers_ | impala::PartitionedHashJoinNode | private |
~BlockingJoinNode() | impala::BlockingJoinNode | virtual |
~ExecNode() | impala::ExecNode | virtual |