Searched refs:table_id (Results 1 – 6 of 6) sorted by relevance
| /tools/test/connectivity/acts/framework/acts/controllers/buds_lib/data_storage/bigquery/ |
| D | bigquery_logger_utils.py | 338 def create_table(self, dataset_id, table_id, schema): argument
350 table_ref = dataset.table(table_id)
358 def update_table_schema(self, dataset_id, table_id, new_schema): argument
372 table = self.create_table(dataset_id, table_id, new_schema)
387 def delete(self, dataset_id, table_id=None): argument
398 if table_id:
399 table_ref = dataset.table(table_id)
407 def flush(self, rows_list, dataset_id, table_id, retries=5): argument
428 dataset_id, table_id, local_schema)
|
| D | bigquery_logger.py | 31 def __init__(self, dataset_id, table_id): argument
36 self.table_id = table_id
45 self.utils.flush(self.rows, self.dataset_id, self.table_id)
|
| D | bigquery_scheduled_automatic_client.py | 35 dataset_id, table_id = dataset_table_tuple
36 client.flush(rows_list, dataset_id, table_id)
|
| D | bigquery_logger_queue.py | 30 def add_row(self, dataset_id, table_id, row): argument
39 self.queue.put(((dataset_id, table_id), row))
|
| D | bigquery_buffer.py | 127 def log(dataset_id, table_id, row_dict): argument
150 queue.add_row(dataset_id, table_id, row_dict)
|
| D | test_bigquery_logger.py | 20 logger = bigquery_logger.BigqueryLogger(dataset_id='test', table_id='test')
|