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

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

active_hdfs_read_thread_counter_impala::ScanNodeprotected
active_scanner_thread_counter()impala::ScanNodeinline
active_scanner_thread_counter_impala::ScanNodeprotected
AddDiskIoRanges(const std::vector< DiskIoMgr::ScanRange * > &ranges)impala::HdfsScanNode
AddDiskIoRanges(const HdfsFileDesc *file_desc)impala::HdfsScanNode
AddExprCtxsToFree(const std::vector< ExprContext * > &ctxs)impala::ExecNodeprotected
AddExprCtxsToFree(const SortExecExprs &sort_exec_exprs)impala::ExecNodeprotected
AddExprCtxToFree(ExprContext *ctx)impala::ExecNodeinlineprotected
AddMaterializedRowBatch(RowBatch *row_batch)impala::HdfsScanNode
AddRuntimeExecOption(const std::string &option)impala::ExecNodeprotected
all_ranges_started_impala::HdfsScanNodeprivate
AllocateScanRange(hdfsFS fs, const char *file, int64_t len, int64_t offset, int64_t partition_id, int disk_id, bool try_cache, bool expected_local, int64_t mtime)impala::HdfsScanNode
AVERAGE_HDFS_READ_THREAD_CONCURRENCYimpala::ScanNodestatic
average_hdfs_read_thread_concurrency_impala::ScanNodeprotected
average_scanner_thread_concurrency() const impala::ScanNodeinline
AVERAGE_SCANNER_THREAD_CONCURRENCYimpala::ScanNodestatic
average_scanner_thread_concurrency_impala::ScanNodeprotected
bytes_read_counter() const impala::ScanNodeinline
BYTES_READ_COUNTERimpala::ScanNodestatic
bytes_read_counter_impala::ScanNodeprotected
bytes_read_dn_cache_impala::HdfsScanNodeprivate
bytes_read_local_impala::HdfsScanNodeprivate
bytes_read_short_circuit_impala::HdfsScanNodeprivate
bytes_read_timeseries_counter_impala::ScanNodeprotected
child(int i)impala::ExecNodeinlineprotected
children_impala::ExecNodeprotected
Close(RuntimeState *state)impala::HdfsScanNodevirtual
codegend_fn_map_impala::HdfsScanNodeprivate
CodegendFnMap typedefimpala::HdfsScanNodeprivate
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
ComputeSlotMaterializationOrder(std::vector< int > *order) const impala::HdfsScanNode
conjunct_ctxs() const impala::ExecNodeinline
conjunct_ctxs_impala::HdfsScanNodeprivate
counters_running_impala::HdfsScanNodeprivate
CreateAndPrepareScanner(HdfsPartitionDescriptor *partition_desc, ScannerContext *context, Status *status)impala::HdfsScanNodeprivate
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() const impala::ExecNode
DebugString(int indentation_level, std::stringstream *out) const impala::ExecNodevirtual
disks_accessed_bitmap_impala::HdfsScanNodeprivate
done_impala::HdfsScanNodeprivate
EnoughMemoryForScannerThread(bool new_thread)impala::HdfsScanNodeprivate
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
file_descs_impala::HdfsScanNodeprivate
file_type_counts_impala::HdfsScanNodeprivate
file_type_counts_lock_impala::HdfsScanNodeprivate
FileDescMap typedefimpala::HdfsScanNodeprivate
FileFormatsMap typedefimpala::HdfsScanNodeprivate
FileTypeCountsMap typedefimpala::HdfsScanNodeprivate
GetCodegenFn(THdfsFileFormat::type)impala::HdfsScanNode
GetConjunctCtxs(std::vector< ExprContext * > *ctxs)impala::HdfsScanNode
GetFileDesc(const std::string &filename)impala::HdfsScanNode
GetFileMetadata(const std::string &filename)impala::HdfsScanNode
GetMaterializedSlotIdx(const std::vector< int > &path) const impala::HdfsScanNodeinline
GetNext(RuntimeState *state, RowBatch *row_batch, bool *eos)impala::HdfsScanNodevirtual
GetNextInternal(RuntimeState *state, RowBatch *row_batch, bool *eos)impala::HdfsScanNodeprivate
GetNodeIdFromProfile(RuntimeProfile *p)impala::ExecNodestatic
hdfs_read_thread_concurrency_bucket_impala::ScanNodeprotected
HDFS_SPLIT_STATS_DESCimpala::HdfsScanNodestatic
hdfs_table()impala::HdfsScanNodeinline
hdfs_table_impala::HdfsScanNodeprivate
HdfsScanNode(ObjectPool *pool, const TPlanNode &tnode, const DescriptorTbl &descs)impala::HdfsScanNode
id() const impala::ExecNodeinline
id_impala::ExecNodeprotected
IncNumScannersCodegenDisabled()impala::HdfsScanNodeinline
IncNumScannersCodegenEnabled()impala::HdfsScanNodeinline
Init(const TPlanNode &tnode)impala::ExecNodevirtual
InitEmptyTemplateTuple()impala::HdfsScanNode
initial_ranges_issued_impala::HdfsScanNodeprivate
InitRuntimeProfile(const std::string &name)impala::ExecNodeprotected
InitTemplateTuple(RuntimeState *state, const std::vector< ExprContext * > &value_ctxs)impala::HdfsScanNode
is_closed()impala::ExecNodeinlineprotected
is_materialized_col()impala::HdfsScanNodeinline
is_materialized_col_impala::HdfsScanNodeprivate
IsScanNode() const impala::ScanNodeinlinevirtual
limit() const impala::HdfsScanNodeinline
limit_impala::ExecNodeprotected
lock_impala::HdfsScanNodeprivate
MarkFileDescIssued(const HdfsFileDesc *file_desc)impala::HdfsScanNode
materialize_tuple_timer() const impala::ScanNodeinline
MATERIALIZE_TUPLE_TIMERimpala::ScanNodestatic
materialize_tuple_timer_impala::ScanNodeprotected
materialized_row_batches_impala::HdfsScanNodeprivate
materialized_slots() const impala::HdfsScanNodeinline
materialized_slots_impala::HdfsScanNodeprivate
max_compressed_text_file_length()impala::HdfsScanNodeinline
max_compressed_text_file_length_impala::HdfsScanNodeprivate
max_materialized_row_batches_impala::HdfsScanNodeprivate
mem_tracker()impala::ExecNodeinline
mem_tracker_impala::ExecNodeprotected
metadata_lock_impala::HdfsScanNodeprivate
NUM_DISKS_ACCESSED_COUNTERimpala::ScanNodestatic
num_disks_accessed_counter_impala::ScanNodeprotected
num_materialized_partition_keys() const impala::HdfsScanNodeinline
num_owned_io_buffers_impala::HdfsScanNodeprivate
num_partition_keys() const impala::HdfsScanNodeinline
num_remote_ranges_impala::HdfsScanNodeprivate
num_rows_returned_impala::ExecNodeprotected
NUM_SCANNER_THREADS_STARTEDimpala::ScanNodestatic
num_scanner_threads_started_counter_impala::ScanNodeprotected
num_scanners_codegen_disabled_impala::HdfsScanNodeprivate
num_scanners_codegen_enabled_impala::HdfsScanNodeprivate
num_skipped_tokens_impala::HdfsScanNodeprivate
num_unqueued_files_impala::HdfsScanNodeprivate
Open(RuntimeState *state)impala::HdfsScanNodevirtual
partition_ids_impala::HdfsScanNodeprivate
partition_key_slots_impala::HdfsScanNodeprivate
path_to_materialized_slot_idx_impala::HdfsScanNodeprivate
PathToSlotIdxMap typedefimpala::HdfsScanNodeprivate
per_file_metadata_impala::HdfsScanNodeprivate
per_read_thread_throughput_counter() const impala::ScanNodeinline
PER_READ_THREAD_THROUGHPUT_COUNTERimpala::ScanNodestatic
per_read_thread_throughput_counter_impala::ScanNodeprotected
per_type_files_impala::HdfsScanNodeprivate
PerVolumnStats typedefimpala::HdfsScanNode
pool_impala::ExecNodeprotected
Prepare(RuntimeState *state)impala::HdfsScanNodevirtual
PrintHdfsSplitStats(const PerVolumnStats &per_volume_stats, std::stringstream *ss)impala::HdfsScanNodestatic
progress_impala::HdfsScanNodeprivate
QueryMaintenance(RuntimeState *state)impala::ExecNodeprotectedvirtual
RangeComplete(const THdfsFileFormat::type &file_type, const THdfsCompression::type &compression_type)impala::HdfsScanNode
RangeComplete(const THdfsFileFormat::type &file_type, const std::vector< THdfsCompression::type > &compression_type)impala::HdfsScanNode
ReachedLimit()impala::ExecNodeinline
read_timer() const impala::ScanNodeinline
read_timer_impala::ScanNodeprotected
reader_context()impala::HdfsScanNodeinline
reader_context_impala::HdfsScanNodeprivate
Reset(RuntimeState *state)impala::HdfsScanNodevirtual
rm_callback_id_impala::HdfsScanNodeprivate
row_desc() const impala::ExecNodeinline
row_descriptor_impala::ExecNodeprotected
ROW_THROUGHPUT_COUNTERimpala::ExecNodestatic
rows_read_counter() const impala::ScanNodeinline
ROWS_READ_COUNTERimpala::ScanNodestatic
rows_read_counter_impala::ScanNodeprotected
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::HdfsScanNodeinline
runtime_state_impala::HdfsScanNodeprivate
scan_node_pool_impala::HdfsScanNodeprivate
scan_range_params_impala::ScanNodeprotected
SCAN_RANGES_COMPLETE_COUNTERimpala::ScanNodestatic
scan_ranges_complete_counter() const impala::ScanNodeinline
scan_ranges_complete_counter_impala::ScanNodeprotected
scanner_map_impala::HdfsScanNodeprivate
scanner_thread_bytes_required_impala::HdfsScanNodeprivate
scanner_thread_counters() const impala::ScanNodeinline
scanner_thread_counters_impala::ScanNodeprotected
SCANNER_THREAD_COUNTERS_PREFIXimpala::ScanNodestatic
SCANNER_THREAD_TOTAL_WALLCLOCK_TIMEimpala::ScanNodestatic
scanner_threads_impala::HdfsScanNodeprivate
ScannerContext classimpala::HdfsScanNodefriend
ScannerMap typedefimpala::HdfsScanNodeprivate
ScannerThread()impala::HdfsScanNodeprivate
ScanNode(ObjectPool *pool, const TPlanNode &tnode, const DescriptorTbl &descs)impala::ScanNodeinline
SetDebugOptions(int node_id, TExecNodePhase::type phase, TDebugAction::type action, ExecNode *tree)impala::ExecNodestatic
SetDone()impala::HdfsScanNodeprivate
SetFileMetadata(const std::string &filename, void *metadata)impala::HdfsScanNode
SetScanRanges(const std::vector< TScanRangeParams > &scan_range_params)impala::ScanNodeinline
SKIP_COLUMNimpala::HdfsScanNodestatic
status_impala::HdfsScanNodeprivate
StopAndFinalizeCounters()impala::HdfsScanNodeprivate
ThreadTokenAvailableCb(ThreadResourceMgr::ResourcePool *pool)impala::HdfsScanNodeprivate
thrift_plan_node_impala::HdfsScanNodeprivate
TOTAL_HBASE_READ_TIMERimpala::ScanNodestatic
TOTAL_HDFS_READ_TIMERimpala::ScanNodestatic
total_throughput_counter() const impala::ScanNodeinline
TOTAL_THROUGHPUT_COUNTERimpala::ScanNodestatic
total_throughput_counter_impala::ScanNodeprotected
TransferToScanNodePool(MemPool *pool)impala::HdfsScanNode
tuple_desc()impala::HdfsScanNodeinline
tuple_desc_impala::HdfsScanNodeprivate
tuple_id_impala::HdfsScanNodeprivate
tuple_idx() const impala::HdfsScanNodeinline
type() const impala::ExecNodeinline
type_impala::ExecNodeprotected
unexpected_remote_bytes_impala::HdfsScanNodeprivate
unknown_disk_id_warned_impala::HdfsScanNodeprivate
UpdateHdfsSplitStats(const std::vector< TScanRangeParams > &scan_range_params_list, PerVolumnStats *per_volume_stats)impala::HdfsScanNodestatic
~ExecNode()impala::ExecNodevirtual
~HdfsScanNode()impala::HdfsScanNode