| 459 | } |
| 460 | |
| 461 | HdfsScanNodeBase::HdfsScanNodeBase(ObjectPool* pool, const HdfsScanPlanNode& pnode, |
| 462 | const THdfsScanNode& hdfs_scan_node, const DescriptorTbl& descs) |
| 463 | : ScanNode(pool, pnode, descs), |
| 464 | stats_tuple_id_( |
| 465 | hdfs_scan_node.__isset.stats_tuple_id ? hdfs_scan_node.stats_tuple_id : -1), |
| 466 | stats_conjuncts_(pnode.stats_conjuncts_), |
| 467 | stats_tuple_desc_( |
| 468 | stats_tuple_id_ == -1 ? nullptr : descs.GetTupleDescriptor(stats_tuple_id_)), |
| 469 | skip_header_line_count_(hdfs_scan_node.__isset.skip_header_line_count ? |
| 470 | hdfs_scan_node.skip_header_line_count : |
| 471 | 0), |
| 472 | tuple_id_(pnode.tuple_id_), |
| 473 | count_star_slot_offset_(hdfs_scan_node.__isset.count_star_slot_offset ? |
| 474 | hdfs_scan_node.count_star_slot_offset : |
| 475 | -1), |
| 476 | is_partition_key_scan_(hdfs_scan_node.is_partition_key_scan), |
| 477 | tuple_desc_(pnode.tuple_desc_), |
| 478 | hdfs_table_(pnode.hdfs_table_), |
| 479 | avro_schema_(*pnode.avro_schema_.get()), |
| 480 | conjuncts_map_(pnode.conjuncts_map_), |
| 481 | thrift_dict_filter_conjuncts_map_(hdfs_scan_node.__isset.dictionary_filter_conjuncts ? |
| 482 | &hdfs_scan_node.dictionary_filter_conjuncts : |
| 483 | nullptr), |
| 484 | codegend_fn_map_(pnode.codegend_fn_map_), |
| 485 | is_materialized_col_(pnode.is_materialized_col_), |
| 486 | materialized_slots_(pnode.materialized_slots_), |
| 487 | partition_key_slots_(pnode.partition_key_slots_), |
| 488 | virtual_column_slots_(pnode.virtual_column_slots_), |
| 489 | disks_accessed_bitmap_(TUnit::UNIT, 0), |
| 490 | active_hdfs_read_thread_counter_(TUnit::UNIT, 0), |
| 491 | shared_state_(const_cast<ScanRangeSharedState*>(&(pnode.shared_state_))), |
| 492 | deterministic_scanrange_assignment_( |
| 493 | hdfs_scan_node.deterministic_scanrange_assignment), |
| 494 | file_metadata_utils_(this) {} |
| 495 | |
| 496 | HdfsScanNodeBase::~HdfsScanNodeBase() {} |
| 497 |
nothing calls this directly
no test coverage detected