Skip to content
Permalink

Comparing changes

This is a direct comparison between two commits made in this repository or its related repositories. View the default comparison for this range or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: prestodb/presto
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: 32aa4e44d7cf262040d1ff2d2956c16e7e266bf1
Choose a base ref
..
head repository: prestodb/presto
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: 42377b8dc8fd62253271dd2cdf0a2bd473157c03
Choose a head ref
Showing with 16 additions and 332 deletions.
  1. +2 −1 presto-native-execution/presto_cpp/main/connectors/tpcds/CMakeLists.txt
  2. +0 −1 presto-native-execution/presto_cpp/main/connectors/tpcds/DSDGenIterator.cpp
  3. +0 −2 presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/CMakeLists.txt
  4. +0 −1 presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/address.cpp
  5. +0 −1 presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/build_support.cpp
  6. +0 −2 presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/dbgen_version.cpp
  7. +0 −1 presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/dist.cpp
  8. +0 −1 presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/genrand.cpp
  9. +0 −95 presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/init.cpp
  10. +0 −1 presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/join.cpp
  11. +0 −1 presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/parallel.cpp
  12. +0 −1 presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/r_params.cpp
  13. +0 −53 presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/release.cpp
  14. +10 −9 presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/scaling.cpp
  15. +1 −2 presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/w_call_center.cpp
  16. +0 −1 presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/w_catalog_page.cpp
  17. +0 −1 presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/w_catalog_sales.cpp
  18. +0 −2 presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/include/dsdgen-c/config.h
  19. +0 −102 presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/include/dsdgen-c/init.h
  20. +0 −1 presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/include/dsdgen-c/params.h
  21. +0 −52 presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/include/dsdgen-c/release.h
  22. +1 −1 presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/include/dsdgen-c/scaling.h
  23. +2 −0 ...tive-execution/src/test/java/com/facebook/presto/nativeworker/AbstractTestNativeTpcdsQueries.java
3 changes: 2 additions & 1 deletion presto-native-execution/presto_cpp/main/connectors/tpcds/CMakeLists.txt
View file
Original file line number Diff line number Diff line change
@@ -46,4 +46,5 @@ target_link_libraries(dsdgen_c append_info)

