From ba31545de32be3720823916d25c1674aab86073c Mon Sep 17 00:00:00 2001 From: Chengcheng Jin Date: Thu, 15 Aug 2024 16:04:59 +0000 Subject: [PATCH] fix compile --- cpp/velox/operators/writer/VeloxParquetDatasourceABFS.h | 4 ++-- cpp/velox/operators/writer/VeloxParquetDatasourceHDFS.h | 4 ++-- cpp/velox/operators/writer/VeloxParquetDatasourceS3.h | 4 ++-- 3 files changed, 6 insertions(+), 6 deletions(-) diff --git a/cpp/velox/operators/writer/VeloxParquetDatasourceABFS.h b/cpp/velox/operators/writer/VeloxParquetDatasourceABFS.h index ee54865ff66c..b542e42babd4 100644 --- a/cpp/velox/operators/writer/VeloxParquetDatasourceABFS.h +++ b/cpp/velox/operators/writer/VeloxParquetDatasourceABFS.h @@ -43,8 +43,8 @@ class VeloxParquetDatasourceABFS final : public VeloxParquetDatasource { : VeloxParquetDatasource(filePath, veloxPool, sinkPool, schema) {} void initSink(const std::unordered_map& sparkConfs) override { - auto hiveConf = getHiveConfig( - std::make_shared(std::unordered_map(confMap_))); + auto hiveConf = getHiveConfig(std::make_shared( + std::unordered_map(sparkConfs))); auto fileSystem = filesystems::getFileSystem(filePath_, hiveConf); auto* abfsFileSystem = dynamic_cast(fileSystem.get()); sink_ = std::make_unique( diff --git a/cpp/velox/operators/writer/VeloxParquetDatasourceHDFS.h b/cpp/velox/operators/writer/VeloxParquetDatasourceHDFS.h index a91377a32ec3..19e9e3560648 100644 --- a/cpp/velox/operators/writer/VeloxParquetDatasourceHDFS.h +++ b/cpp/velox/operators/writer/VeloxParquetDatasourceHDFS.h @@ -43,8 +43,8 @@ class VeloxParquetDatasourceHDFS final : public VeloxParquetDatasource { : VeloxParquetDatasource(filePath, veloxPool, sinkPool, schema) {} void initSink(const std::unordered_map& sparkConfs) override { - auto hiveConf = getHiveConfig( - std::make_shared(std::unordered_map(confMap_))); + auto hiveConf = getHiveConfig(std::make_shared( + std::unordered_map(sparkConfs))); sink_ = dwio::common::FileSink::create(filePath_, {.connectorProperties = hiveConf, .pool = sinkPool_.get()}); } }; diff --git a/cpp/velox/operators/writer/VeloxParquetDatasourceS3.h b/cpp/velox/operators/writer/VeloxParquetDatasourceS3.h index 26928b297571..8219fe42a3c4 100644 --- a/cpp/velox/operators/writer/VeloxParquetDatasourceS3.h +++ b/cpp/velox/operators/writer/VeloxParquetDatasourceS3.h @@ -43,8 +43,8 @@ class VeloxParquetDatasourceS3 final : public VeloxParquetDatasource { : VeloxParquetDatasource(filePath, veloxPool, sinkPool, schema) {} void initSink(const std::unordered_map& sparkConfs) override { - auto hiveConf = getHiveConfig( - std::make_shared(std::unordered_map(confMap_))); + auto hiveConf = getHiveConfig(std::make_shared( + std::unordered_map(sparkConfs))); sink_ = dwio::common::FileSink::create(filePath_, {.connectorProperties = hiveConf, .pool = sinkPool_.get()}); } };