| <map id="impala::ExecNode" name="impala::ExecNode"> |
| <area shape="rect" id="node2" href="$classimpala_1_1AggregationNode.html" title="{impala::AggregationNode\n|+ LLVM_CLASS_NAME\l- hash_tbl_\l- output_iterator_\l- aggregate_evaluators_\l- agg_fn_ctxs_\l- agg_fn_pool_\l- probe_expr_ctxs_\l- build_expr_ctxs_\l- intermediate_tuple_id_\l- intermediate_tuple\l_desc_\l- output_tuple_id_\land 10 more...\l|+ AggregationNode()\l+ Init()\l+ Prepare()\l+ Open()\l+ GetNext()\l+ Reset()\l+ Close()\l# DebugString()\l- ConstructIntermediateTuple()\l- UpdateTuple()\l- FinalizeTuple()\l- ProcessRowBatchNoGrouping()\l- ProcessRowBatchWithGrouping()\l- CodegenProcessRowBatch()\l- CodegenUpdateSlot()\l- CodegenUpdateTuple()\l}" alt="" coords="5,909,232,1382"/> |
| <area shape="rect" id="node3" href="$classimpala_1_1AnalyticEvalNode.html" title="{impala::AnalyticEvalNode\n|- window_\l- intermediate_tuple\l_desc_\l- result_tuple_desc_\l- buffered_tuple_desc_\l- child_tuple_cmp_row_\l- partition_by_eq_expr_ctx_\l- order_by_eq_expr_ctx_\l- fn_scope_\l- rows_start_offset_\l- rows_end_offset_\land 24 more...\l|+ AnalyticEvalNode()\l+ Init()\l+ Prepare()\l+ Open()\l+ GetNext()\l+ Reset()\l+ Close()\l# QueryMaintenance()\l# DebugString()\l- ProcessChildBatch()\l- ProcessChildBatches()\l- GetNextOutputBatch()\l- AddRow()\l- TryAddResultTupleForPrevRow()\l- TryAddResultTupleForCurrRow()\l- TryAddRemainingResults()\l- TryRemoveRowsBeforeWindow()\l- InitNextPartition()\l- AddResultTuple()\land 6 more...\l}" alt="" coords="257,887,481,1404"/> |
| <area shape="rect" id="node4" href="$classimpala_1_1BlockingJoinNode.html" title="{impala::BlockingJoinNode\n|+ LLVM_CLASS_NAME\l# node_name_\l# join_op_\l# eos_\l# build_pool_\l# probe_batch_\l# probe_side_eos_\l# probe_batch_pos_\l# current_probe_row_\l# matched_probe_\l# probe_tuple_row_size_\land 7 more...\l|+ BlockingJoinNode()\l+ ~BlockingJoinNode()\l+ Init()\l+ Prepare()\l+ Open()\l+ Reset()\l+ Close()\l# InitGetNext()\l# ConstructBuildSide()\l# AddToDebugString()\l# DebugString()\l# GetLeftChildRowString()\l# CreateOutputRow()\l- BuildSideThread()\l}" alt="" coords="506,931,680,1360"/> |
| <area shape="rect" id="node8" href="$classimpala_1_1EmptySetNode.html" title="{impala::EmptySetNode\n||+ EmptySetNode()\l+ GetNext()\l}" alt="" coords="705,1099,863,1191"/> |
| <area shape="rect" id="node9" href="$classimpala_1_1ExchangeNode.html" title="{impala::ExchangeNode\n|- num_senders_\l- stream_recvr_\l- input_row_desc_\l- input_batch_\l- next_row_idx_\l- convert_row_batch_timer_\l- is_merging_\l- sort_exec_exprs_\l- is_asc_order_\l- nulls_first_\l- offset_\l- num_rows_skipped_\l|+ ExchangeNode()\l+ Init()\l+ Prepare()\l+ Open()\l+ GetNext()\l+ Reset()\l+ Close()\l+ set_num_senders()\l# DebugString()\l- GetNextMerging()\l- FillInputRowBatch()\l}" alt="" coords="887,953,1069,1338"/> |
| <area shape="rect" id="node10" href="$classimpala_1_1PartitionedAggregationNode.html" title="{impala::PartitionedAggregationNode\n|+ LLVM_CLASS_NAME\l- intermediate_tuple_id_\l- intermediate_tuple\l_desc_\l- intermediate_row_desc_\l- output_tuple_id_\l- output_tuple_desc_\l- needs_finalize_\l- needs_serialize_\l- aggregate_evaluators_\l- agg_fn_ctxs_\l- agg_fn_pool_\land 27 more...\l- PARTITION_FANOUT\l- NUM_PARTITIONING_BITS\l- MAX_PARTITION_DEPTH\l|+ PartitionedAggregationNode()\l+ Init()\l+ Prepare()\l+ Open()\l+ GetNext()\l+ Reset()\l+ Close()\l+ ProcessBatch()\l# QueryMaintenance()\l# DebugString()\l- ConstructIntermediateTuple()\l- UpdateTuple()\l- GetOutputTuple()\l- ProcessBatchNoGrouping()\l- ProcessBatch()\l- ProcessStream()\l- CreateHashPartitions()\l- LargestSpilledPartition()\l- NextPartition()\l- SpillPartition()\land 8 more...\l}" alt="" coords="1094,850,1324,1441"/> |
| <area shape="rect" id="node11" href="$classimpala_1_1ScanNode.html" title="Abstract base class of all scan nodes; introduces SetScanRange(). " alt="" coords="1349,718,1620,1573"/> |
| <area shape="rect" id="node15" href="$classimpala_1_1SelectNode.html" title="{impala::SelectNode\n|- child_row_batch_\l- child_row_idx_\l- child_eos_\l|+ SelectNode()\l+ Prepare()\l+ Open()\l+ GetNext()\l+ Reset()\l+ Close()\l- CopyRows()\l}" alt="" coords="1645,1048,1780,1243"/> |
| <area shape="rect" id="node16" href="$classimpala_1_1SortNode.html" title="{impala::SortNode\n|- offset_\l- num_rows_skipped_\l- sorter_\l- sort_exec_exprs_\l- is_asc_order_\l- nulls_first_\l|+ SortNode()\l+ ~SortNode()\l+ Init()\l+ Prepare()\l+ Open()\l+ GetNext()\l+ Reset()\l+ Close()\l# DebugString()\l- SortInput()\l- CreateBlockMgr()\l}" alt="" coords="1805,997,1953,1294"/> |
| <area shape="rect" id="node17" href="$classimpala_1_1TopNNode.html" title="{impala::TopNNode\n|- offset_\l- num_rows_skipped_\l- sort_exec_exprs_\l- is_asc_order_\l- nulls_first_\l- materialized_tuple\l_desc_\l- tuple_row_less_than_\l- priority_queue_\l- sorted_top_n_\l- get_next_iter_\l- tuple_pool_\l- tmp_tuple_\l|+ TopNNode()\l+ Init()\l+ Prepare()\l+ Open()\l+ GetNext()\l+ Reset()\l+ Close()\l# DebugString()\l- InsertTupleRow()\l- PrepareForOutput()\l}" alt="" coords="1979,953,2135,1338"/> |
| <area shape="rect" id="node18" href="$classimpala_1_1UnionNode.html" title="{impala::UnionNode\n|- tuple_id_\l- tuple_desc_\l- materialized_slots_\l- const_result_expr_ctx\l_lists_\l- const_result_expr_idx_\l- result_expr_ctx_lists_\l- child_idx_\l- child_row_batch_\l- child_eos_\l- child_row_idx_\l|+ UnionNode()\l+ Init()\l+ Prepare()\l+ Open()\l+ GetNext()\l+ Reset()\l+ Close()\l- OpenCurrentChild()\l- EvalAndMaterializeExprs()\l}" alt="" coords="2160,975,2344,1316"/> |
| <area shape="rect" id="node5" href="$classimpala_1_1CrossJoinNode.html" title="{impala::CrossJoinNode\n|- build_batch_pool_\l- build_batches_\l- current_build_row_\l|+ CrossJoinNode()\l+ Prepare()\l+ GetNext()\l+ Reset()\l+ Close()\l# InitGetNext()\l# ConstructBuildSide()\l- ProcessLeftChildBatch()\l- BuildListDebugString()\l}" alt="" coords="294,1797,465,2021"/> |
| <area shape="rect" id="node6" href="$classimpala_1_1HashJoinNode.html" title="{impala::HashJoinNode\n|+ LLVM_CLASS_NAME\l- hash_tbl_\l- hash_tbl_iterator_\l- probe_expr_ctxs_\l- build_expr_ctxs_\l- other_join_conjunct\l_ctxs_\l- match_all_probe_\l- match_one_build_\l- match_all_build_\l- codegen_process_build\l_batch_fn_\l- process_build_batch_fn_\l- process_probe_batch_fn_\l- build_buckets_counter_\l- hash_tbl_load_factor\l_counter_\l|+ HashJoinNode()\l+ Init()\l+ Prepare()\l+ GetNext()\l+ Reset()\l+ Close()\l# AddToDebugString()\l# InitGetNext()\l# ConstructBuildSide()\l- LeftJoinGetNext()\l- ProcessProbeBatch()\l- ProcessBuildBatch()\l- CodegenCreateOutputRow()\l- CodegenProcessBuildBatch()\l- CodegenProcessProbeBatch()\l}" alt="" coords="490,1651,696,2168"/> |
| <area shape="rect" id="node7" href="$classimpala_1_1PartitionedHashJoinNode.html" title="{impala::PartitionedHashJoinNode\n|- runtime_state_\l- probe_expr_ctxs_\l- build_expr_ctxs_\l- other_join_conjunct\l_ctxs_\l- using_small_buffers_\l- state_\l- status_\l- block_mgr_client_\l- ht_ctx_\l- hash_tbl_iterator_\land 26 more...\l- PARTITION_FANOUT\l- NUM_PARTITIONING_BITS\l- MAX_PARTITION_DEPTH\l- MAX_IN_MEM_BUILD_TABLES\l|+ PartitionedHashJoinNode()\l+ Init()\l+ Prepare()\l+ GetNext()\l+ Reset()\l+ Close()\l# AddToDebugString()\l# InitGetNext()\l# ConstructBuildSide()\l- AppendRow()\l- AppendRowStreamFull()\l- SpillPartition()\l- ProcessBuildInput()\l- ProcessBuildBatch()\l- BuildHashTables()\l- ProcessProbeBatch()\l- ProcessProbeBatch()\l- OutputUnmatchedBuild()\l- PrepareNullAwarePartition()\land 20 more...\l}" alt="" coords="721,1621,943,2197"/> |
| <area shape="rect" id="node12" href="$classimpala_1_1DataSourceScanNode.html" title="{impala::DataSourceScanNode\n|- data_source_executor_\l- data_src_node_\l- tuple_desc_\l- tuple_idx_\l- tuple_\l- materialized_slots_\l- scan_handle_\l- input_batch_\l- num_rows_\l- next_row_idx_\l- cols_next_val_idx_\l|+ DataSourceScanNode()\l+ ~DataSourceScanNode()\l+ Prepare()\l+ Open()\l+ GetNext()\l+ Reset()\l+ Close()\l# DebugString()\l- MaterializeNextRow()\l- GetNextInputBatch()\l- ValidateRowBatchSize()\l- InputBatchHasNext()\l}" alt="" coords="1169,1717,1367,2102"/> |
| <area shape="rect" id="node13" href="$classimpala_1_1HBaseScanNode.html" title="{impala::HBaseScanNode\n|- table_name_\l- tuple_id_\l- tuple_desc_\l- tuple_idx_\l- scan_range_vector_\l- filters_\l- num_errors_\l- tuple_pool_\l- hbase_scanner_\l- sorted_non_key_slots_\land 7 more...\l- SKIP_COLUMN\l- ROW_KEY\l|+ HBaseScanNode()\l+ ~HBaseScanNode()\l+ Prepare()\l+ Open()\l+ GetNext()\l+ Reset()\l+ Close()\l+ suggested_max_caching()\l# DebugString()\l- WriteTextSlot()\l- CmpColPos()\l}" alt="" coords="1392,1709,1579,2109"/> |
| <area shape="rect" id="node14" href="$classimpala_1_1HdfsScanNode.html" title="{impala::HdfsScanNode\n|+ SKIP_COLUMN\l+ HDFS_SPLIT_STATS_DESC\l- thrift_plan_node_\l- runtime_state_\l- tuple_id_\l- reader_context_\l- tuple_desc_\l- hdfs_table_\l- unknown_disk_id_warned_\l- partition_ids_\l- file_descs_\l- per_type_files_\land 36 more...\l|+ HdfsScanNode()\l+ ~HdfsScanNode()\l+ Prepare()\l+ Open()\l+ GetNext()\l+ Reset()\l+ Close()\l+ limit()\l+ materialized_slots()\l+ tuple_idx()\land 27 more...\l+ UpdateHdfsSplitStats()\l+ PrintHdfsSplitStats()\l- ThreadTokenAvailableCb()\l- CreateAndPrepareScanner()\l- ScannerThread()\l- EnoughMemoryForScannerThread()\l- GetNextInternal()\l- SetDone()\l- StopAndFinalizeCounters()\l}" alt="" coords="1603,1643,1839,2175"/> |
| </map> |
