| 1763 | } |
| 1764 | |
| 1765 | void TScanRangeToScanRangePB(const TScanRange& tscan_range, ScanRangePB* scan_range_pb) { |
| 1766 | if (tscan_range.__isset.hdfs_file_split) { |
| 1767 | HdfsFileSplitPB* hdfs_file_split = scan_range_pb->mutable_hdfs_file_split(); |
| 1768 | hdfs_file_split->set_relative_path(tscan_range.hdfs_file_split.relative_path); |
| 1769 | hdfs_file_split->set_offset(tscan_range.hdfs_file_split.offset); |
| 1770 | hdfs_file_split->set_length(tscan_range.hdfs_file_split.length); |
| 1771 | hdfs_file_split->set_partition_id(tscan_range.hdfs_file_split.partition_id); |
| 1772 | hdfs_file_split->set_file_length(tscan_range.hdfs_file_split.file_length); |
| 1773 | hdfs_file_split->set_file_compression( |
| 1774 | THdfsCompressionToProto(tscan_range.hdfs_file_split.file_compression)); |
| 1775 | hdfs_file_split->set_mtime(tscan_range.hdfs_file_split.mtime); |
| 1776 | hdfs_file_split->set_partition_path_hash( |
| 1777 | tscan_range.hdfs_file_split.partition_path_hash); |
| 1778 | hdfs_file_split->set_is_encrypted(tscan_range.hdfs_file_split.is_encrypted); |
| 1779 | hdfs_file_split->set_is_erasure_coded(tscan_range.hdfs_file_split.is_erasure_coded); |
| 1780 | if (tscan_range.hdfs_file_split.__isset.absolute_path) { |
| 1781 | hdfs_file_split->set_absolute_path( |
| 1782 | tscan_range.hdfs_file_split.absolute_path); |
| 1783 | } |
| 1784 | } |
| 1785 | if (tscan_range.__isset.hbase_key_range) { |
| 1786 | HBaseKeyRangePB* hbase_key_range = scan_range_pb->mutable_hbase_key_range(); |
| 1787 | hbase_key_range->set_startkey(tscan_range.hbase_key_range.startKey); |
| 1788 | hbase_key_range->set_stopkey(tscan_range.hbase_key_range.stopKey); |
| 1789 | } |
| 1790 | if (tscan_range.__isset.kudu_scan_token) { |
| 1791 | scan_range_pb->set_kudu_scan_token(tscan_range.kudu_scan_token); |
| 1792 | } |
| 1793 | if (tscan_range.__isset.file_metadata) { |
| 1794 | scan_range_pb->set_file_metadata(tscan_range.file_metadata); |
| 1795 | } |
| 1796 | if (tscan_range.__isset.is_system_scan) { |
| 1797 | scan_range_pb->set_is_system_scan(tscan_range.is_system_scan); |
| 1798 | } |
| 1799 | if (tscan_range.__isset.iceberg_deletion_vector) { |
| 1800 | scan_range_pb->set_iceberg_deletion_vector(tscan_range.iceberg_deletion_vector); |
| 1801 | } |
| 1802 | } |
| 1803 | |
| 1804 | void Scheduler::AssignmentCtx::RecordScanRangeAssignment( |
| 1805 | const BackendDescriptorPB& executor, PlanNodeId node_id, |
no test coverage detected