| 275 | std::shared_ptr<::arrow::io::HadoopFileSystem> client_; |
| 276 | |
| 277 | void PathInfoToFileInfo(const io::HdfsPathInfo& info, FileInfo* out) { |
| 278 | if (info.kind == io::ObjectType::DIRECTORY) { |
| 279 | out->set_type(FileType::Directory); |
| 280 | out->set_size(kNoSize); |
| 281 | } else if (info.kind == io::ObjectType::FILE) { |
| 282 | out->set_type(FileType::File); |
| 283 | out->set_size(info.size); |
| 284 | } |
| 285 | out->set_mtime(ToTimePoint(info.last_modified_time)); |
| 286 | } |
| 287 | |
| 288 | Result<std::shared_ptr<io::OutputStream>> OpenOutputStreamGeneric( |
| 289 | const std::string& path, bool append) { |
nothing calls this directly
no test coverage detected