Skip to content

Commit

Permalink
Update benchmark automation script (NVIDIA#998)
Browse files Browse the repository at this point in the history
* Update benchmark automation script to reflect the recent refactor to the benchmark runner

Signed-off-by: Andy Grove <andygrove@nvidia.com>

* Fix some inconsistencies around argument defaults

Signed-off-by: Andy Grove <andygrove@nvidia.com>
  • Loading branch information
andygrove authored Oct 21, 2020
1 parent c864165 commit 1dffd9a
Showing 1 changed file with 7 additions and 17 deletions.
24 changes: 7 additions & 17 deletions integration_tests/src/main/python/benchmark.py
Original file line number Diff line number Diff line change
Expand Up @@ -75,28 +75,19 @@ def main():
help='Path to source data set')
parser.add_argument('--input-format', required=True,
help='Format of input data set (parquet or csv)')
parser.add_argument('--output', required=True,
parser.add_argument('--output', required=False,
help='Path to write query output to')
parser.add_argument('--output-format', required=True,
parser.add_argument('--output-format', required=False,
help='Format to write to (parquet or orc)')
parser.add_argument('--configs', required=True, type=str, nargs='+',
help='One or more configuration filenames to run')
parser.add_argument('--query', required=True, type=str, nargs='+',
help='Queries to run')
parser.add_argument('--iterations', required=True,
parser.add_argument('--iterations', required=False,
help='The number of iterations to run (defaults to 1)')

args = parser.parse_args()

if args.benchmark == "tpcds":
class_name = "com.nvidia.spark.rapids.tests.tpcds.TpcdsLikeBench"
elif args.benchmark == "tpcxbb":
class_name = "com.nvidia.spark.rapids.tests.tpcxbb.TpcxbbLikeBench"
elif args.benchmark == "tpch":
class_name = "com.nvidia.spark.rapids.tests.tpch.TpchLikeBench"
else:
sys.exit("invalid benchmark name")

with open(args.template, "r") as myfile:
template = myfile.read()

Expand All @@ -110,20 +101,19 @@ def main():
cmd.append("--conf " + k + "=" + v)

cmd.append("--jars $SPARK_RAPIDS_PLUGIN_JAR,$CUDF_JAR")
cmd.append("--class " + class_name)
cmd.append("--class com.nvidia.spark.rapids.tests.BenchmarkRunner")
cmd.append("$SPARK_RAPIDS_PLUGIN_INTEGRATION_TEST_JAR")
cmd.append("--benchmark " + args.benchmark)
cmd.append("--query " + query)
cmd.append("--input " + args.input)

if args.input_format is not None:
cmd.append("--input-format {}".format(args.input_format))
cmd.append("--input-format {}".format(args.input_format))

if args.output is not None:
cmd.append("--output " + args.output + "/" + config_name + "/" + query)

if args.output_format is not None:
cmd.append("--output-format {}".format(args.output_format))

cmd.append("--query " + query)
cmd.append("--summary-file-prefix " + summary_file_prefix)

if args.iterations is None:
Expand Down

0 comments on commit 1dffd9a

Please sign in to comment.