MCPcopy Create free account
hub / github.com/apache/impala / HdfsScanner

Method HdfsScanner

be/src/exec/hdfs-scanner.cc:51–65  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

49const char* HdfsScanner::LLVM_CLASS_NAME = "class.impala::HdfsScanner";
50
51HdfsScanner::HdfsScanner(HdfsScanNodeBase* scan_node, RuntimeState* state)
52 : scan_node_(scan_node),
53 state_(state),
54 file_metadata_utils_(scan_node),
55 expr_perm_pool_(new MemPool(scan_node->expr_mem_tracker())),
56 template_tuple_pool_(new MemPool(scan_node->mem_tracker())),
57 tuple_byte_size_(scan_node->tuple_desc()->byte_size()),
58 data_buffer_pool_(new MemPool(scan_node->mem_tracker())) {
59 DCHECK_EQ(1, scan_node->row_desc()->tuple_descriptors().size())
60 << "All HDFS scanners assume one tuple per row";
61 for (SlotDescriptor* string_slot : scan_node_->tuple_desc()->string_slots()) {
62 string_slot_offsets_.push_back(
63 {string_slot->null_indicator_offset(), string_slot->tuple_offset()});
64 }
65}
66
67HdfsScanner::HdfsScanner()
68 : scan_node_(nullptr),

Callers

nothing calls this directly

Calls 8

expr_mem_trackerMethod · 0.80
push_backMethod · 0.80
tuple_offsetMethod · 0.80
mem_trackerMethod · 0.45
byte_sizeMethod · 0.45
tuple_descMethod · 0.45
sizeMethod · 0.45
row_descMethod · 0.45

Tested by

no test coverage detected