MCPcopy Create free account
hub / github.com/apache/arrow / DeleteDirContentsAsync

Method DeleteDirContentsAsync

cpp/src/arrow/filesystem/s3fs.cc:2955–2965  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

2953 }
2954
2955 Future<> DeleteDirContentsAsync(const std::string& bucket, const std::string& key) {
2956 auto self = shared_from_this();
2957 return EnsureIsDirAsync(bucket, key)
2958 .Then([self, bucket, key](bool is_dir) -> Future<> {
2959 if (!is_dir) {
2960 return Status::IOError("Cannot delete directory contents at ", bucket, kSep,
2961 key, " because it is a file");
2962 }
2963 return self->DoDeleteDirContentsAsync(bucket, key);
2964 });
2965 }
2966
2967 FileInfoGenerator GetFileInfoGenerator(const FileSelector& select) {
2968 auto maybe_base_path = S3Path::FromString(select.base_dir);

Callers

nothing calls this directly

Calls 3

IOErrorFunction · 0.85
ThenMethod · 0.80

Tested by

no test coverage detected