| 83 | } |
| 84 | |
| 85 | Status TableSinkBase::ClosePartitionFile( |
| 86 | RuntimeState* state, OutputPartition* partition) { |
| 87 | if (partition->tmp_hdfs_file == nullptr) return Status::OK(); |
| 88 | int hdfs_ret = hdfsCloseFile(partition->hdfs_connection, partition->tmp_hdfs_file); |
| 89 | VLOG_FILE << "hdfsCloseFile() file=" << partition->current_file_name; |
| 90 | partition->tmp_hdfs_file = nullptr; |
| 91 | ImpaladMetrics::NUM_FILES_OPEN_FOR_INSERT->Increment(-1); |
| 92 | if (hdfs_ret != 0) { |
| 93 | return Status(ErrorMsg(TErrorCode::GENERAL, |
| 94 | GetHdfsErrorMsg("Failed to close HDFS file: ", |
| 95 | partition->current_file_name))); |
| 96 | } |
| 97 | return Status::OK(); |
| 98 | } |
| 99 | |
| 100 | string TableSinkBase::GetPartitionName(int i) { |
| 101 | if (IsIceberg()) { |
nothing calls this directly
no test coverage detected