(load_template, db_name, db_suffix, table_name, scale_factor="")
| 659 | |
| 660 | |
| 661 | def build_load_statement(load_template, db_name, db_suffix, table_name, scale_factor=""): |
| 662 | # hbase does not need the hdfs path. |
| 663 | if table_name.startswith('hbase'): |
| 664 | params = build_replacement_params(db_name, db_suffix, table_name) |
| 665 | load_template = load_template.format(**params) |
| 666 | else: |
| 667 | base_load_dir = os.getenv("REMOTE_LOAD", IMPALA_HOME) |
| 668 | params = build_replacement_params( |
| 669 | db_name, |
| 670 | db_suffix, |
| 671 | table_name, |
| 672 | impala_home=base_load_dir, |
| 673 | hint="", |
| 674 | part_predicate="", |
| 675 | scale_factor=scale_factor) |
| 676 | |
| 677 | m = PARTITIONED_INSERT_RE.search(load_template) |
| 678 | if m: |
| 679 | load_template = build_partitioned_load(load_template, m, False, params) |
| 680 | else: |
| 681 | load_template = load_template.format(**params) |
| 682 | |
| 683 | return load_template |
| 684 | |
| 685 | |
| 686 | def build_hbase_create_stmt(db_name, table_name, column_families, region_splits): |
no test coverage detected