Fixed formatting errors

prestodb · Jun 25, 2024 · 8734eef · 8734eef
1 parent df192c3
commit 8734eef
Show file tree

Hide file tree

Showing 5 changed files with 14 additions and 39 deletions.
diff --git a/presto-native-execution/presto_cpp/main/connectors/CMakeLists.txt b/presto-native-execution/presto_cpp/main/connectors/CMakeLists.txt
@@ -17,5 +17,5 @@ add_library(presto_tpcds_connector OBJECT tpcds/TpcdsConnector.cpp)
 target_link_libraries(presto_tpcds_connector velox_connector tpcds_gen fmt::fmt)
 
 # if(${VELOX_ENABLE_TPCDS_CONNECTOR}) # make this change to a presto flag
-  add_subdirectory(tpcds)
+add_subdirectory(tpcds)
 # endif()
diff --git a/presto-native-execution/presto_cpp/main/connectors/tpcds/DSDGenIterator.cpp b/presto-native-execution/presto_cpp/main/connectors/tpcds/DSDGenIterator.cpp
@@ -60,7 +60,6 @@ DSDGenIterator::DSDGenIterator(
     double scaleFactor,
     vector_size_t parallel,
     vector_size_t child) {
-
   table_defs.resize(DBGEN_VERSION); // there are 24 TPC-DS tables
   VELOX_CHECK_GE(scaleFactor, 0, "Tpch scale factor must be non-negative");
   dsdgenCtx_.scaleFactor = scaleFactor;

diff --git a/presto-native-execution/presto_cpp/main/connectors/tpcds/TpcdsGen.cpp b/presto-native-execution/presto_cpp/main/connectors/tpcds/TpcdsGen.cpp
@@ -479,35 +479,12 @@ RowTypePtr getTableSchema(Table table) {
               "s_tax_precentage",
           },
           {
-              INTEGER(),
-              VARCHAR(),
-              DATE(),
-              DATE(),
-              INTEGER(),
-              VARCHAR(),
-              INTEGER(),
-              INTEGER(),
-              VARCHAR(),
-              VARCHAR(),
-              INTEGER(),
-              VARCHAR(),
-              VARCHAR(),
-              VARCHAR(),
-              INTEGER(),
-              VARCHAR(),
-              INTEGER(),
-              VARCHAR(),
-              VARCHAR(),
-              VARCHAR(),
-              VARCHAR(),
-              VARCHAR(),
-              VARCHAR(),
-              VARCHAR(),
-              VARCHAR(),
-              VARCHAR(),
-              VARCHAR(),
-              DECIMAL(5, 2),
-              DECIMAL(5, 2),
+              INTEGER(), VARCHAR(), DATE(),        DATE(),        INTEGER(),
+              VARCHAR(), INTEGER(), INTEGER(),     VARCHAR(),     VARCHAR(),
+              INTEGER(), VARCHAR(), VARCHAR(),     VARCHAR(),     INTEGER(),
+              VARCHAR(), INTEGER(), VARCHAR(),     VARCHAR(),     VARCHAR(),
+              VARCHAR(), VARCHAR(), VARCHAR(),     VARCHAR(),     VARCHAR(),
+              VARCHAR(), VARCHAR(), DECIMAL(5, 2), DECIMAL(5, 2),
           });
       return type;
     }

diff --git a/presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/r_params.cpp b/presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/r_params.cpp
@@ -446,11 +446,10 @@ int set_option(const char* name, const char* param) {
   //	switch (o->flags & TYPE_MASK) {
   //	case OPT_FLG:
   //		if ((param && (*param == 'Y' || *param == 'Y' || *param ==
-  //OPTION_START)) || (param == NULL)) { 			if (o->action) 				if (o->action((char
-  //*)o->name, NULL) < 0) 					usage((char *)o->name, "Cannot process option");
-  //			set_flg(name);
-  //		} else
-  //			clr_flg(name);
+  // OPTION_START)) || (param == NULL)) { 			if (o->action)
+  // if (o->action((char
+  //*)o->name, NULL) < 0) 					usage((char
+  //*)o->name, "Cannot process option"); 			set_flg(name); 		} else 			clr_flg(name);
   //		res = 1;
   //		break;
   //	case OPT_INT:
@@ -483,7 +482,7 @@ int set_option(const char* name, const char* param) {
   //		break;
   //	default:
   //		fprintf(stderr, "Invalid option/type (%d/%s)\n", o->flags &
-  //TYPE_MASK, o->name); 		exit(0); 		break;
+  // TYPE_MASK, o->name); 		exit(0); 		break;
   //	}
   //
   //	o->flags |= OPT_SET; /* marked as set */

diff --git a/presto-native-execution/presto_cpp/main/types/PrestoToVeloxConnector.cpp b/presto-native-execution/presto_cpp/main/types/PrestoToVeloxConnector.cpp
@@ -14,14 +14,14 @@
 
 #include "presto_cpp/main/types/PrestoToVeloxConnector.h"
 #include <velox/type/fbhive/HiveTypeParser.h>
+#include "presto_cpp/main/connectors/tpcds/TpcdsConnector.h"
+#include "presto_cpp/main/connectors/tpcds/TpcdsConnectorSplit.h"
 #include "velox/connectors/hive/HiveConnector.h"
 #include "velox/connectors/hive/HiveConnectorSplit.h"
 #include "velox/connectors/hive/HiveDataSink.h"
 #include "velox/connectors/hive/TableHandle.h"
 #include "velox/connectors/hive/iceberg/IcebergDeleteFile.h"
 #include "velox/connectors/hive/iceberg/IcebergSplit.h"
-#include "presto_cpp/main/connectors/tpcds/TpcdsConnector.h"
-#include "presto_cpp/main/connectors/tpcds/TpcdsConnectorSplit.h"
 #include "velox/connectors/tpch/TpchConnector.h"
 #include "velox/connectors/tpch/TpchConnectorSplit.h"