2016-11-28 3 views
0

Я хочу обработать файл csv, присутствующий в облачном ковше, и вставить его данные в таблицу BQ. Я нашел следующий кусок кода, но я не знаю, как я могу создать экземпляр com.google.cloud.bigquery.Table для данного имени таблицыКак создать экземпляр com.google.cloud.bigquery.Table

com.google.cloud.bigquery.Table table = null; 
    com.google.cloud.bigquery.Job job = table.load(FormatOptions.csv(), sourceUri); 
     com.google.cloud.bigquery.Job completedJob = job.waitFor(WaitForOption.checkEvery(1, TimeUnit.SECONDS), 
      WaitForOption.timeout(3, TimeUnit.MINUTES)); 
     if (!(completedJob != null && completedJob.getStatus().getError() == null)) { 
      throw new InterruptedException("Unable to load file from bucket into BQ"); 
     } 
    return job; 
+0

@shama - сделал отрывок работы? –

+1

@polleyg: Да, это сработало, жаль, что я забыл обновить этот форум. – Programmer

ответ

1

Snippet взяты из here.

[imports] 

BigQuery bigquery = BigQueryOptions.getDefaultInstance().getService(); 
TableId tableId = TableId.of("dataset", "table"); 
Table table = bigquery.getTable(tableId); 

[..] 

Сторона примечания - это клиентская библиотека Alpha, которую вы используете. Просто так вы знаете.

Смежные вопросы