|
@@ -164,7 +164,8 @@ class SQLIndexer(object):
|
|
|
'overwrite': False,
|
|
'overwrite': False,
|
|
|
'partition_columns': [(partition['name'], partition['partitionValue']) for partition in partition_columns],
|
|
'partition_columns': [(partition['name'], partition['partitionValue']) for partition in partition_columns],
|
|
|
}
|
|
}
|
|
|
- db = dbms.get(self.user)
|
|
|
|
|
|
|
+ query_server_config = dbms.get_query_server_config(name=source_type)
|
|
|
|
|
+ db = dbms.get(self.user, query_server=query_server_config)
|
|
|
sql += "\n\n%s;" % db.load_data(database, table_name, form_data, None, generate_ddl_only=True)
|
|
sql += "\n\n%s;" % db.load_data(database, table_name, form_data, None, generate_ddl_only=True)
|
|
|
|
|
|
|
|
if load_data and table_format in ('parquet', 'kudu'):
|
|
if load_data and table_format in ('parquet', 'kudu'):
|