File tree Expand file tree Collapse file tree
gcloud-java-bigquery/src/main/java/com/google/gcloud/bigquery Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -57,5 +57,5 @@ refs/tags/v0.18.0: 9d193c4c4b9d1c6f21515dd8e50836b9194ec9bb
5757refs/tags/v0.19.0: e67b56e4d8dad5f9a7b38c9b2107c23c828f2ed5
5858refs/tags/v0.20.0: 839f7fb7156535146aa1cb2c5aadd8d375d854e8
5959refs/tags/v0.20.1: 370471f437f1f4f68a11e068df5cd6bf39edb1fa
60- refs/heads/tswast-patch-1: 70ee77cae5cca69c1a4c6e274d242b5c09818e7b
60+ refs/heads/tswast-patch-1: 05d6c57f0f05921af6ea55e8d20d2c5d8c2a5952
6161refs/heads/pubsub-streaming-pull: 19262b752ee874eb2ca3b950eb2aef44d5a5267b
Original file line number Diff line number Diff line change @@ -130,7 +130,7 @@ import com.google.gcloud.bigquery.BigQuery;
130130import com.google.gcloud.bigquery.BigQueryOptions;
131131import com.google.gcloud.bigquery.Field;
132132import com.google.gcloud.bigquery.JobStatus;
133- import com.google.gcloud.bigquery.LoadJobInfo ;
133+ import com.google.gcloud.bigquery.JobInfo ;
134134import com.google.gcloud.bigquery.Schema;
135135import com.google.gcloud.bigquery.TableId;
136136import com.google.gcloud.bigquery.TableInfo;
@@ -144,7 +144,8 @@ if (info == null) {
144144 bigquery.create(TableInfo.of(tableId, Schema.of(integerField)));
145145} else {
146146 System.out.println(" Loading data into table " + tableId);
147- LoadJobInfo loadJob = LoadJobInfo.of(tableId, " gs://bucket/path" );
147+ LoadJobConfiguration configuration = LoadJobConfiguration.of(tableId, " gs://bucket/path" );
148+ JobInfo loadJob = JobInfo.of(configuration);
148149 loadJob = bigquery.create(loadJob);
149150 while (loadJob.status().state() ! = JobStatus.State.DONE) {
150151 Thread.sleep(1000L);
Original file line number Diff line number Diff line change 2828 * bigquery.create(TableInfo.of(tableId, Schema.of(integerField)));
2929 * } else {
3030 * System.out.println("Loading data into table " + tableId);
31- * LoadJobInfo loadJob = LoadJobInfo.of(tableId, "gs://bucket/path");
31+ * LoadJobConfiguration configuration = LoadJobConfiguration.of(tableId, "gs://bucket/path");
32+ * JobInfo loadJob = JobInfo.of(configuration);
3233 * loadJob = bigquery.create(loadJob);
3334 * while (loadJob.status().state() != JobStatus.State.DONE) {
3435 * Thread.sleep(1000L);
You can’t perform that action at this time.
0 commit comments