googleapis
diff --git a/‎gcloud-java-bigquery/src/main/java/com/google/gcloud/bigquery/BigQuery.java‎
Lines changed: 8 additions & 0 deletions b/‎gcloud-java-bigquery/src/main/java/com/google/gcloud/bigquery/BigQuery.java‎
Lines changed: 8 additions & 0 deletions
diff --git a/‎gcloud-java-bigquery/src/main/java/com/google/gcloud/bigquery/BigQueryImpl.java‎
Lines changed: 11 additions & 2 deletions b/‎gcloud-java-bigquery/src/main/java/com/google/gcloud/bigquery/BigQueryImpl.java‎
Lines changed: 11 additions & 2 deletions
@@ -662,4 +662,12 @@ Page<List<FieldValue>> listTableData(TableId tableId, TableDataListOption... opt
    * @throws BigQueryException upon failure
    */
   QueryResponse getQueryResults(JobId job, QueryResultsOption... options) throws BigQueryException;
+
+  /**
+   * Returns a channel to write data to be inserted into a BigQuery table. Data format and other
+   * options can be configured using the {@link LoadConfiguration} parameter.
+   *
+   * @throws BigQueryException upon failure
+   */
+  TableDataWriteChannel writer(LoadConfiguration loadConfiguration);
 }
@@ -619,6 +619,10 @@ private static QueryResult.Builder transformQueryResults(JobId jobId, List<Table
         .results(transformTableData(rowsPb));
   }
 
+  public TableDataWriteChannel writer(LoadConfiguration loadConfiguration) {
+    return new TableDataWriteChannel(options(), setProjectId(loadConfiguration));
+  }
+
   private Map<BigQueryRpc.Option, ?> optionMap(Option... options) {
     Map<BigQueryRpc.Option, Object> optionMap = Maps.newEnumMap(BigQueryRpc.Option.class);
     for (Option option : options) {
@@ -698,8 +702,7 @@ public TableId apply(TableId tableId) {
     if (job instanceof LoadJobInfo) {
       LoadJobInfo loadJob = (LoadJobInfo) job;
       LoadJobInfo.Builder loadBuilder = loadJob.toBuilder();
-      loadBuilder.destinationTable(setProjectId(loadJob.destinationTable()));
-      return loadBuilder.build();
+      return loadBuilder.configuration(setProjectId(loadJob.configuration())).build();
     }
     return job;
   }
@@ -711,4 +714,10 @@ private QueryRequest setProjectId(QueryRequest request) {
     }
     return builder.build();
   }
+
+  private LoadConfiguration setProjectId(LoadConfiguration configuration) {
+    LoadConfiguration.Builder builder = configuration.toBuilder();
+    builder.destinationTable(setProjectId(configuration.destinationTable()));
+    return builder.build();
+  }
 }
Original file line number	Diff line number	Diff line change
`@@ -619,6 +619,10 @@ private static QueryResult.Builder transformQueryResults(JobId jobId, List<Table`
`619`	`619`	`.results(transformTableData(rowsPb));`
`620`	`620`	`}`
`621`	`621`
	`622`	`+ public TableDataWriteChannel writer(LoadConfiguration loadConfiguration) {`
	`623`	`+ return new TableDataWriteChannel(options(), setProjectId(loadConfiguration));`
	`624`	`+ }`
	`625`	`+`
`622`	`626`	`private Map<BigQueryRpc.Option, ?> optionMap(Option... options) {`
`623`	`627`	`Map<BigQueryRpc.Option, Object> optionMap = Maps.newEnumMap(BigQueryRpc.Option.class);`
`624`	`628`	`for (Option option : options) {`
`@@ -698,8 +702,7 @@ public TableId apply(TableId tableId) {`
`698`	`702`	`if (job instanceof LoadJobInfo) {`
`699`	`703`	`LoadJobInfo loadJob = (LoadJobInfo) job;`
`700`	`704`	`LoadJobInfo.Builder loadBuilder = loadJob.toBuilder();`
`701`		`- loadBuilder.destinationTable(setProjectId(loadJob.destinationTable()));`
`702`		`- return loadBuilder.build();`
	`705`	`+ return loadBuilder.configuration(setProjectId(loadJob.configuration())).build();`
`703`	`706`	`}`
`704`	`707`	`return job;`
`705`	`708`	`}`
`@@ -711,4 +714,10 @@ private QueryRequest setProjectId(QueryRequest request) {`
`711`	`714`	`}`
`712`	`715`	`return builder.build();`
`713`	`716`	`}`
	`717`	`+`
	`718`	`+ private LoadConfiguration setProjectId(LoadConfiguration configuration) {`
	`719`	`+ LoadConfiguration.Builder builder = configuration.toBuilder();`
	`720`	`+ builder.destinationTable(setProjectId(configuration.destinationTable()));`
	`721`	`+ return builder.build();`
	`722`	`+ }`
`714`	`723`	`}`