[native] Refactor PrestoToVeloxConnector for modularity

prestodb · Oct 30, 2024 · acd4f3b · acd4f3b
1 parent 1c0fc17
commit acd4f3b
Show file tree

Hide file tree

Showing 14 changed files with 1,725 additions and 1,588 deletions.
diff --git a/presto-native-execution/presto_cpp/main/PrestoServer.cpp b/presto-native-execution/presto_cpp/main/PrestoServer.cpp
@@ -36,7 +36,10 @@
 #include "presto_cpp/main/operators/ShuffleRead.h"
 #include "presto_cpp/main/operators/UnsafeRowExchangeSource.h"
 #include "presto_cpp/main/types/FunctionMetadata.h"
+#include "presto_cpp/main/types/HivePrestoToVeloxConnector.h"
+#include "presto_cpp/main/types/IcebergPrestoToVeloxConnector.h"
 #include "presto_cpp/main/types/PrestoToVeloxQueryPlan.h"
+#include "presto_cpp/main/types/TpchPrestoToVeloxConnector.h"
 #include "velox/common/base/Counters.h"
 #include "velox/common/base/StatsReporter.h"
 #include "velox/common/caching/CacheTTLController.h"

diff --git a/presto-native-execution/presto_cpp/main/tests/TaskManagerTest.cpp b/presto-native-execution/presto_cpp/main/tests/TaskManagerTest.cpp
@@ -21,6 +21,7 @@
 #include "presto_cpp/main/tests/HttpServerWrapper.h"
 #include "presto_cpp/main/tests/MultableConfigs.h"
 #include "presto_cpp/main/types/PrestoToVeloxConnector.h"
+#include "presto_cpp/main/types/HivePrestoToVeloxConnector.h"
 #include "velox/common/base/Fs.h"
 #include "velox/common/base/tests/GTestUtils.h"
 #include "velox/common/file/FileSystems.h"

diff --git a/presto-native-execution/presto_cpp/main/types/CMakeLists.txt b/presto-native-execution/presto_cpp/main/types/CMakeLists.txt
@@ -16,8 +16,14 @@ target_link_libraries(presto_type_converter velox_type_parser)
 
 add_library(
   presto_types OBJECT
-  PrestoToVeloxQueryPlan.cpp PrestoToVeloxExpr.cpp VeloxPlanValidator.cpp
-  PrestoToVeloxSplit.cpp PrestoToVeloxConnector.cpp)
+  PrestoToVeloxQueryPlan.cpp
+  PrestoToVeloxExpr.cpp
+  VeloxPlanValidator.cpp
+  PrestoToVeloxSplit.cpp
+  PrestoToVeloxConnector.cpp
+  TpchPrestoToVeloxConnector.cpp
+  HivePrestoToVeloxConnector.cpp
+  IcebergPrestoToVeloxConnector.cpp)
 add_dependencies(presto_types presto_operators presto_type_converter velox_type
                  velox_type_fbhive velox_dwio_dwrf_proto)