| 225 | exit_on_error=True) |
| 226 | |
| 227 | def generate_schema_statements(workload): |
| 228 | generate_cmd = GENERATE_SCHEMA_CMD % (options.exploration_strategy, workload, |
| 229 | options.scale_factor) |
| 230 | if options.table_names: |
| 231 | generate_cmd += " --table_names=%s" % options.table_names |
| 232 | if options.force_reload: |
| 233 | generate_cmd += " --force_reload" |
| 234 | if options.table_formats: |
| 235 | generate_cmd += " --table_formats=%s" % options.table_formats |
| 236 | if options.hive_warehouse_dir is not None: |
| 237 | generate_cmd += " --hive_warehouse_dir=%s" % options.hive_warehouse_dir |
| 238 | if options.hdfs_namenode is not None: |
| 239 | generate_cmd += " --hdfs_namenode=%s" % options.hdfs_namenode |
| 240 | generate_cmd += " --backend=%s" % HS2_HOST_PORT |
| 241 | LOG.info('Executing Generate Schema Command: ' + generate_cmd) |
| 242 | schema_cmd = os.path.join(TESTDATA_BIN_DIR, generate_cmd) |
| 243 | error_msg = 'Error generating schema statements for workload: ' + workload |
| 244 | exec_cmd(schema_cmd, error_msg=error_msg) |
| 245 | |
| 246 | def get_dataset_for_workload(workload): |
| 247 | dimension_file_name = os.path.join(WORKLOAD_DIR, workload, |