fix ABFS API change

Signed-off-by: Yuan Zhou <[email protected]>
apache · Nov 19, 2024 · 2987c5c · 2987c5c
1 parent a5ce606
commit 2987c5c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/cpp/velox/compute/VeloxBackend.cc b/cpp/velox/compute/VeloxBackend.cc
@@ -145,7 +145,7 @@ void VeloxBackend::init(const std::unordered_map<std::string, std::string>& conf
   velox::filesystems::registerGcsFileSystem();
 #endif
 #ifdef ENABLE_ABFS
-  velox::filesystems::abfs::registerAbfsFileSystem();
+  velox::filesystems::registerAbfsFileSystem();
 #endif
 
   initJolFilesystem();

diff --git a/cpp/velox/operators/writer/VeloxParquetDataSourceABFS.h b/cpp/velox/operators/writer/VeloxParquetDataSourceABFS.h
@@ -46,7 +46,7 @@ class VeloxParquetDataSourceABFS final : public VeloxParquetDataSource {
     auto hiveConf = getHiveConfig(std::make_shared<facebook::velox::config::ConfigBase>(
         std::unordered_map<std::string, std::string>(sparkConfs)));
     auto fileSystem = filesystems::getFileSystem(filePath_, hiveConf);
-    auto* abfsFileSystem = dynamic_cast<filesystems::abfs::AbfsFileSystem*>(fileSystem.get());
+    auto* abfsFileSystem = dynamic_cast<filesystems::AbfsFileSystem*>(fileSystem.get());
     sink_ = std::make_unique<dwio::common::WriteFileSink>(
         abfsFileSystem->openFileForWrite(filePath_, {{}, sinkPool_.get()}), filePath_);
   }