Function build_hbase_insert

testdata/bin/generate-schema-statements.py:627–636

(db_name, db_suffix, table_name)

def build_hbase_insert(db_name, db_suffix, table_name):
  hbase_insert = SET_HIVE_HBASE_BULK_LOAD + ';\n'
  # For Apache Hive, "hive.hbase.bulk does not exist" exception will be thrown and there
  # is only warning in cdp
  if os.environ['USE_APACHE_HIVE_3'] == "true":
    hbase_insert = ""
  params = build_replacement_params(db_name, db_suffix, table_name)
  hbase_insert += ("INSERT OVERWRITE TABLE {db_name}{db_suffix}.{table_name}"
                   " SELECT * FROM {db_name}.{table_name};\n").format(**params)
  return hbase_insert


def build_insert(insert, db_name, db_suffix, file_format,