Skip to content

Commit 4ed7f13

Browse files
jeffgardnerdavorbonaci
authored andcommitted
Allow 'game' examples to append to existing BigQuery tables.
----Release Notes---- [] ------------- Created by MOE: https://github.com/google/moe MOE_MIGRATED_REVID=112915940
1 parent 8929f3e commit 4ed7f13

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

examples/src/main/java8/com/google/cloud/dataflow/examples/complete/game/utils/WriteToBigQuery.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424
import com.google.cloud.dataflow.sdk.Pipeline;
2525
import com.google.cloud.dataflow.sdk.io.BigQueryIO;
2626
import com.google.cloud.dataflow.sdk.io.BigQueryIO.Write.CreateDisposition;
27+
import com.google.cloud.dataflow.sdk.io.BigQueryIO.Write.WriteDisposition;
2728
import com.google.cloud.dataflow.sdk.options.GcpOptions;
2829
import com.google.cloud.dataflow.sdk.options.PipelineOptions;
2930
import com.google.cloud.dataflow.sdk.transforms.DoFn;
@@ -117,7 +118,8 @@ public PDone apply(PCollection<T> teamAndScore) {
117118
.to(getTable(teamAndScore.getPipeline(),
118119
tableName))
119120
.withSchema(getSchema())
120-
.withCreateDisposition(CreateDisposition.CREATE_IF_NEEDED));
121+
.withCreateDisposition(CreateDisposition.CREATE_IF_NEEDED)
122+
.withWriteDisposition(WriteDisposition.WRITE_APPEND));
121123
}
122124

123125
/** Utility to construct an output table reference. */

examples/src/main/java8/com/google/cloud/dataflow/examples/complete/game/utils/WriteWindowedToBigQuery.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
import com.google.api.services.bigquery.model.TableRow;
2020
import com.google.cloud.dataflow.sdk.io.BigQueryIO;
2121
import com.google.cloud.dataflow.sdk.io.BigQueryIO.Write.CreateDisposition;
22+
import com.google.cloud.dataflow.sdk.io.BigQueryIO.Write.WriteDisposition;
2223
import com.google.cloud.dataflow.sdk.transforms.DoFn;
2324
import com.google.cloud.dataflow.sdk.transforms.DoFn.RequiresWindowAccess;
2425
import com.google.cloud.dataflow.sdk.transforms.ParDo;
@@ -68,7 +69,8 @@ public PDone apply(PCollection<T> teamAndScore) {
6869
.to(getTable(teamAndScore.getPipeline(),
6970
tableName))
7071
.withSchema(getSchema())
71-
.withCreateDisposition(CreateDisposition.CREATE_IF_NEEDED));
72+
.withCreateDisposition(CreateDisposition.CREATE_IF_NEEDED)
73+
.withWriteDisposition(WriteDisposition.WRITE_APPEND));
7274
}
7375

7476
}

0 commit comments

Comments
 (0)