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

This is the complete list of members for impala::PartitionedHashJoinNode, 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
AddToDebugString(int indentation_level, std::stringstream *out) const impala::PartitionedHashJoinNodeprotectedvirtual
AllocateProbeFilters(RuntimeState *state)impala::PartitionedHashJoinNodeprivate
AppendRow(BufferedTupleStream *stream, TupleRow *row)impala::PartitionedHashJoinNodeinlineprivate
AppendRowStreamFull(BufferedTupleStream *stream, TupleRow *row)impala::PartitionedHashJoinNodeprivate
AttachProbeFilters(RuntimeState *state)impala::PartitionedHashJoinNodeprivate
block_mgr_client_impala::PartitionedHashJoinNodeprivate
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::PartitionedHashJoinNodeprivate
build_pool_impala::BlockingJoinNodeprotected
build_row_counter_impala::BlockingJoinNodeprotected
build_timer_impala::BlockingJoinNodeprotected
build_tuple_row_size_impala::BlockingJoinNodeprotected
BuildHashTables(RuntimeState *state)impala::PartitionedHashJoinNodeprivate
can_add_probe_filters_impala::BlockingJoinNodeprotected
child(int i)impala::ExecNodeinlineprotected
children_impala::ExecNodeprotected
CleanUpHashPartitions(RowBatch *batch)impala::PartitionedHashJoinNodeprivate
Close(RuntimeState *state)impala::PartitionedHashJoinNodevirtual
CodegenCreateOutputRow(LlvmCodeGen *codegen)impala::PartitionedHashJoinNodeprivate
CodegenEvalConjuncts(RuntimeState *state, const std::vector< ExprContext * > &conjunct_ctxs, const char *name="EvalConjuncts")impala::ExecNodestatic
CodegenProcessBuildBatch(RuntimeState *state, llvm::Function *hash_fn, llvm::Function *murmur_hash_fn)impala::PartitionedHashJoinNodeprivate
CodegenProcessProbeBatch(RuntimeState *state, llvm::Function *hash_fn, llvm::Function *murmur_hash_fn)impala::PartitionedHashJoinNodeprivate
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
ConstructBuildSide(RuntimeState *state)impala::PartitionedHashJoinNodeprotectedvirtual
CreateNode(ObjectPool *pool, const TPlanNode &tnode, const DescriptorTbl &descs, ExecNode **node)impala::ExecNodeprotectedstatic
CreateOutputRow(TupleRow *out_row, TupleRow *probe_row, TupleRow *build_row)impala::BlockingJoinNodeprotected
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
current_probe_row_impala::BlockingJoinNodeprotected
debug_action_impala::ExecNodeprotected
debug_phase_impala::ExecNodeprotected
DebugString(int indentation_level, std::stringstream *out) const impala::BlockingJoinNodeprotectedvirtual
impala::ExecNode::DebugString() const impala::ExecNode
eos_impala::BlockingJoinNodeprotected
EvalConjuncts(ExprContext *const *ctxs, int num_ctxs, TupleRow *row)impala::ExecNodestatic
EvaluateNullProbe(BufferedTupleStream *build)impala::PartitionedHashJoinNodeprivate
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
GetLeftChildRowString(TupleRow *row)impala::BlockingJoinNodeprotected
GetNext(RuntimeState *state, RowBatch *row_batch, bool *eos)impala::PartitionedHashJoinNodevirtual
GetNodeIdFromProfile(RuntimeProfile *p)impala::ExecNodestatic
hash_partitions_impala::PartitionedHashJoinNodeprivate
hash_tbl_iterator_impala::PartitionedHashJoinNodeprivate
hash_tbls_impala::PartitionedHashJoinNodeprivate
ht_ctx_impala::PartitionedHashJoinNodeprivate
id() const impala::ExecNodeinline
id_impala::ExecNodeprotected
Init(const TPlanNode &tnode)impala::PartitionedHashJoinNodevirtual
InitGetNext(TupleRow *first_probe_row)impala::PartitionedHashJoinNodeprotectedvirtual
InitRuntimeProfile(const std::string &name)impala::ExecNodeprotected
input_partition_impala::PartitionedHashJoinNodeprivate
is_closed()impala::ExecNodeinlineprotected
IsScanNode() const impala::ExecNodeinlineprotectedvirtual
join_op_impala::BlockingJoinNodeprotected
largest_partition_percent_impala::PartitionedHashJoinNodeprivate
LargestSpilledPartition() const impala::PartitionedHashJoinNodeprivate
limit() const impala::ExecNodeinline
limit_impala::ExecNodeprotected
LLVM_CLASS_NAMEimpala::BlockingJoinNodestatic
matched_null_probe_impala::PartitionedHashJoinNodeprivate
matched_probe_impala::BlockingJoinNodeprotected
MAX_IN_MEM_BUILD_TABLESimpala::PartitionedHashJoinNodeprivatestatic
MAX_PARTITION_DEPTHimpala::PartitionedHashJoinNodeprivatestatic
max_partition_level_impala::PartitionedHashJoinNodeprivate
mem_tracker()impala::ExecNodeinline
mem_tracker_impala::ExecNodeprotected
MinRequiredBuffers() const impala::PartitionedHashJoinNodeinlineprivate
NextProbeRowBatch(RuntimeState *, RowBatch *out_batch)impala::PartitionedHashJoinNodeprivate
NextSpilledProbeRowBatch(RuntimeState *, RowBatch *out_batch)impala::PartitionedHashJoinNodeprivate
node_name_impala::BlockingJoinNodeprotected
NodeDebugString() const impala::PartitionedHashJoinNodeprivate
non_empty_build_impala::PartitionedHashJoinNodeprivate
null_aware_eval_timer_impala::PartitionedHashJoinNodeprivate
null_aware_partition_impala::PartitionedHashJoinNodeprivate
null_probe_output_idx_impala::PartitionedHashJoinNodeprivate
null_probe_rows_impala::PartitionedHashJoinNodeprivate
nulls_build_batch_impala::PartitionedHashJoinNodeprivate
num_build_rows_partitioned_impala::PartitionedHashJoinNodeprivate
num_hash_buckets_impala::PartitionedHashJoinNodeprivate
NUM_PARTITIONING_BITSimpala::PartitionedHashJoinNodeprivatestatic
num_probe_rows_partitioned_impala::PartitionedHashJoinNodeprivate
num_repartitions_impala::PartitionedHashJoinNodeprivate
num_rows_returned_impala::ExecNodeprotected
num_spilled_partitions_impala::PartitionedHashJoinNodeprivate
Open(RuntimeState *state)impala::BlockingJoinNodevirtual
other_join_conjunct_ctxs_impala::PartitionedHashJoinNodeprivate
output_build_partitions_impala::PartitionedHashJoinNodeprivate
OutputNullAwareNullProbe(RuntimeState *state, RowBatch *out_batch)impala::PartitionedHashJoinNodeprivate
OutputNullAwareProbeRows(RuntimeState *state, RowBatch *out_batch)impala::PartitionedHashJoinNodeprivate
OutputUnmatchedBuild(RowBatch *out_batch)impala::PartitionedHashJoinNodeprivate
partition_build_timer_impala::PartitionedHashJoinNodeprivate
PARTITION_FANOUTimpala::PartitionedHashJoinNodeprivatestatic
PartitionedHashJoinNode(ObjectPool *pool, const TPlanNode &tnode, const DescriptorTbl &descs)impala::PartitionedHashJoinNode
PARTITIONING_BUILD enum valueimpala::PartitionedHashJoinNodeprivate
partitions_created_impala::PartitionedHashJoinNodeprivate
pool_impala::ExecNodeprotected
Prepare(RuntimeState *state)impala::PartitionedHashJoinNodevirtual
PrepareNextPartition(RuntimeState *)impala::PartitionedHashJoinNodeprivate
PrepareNullAwareNullProbe()impala::PartitionedHashJoinNodeprivate
PrepareNullAwarePartition()impala::PartitionedHashJoinNodeprivate
PrintState() const impala::PartitionedHashJoinNodeprivate
probe_batch_impala::BlockingJoinNodeprotected
probe_batch_pos_impala::BlockingJoinNodeprotected
probe_expr_ctxs_impala::PartitionedHashJoinNodeprivate
probe_filters_impala::PartitionedHashJoinNodeprivate
probe_row_counter_impala::BlockingJoinNodeprotected
probe_side_eos_impala::BlockingJoinNodeprotected
probe_timer_impala::BlockingJoinNodeprotected
probe_tuple_row_size_impala::BlockingJoinNodeprotected
PROBING_SPILLED_PARTITION enum valueimpala::PartitionedHashJoinNodeprivate
process_build_batch_fn_impala::PartitionedHashJoinNodeprivate
process_build_batch_fn_level0_impala::PartitionedHashJoinNodeprivate
process_probe_batch_fn_impala::PartitionedHashJoinNodeprivate
process_probe_batch_fn_level0_impala::PartitionedHashJoinNodeprivate
ProcessBuildBatch(RowBatch *build_batch)impala::PartitionedHashJoinNodeprivate
ProcessBuildBatchFn typedefimpala::PartitionedHashJoinNodeprivate
ProcessBuildInput(RuntimeState *state, int level)impala::PartitionedHashJoinNodeprivate
PROCESSING_PROBE enum valueimpala::PartitionedHashJoinNodeprivate
ProcessProbeBatch(RowBatch *out_batch, HashTableCtx *ht_ctx)impala::PartitionedHashJoinNodeprivate
ProcessProbeBatch(const TJoinOp::type join_op, RowBatch *out_batch, HashTableCtx *ht_ctx)impala::PartitionedHashJoinNodeprivate
ProcessProbeBatchFn typedefimpala::PartitionedHashJoinNodeprivate
QueryMaintenance(RuntimeState *state)impala::ExecNodeprotectedvirtual
ReachedLimit()impala::ExecNodeinline
REPARTITIONING enum valueimpala::PartitionedHashJoinNodeprivate
ReserveTupleStreamBlocks()impala::PartitionedHashJoinNodeprivate
Reset(RuntimeState *state)impala::PartitionedHashJoinNodevirtual
ResetForProbe()impala::PartitionedHashJoinNodeinlineprivate
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
runtime_state_impala::PartitionedHashJoinNodeprivate
semi_join_staging_row_impala::BlockingJoinNodeprotected
SetDebugOptions(int node_id, TExecNodePhase::type phase, TDebugAction::type action, ExecNode *tree)impala::ExecNodestatic
spilled_partitions_impala::PartitionedHashJoinNodeprivate
SpillPartition(Partition **spilled_partition)impala::PartitionedHashJoinNodeprivate
State enum nameimpala::PartitionedHashJoinNodeprivate
state_impala::PartitionedHashJoinNodeprivate
status_impala::PartitionedHashJoinNodeprivate
type() const impala::ExecNodeinline
type_impala::ExecNodeprotected
UpdateState(State s)impala::PartitionedHashJoinNodeprivate
using_small_buffers_impala::PartitionedHashJoinNodeprivate
~BlockingJoinNode()impala::BlockingJoinNodevirtual
~ExecNode()impala::ExecNodevirtual