add_library(tpcds_gen TpcdsGen.cpp DSDGenIterator.cpp)
target_include_directories(tpcds_gen PUBLIC dsdgen/include)
target_link_libraries(tpcds_gen velox_memory velox_vector dsdgen_c append_info fmt::fmt)
target_link_libraries(tpcds_gen velox_memory velox_vector dsdgen_c append_info
fmt::fmt)
1 change: 0 additions & 1 deletion presto-native-execution/presto_cpp/main/connectors/tpcds/DSDGenIterator.cpp
View file
Original file line number Diff line number Diff line change
@@ -18,7 +18,6 @@
#include "config.h"
#include "dist.h"
#include "genrand.h"
#include "init.h"
#include "iostream"
#include "parallel.h"
#include "params.h"
2 changes: 0 additions & 2 deletions presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/CMakeLists.txt
View file
Original file line number Diff line number Diff line change
@@ -23,7 +23,6 @@ add_library(
dist.cpp
error_msg.cpp
genrand.cpp
init.cpp
join.cpp
list.cpp
load.cpp
@@ -33,7 +32,6 @@ add_library(
permute.cpp
pricing.cpp
r_params.cpp
release.cpp
scaling.cpp
scd.cpp
sparse.cpp
1 change: 0 additions & 1 deletion presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/address.cpp
View file
Original file line number Diff line number Diff line change
@@ -52,7 +52,6 @@
#include "config.h"
#include "dist.h"
#include "genrand.h"
#include "init.h"
#include "permute.h"
#include "porting.h"
#include "r_params.h"
1 change: 0 additions & 1 deletion presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/build_support.cpp
View file
Original file line number Diff line number Diff line change
@@ -61,7 +61,6 @@
#include "dist.h"
#include "error_msg.h"
#include "genrand.h"
#include "init.h"
#include "r_params.h"
#include "scaling.h"
#include "tables.h"
2 changes: 0 additions & 2 deletions presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/dbgen_version.cpp
View file
Original file line number Diff line number Diff line change
@@ -53,10 +53,8 @@
#include "columns.h"
#include "config.h"
#include "dist.h"
#include "init.h"
#include "misc.h"
#include "porting.h"
#include "release.h"
#include "tables.h"

/*
1 change: 0 additions & 1 deletion presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/dist.cpp
View file
Original file line number Diff line number Diff line change
@@ -110,7 +110,6 @@ static int load_dist(d_idx_t* d);
#include "config.h"
#include "porting.h"
#include "r_params.h"
#include "release.h"

/*
* Routine: release(char *param_name, char *msg)
1 change: 0 additions & 1 deletion presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/genrand.cpp
View file
Original file line number Diff line number Diff line change
@@ -49,7 +49,6 @@
#include <stdio.h>
#include <stdlib.h>
#include "config.h"
#include "init.h"
#include "porting.h"
#ifdef WIN32
#include <limits.h>
95 changes: 0 additions & 95 deletions presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/init.cpp
View file

This file was deleted.

1 change: 0 additions & 1 deletion presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/join.cpp
View file
Original file line number Diff line number Diff line change
@@ -56,7 +56,6 @@
#include "dist.h"
#include "error_msg.h"
#include "genrand.h"
#include "init.h"
#include "porting.h"
#include "r_params.h"
#include "scaling.h"
1 change: 0 additions & 1 deletion presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/parallel.cpp
View file
Original file line number Diff line number Diff line change
@@ -49,7 +49,6 @@
#include <stdio.h>
#include "config.h"
#include "genrand.h"
#include "init.h"
#include "porting.h"
#include "r_params.h"
#include "scaling.h"
1 change: 0 additions & 1 deletion presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/r_params.cpp
View file
Original file line number Diff line number Diff line change
@@ -57,7 +57,6 @@
#include "config.h"
#include "dist.h"
#include "porting.h"
#include "release.h"
#include "tdefs.h"

#define PARAM_MAX_LEN 80
53 changes: 0 additions & 53 deletions presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/release.cpp
View file

This file was deleted.

19 changes: 10 additions & 9 deletions presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/scaling.cpp
View file
Original file line number Diff line number Diff line change
@@ -56,7 +56,6 @@
#include "dist.h"
#include "error_msg.h"
#include "genrand.h"
#include "init.h"
#include "parallel.h"
#include "porting.h"
#include "r_params.h"
@@ -66,7 +65,7 @@
#include "tpcds.idx.h"
#include "w_inventory.h"

void setUpdateScaling(int table);
void setUpdateScaling(int table, DSDGenContext& dsdGenContext);
int row_skip(int tbl, ds_key_t count, DSDGenContext& dsdGenContext);

/*
@@ -413,7 +412,8 @@ void setUpdateDates(DSDGenContext& dsdGenContext) {
nUpdate = get_int("UPDATE", dsdGenContext);
while (nUpdate--) {
/* pick two adjacent days in the low density zone */
dsdGenContext.arUpdateDates[0] = getSkewedJulianDate(calendar_low, 0);
dsdGenContext.arUpdateDates[0] =
getSkewedJulianDate(calendar_low, 0, dsdGenContext);
jtodt(&dtTemp, dsdGenContext.arUpdateDates[0]);
dist_weight(
&nDay,
@@ -458,7 +458,8 @@ void setUpdateDates(DSDGenContext& dsdGenContext) {
dsdGenContext.arInventoryUpdateDates[1] -= 14;

/* repeat for medium calendar zone */
dsdGenContext.arUpdateDates[2] = getSkewedJulianDate(calendar_medium, 0);
dsdGenContext.arUpdateDates[2] =
getSkewedJulianDate(calendar_medium, 0, dsdGenContext);
jtodt(&dtTemp, dsdGenContext.arUpdateDates[2]);
dist_weight(
&nDay,
@@ -497,7 +498,8 @@ void setUpdateDates(DSDGenContext& dsdGenContext) {
dsdGenContext.arInventoryUpdateDates[3] -= 14;

/* repeat for high calendar zone */
dsdGenContext.arUpdateDates[4] = getSkewedJulianDate(calendar_high, 0);
dsdGenContext.arUpdateDates[4] =
getSkewedJulianDate(calendar_high, 0, dsdGenContext);
jtodt(&dtTemp, dsdGenContext.arUpdateDates[4]);
dist_weight(
&nDay,
@@ -629,10 +631,9 @@ dsdGenContext)getIDCount(nTable), 0, nColumn); *pDest = (ds_key_t)nTemp;
*/

/*
* Routine: getSkewedJulianDate()
* Purpose: return a julian date based on the given skew and column
* Algorithm:
* Data Structures:
* Routine: getSkewedJulianDate(int nWeight, int nColumn, DSDGenContext&
* dsdGenContext) Purpose: return a julian date based on the given skew and
* column Algorithm: Data Structures:
*
* Params:
* Returns:
3 changes: 1 addition & 2 deletions presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/w_call_center.cpp
View file
Original file line number Diff line number Diff line change
@@ -48,15 +48,14 @@
*/
#include "w_call_center.h"

#include <presto_cpp/main/connectors/tpcds/dsdgen/include/dsdgen-c/append_info.h>
#include "append_info.h"
#include "build_support.h"
#include "columns.h"
#include "config.h"
#include "date.h"
#include "decimal.h"
#include "dist.h"
#include "genrand.h"
#include "init.h"
#include "misc.h"
#include "nulls.h"
#include "parallel.h"
1 change: 0 additions & 1 deletion presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/w_catalog_page.cpp
View file
Original file line number Diff line number Diff line change
@@ -55,7 +55,6 @@
#include "date.h"
#include "decimal.h"
#include "genrand.h"
#include "init.h"
#include "misc.h"
#include "nulls.h"
#include "porting.h"
1 change: 0 additions & 1 deletion presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/dsdgen-c/w_catalog_sales.cpp
View file
Original file line number Diff line number Diff line change
@@ -56,7 +56,6 @@
#include "date.h"
#include "decimal.h"
#include "genrand.h"
#include "init.h"
#include "nulls.h"
#include "parallel.h"
#include "params.h"
2 changes: 0 additions & 2 deletions presto-native-execution/presto_cpp/main/connectors/tpcds/dsdgen/include/dsdgen-c/config.h
View file
Original file line number Diff line number Diff line change
@@ -191,6 +191,4 @@
#define STR_QUOTES
#endif

#include "init.h"

#endif /* CONFIG_H */
Loading