Lines Matching refs:big_query
50 def create_table(big_query, project_id, dataset_id, table_id, table_schema, argument
57 return create_table2(big_query, project_id, dataset_id, table_id, fields,
61 def create_partitioned_table(big_query, argument
77 return create_table2(big_query, project_id, dataset_id, table_id, fields,
81 def create_table2(big_query, argument
110 table_req = big_query.tables().insert(
124 def patch_table(big_query, project_id, dataset_id, table_id, fields_schema): argument
139 table_req = big_query.tables().patch(
152 def insert_rows(big_query, project_id, dataset_id, table_id, rows_list): argument
156 insert_req = big_query.tabledata().insertAll(
172 def sync_query_job(big_query, project_id, query, timeout=5000): argument
176 query_job = big_query.jobs().query(