2016-11-28 61 views
0

我想處理存在於雲存儲桶中的csv文件,並將其數據插入到BQ表中。我發現下面這段代碼,但我不知道我怎麼可以實例com.google.cloud.bigquery.Table從here採取定的表名如何實例化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

片段。

[imports] 

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

[..] 

備註 - 這是您正在使用的Alpha客戶端庫。就這樣你知道。