| 288 | } |
| 289 | |
| 290 | bool IcebergMergeNode::IsDuplicateTargetRowIdent(TupleRow* actual_row) { |
| 291 | auto file_path_sv = row_meta_evaluators_[0]->GetStringVal(actual_row); |
| 292 | auto file_pos = row_meta_evaluators_[1]->GetBigIntVal(actual_row); |
| 293 | if (previous_row_file_pos_ != file_pos.val) { return false; } |
| 294 | auto file_path = |
| 295 | std::string_view(reinterpret_cast<const char*>(file_path_sv.ptr), file_path_sv.len); |
| 296 | return file_path == previous_row_file_path_; |
| 297 | } |
| 298 | |
| 299 | void IcebergMergeNode::SavePreviousRowPtrAndIdent(TupleRow* actual_row) { |
| 300 | impala_udf::StringVal file_path_sv = |
nothing calls this directly
no test coverage detected