(workload)
| 76 | impala.execute(query_str) |
| 77 | |
| 78 | def get_test_file_path(workload): |
| 79 | if "IMPALA_HOME" not in os.environ: |
| 80 | raise Exception("IMPALA_HOME must be set") |
| 81 | sql_file_path = os.path.join(os.environ["IMPALA_HOME"], "testdata", "datasets", |
| 82 | workload, "%s_kudu_template.sql" % (workload)) |
| 83 | return sql_file_path |
| 84 | |
| 85 | if __name__ == "__main__": |
| 86 | from argparse import ArgumentDefaultsHelpFormatter, ArgumentParser |