From f71893a1ba2f46cbd878da66803a09f8f6df593b Mon Sep 17 00:00:00 2001 From: RushabhRatnaparkhi Date: Sat, 24 Jan 2026 00:46:07 +0530 Subject: [PATCH 1/2] Fix TriggerExample BigQuery write disposition --- .../org/apache/beam/examples/cookbook/TriggerExample.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/examples/java/src/main/java/org/apache/beam/examples/cookbook/TriggerExample.java b/examples/java/src/main/java/org/apache/beam/examples/cookbook/TriggerExample.java index cd3c6dd84157..ca65a83931e7 100644 --- a/examples/java/src/main/java/org/apache/beam/examples/cookbook/TriggerExample.java +++ b/examples/java/src/main/java/org/apache/beam/examples/cookbook/TriggerExample.java @@ -486,7 +486,10 @@ static void runTriggerExample(TrafficFlowOptions options) throws IOException { .get(i) .apply( "BigQuery Write Rows" + i, - BigQueryIO.writeTableRows().to(tableRef).withSchema(getSchema())); + BigQueryIO.writeTableRows() + .to(tableRef) + .withSchema(getSchema()) + .withWriteDisposition(BigQueryIO.Write.WriteDisposition.WRITE_APPEND)); } PipelineResult result = pipeline.run(); From 525d9bf934763f6d6d9a0ee15cc9f4d55cf815d2 Mon Sep 17 00:00:00 2001 From: RushabhRatnaparkhi Date: Sat, 24 Jan 2026 23:11:41 +0530 Subject: [PATCH 2/2] Apply Spotless formatting to TriggerExample.java --- .../org/apache/beam/examples/cookbook/TriggerExample.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/examples/java/src/main/java/org/apache/beam/examples/cookbook/TriggerExample.java b/examples/java/src/main/java/org/apache/beam/examples/cookbook/TriggerExample.java index ca65a83931e7..64a4f4d73d32 100644 --- a/examples/java/src/main/java/org/apache/beam/examples/cookbook/TriggerExample.java +++ b/examples/java/src/main/java/org/apache/beam/examples/cookbook/TriggerExample.java @@ -487,9 +487,9 @@ static void runTriggerExample(TrafficFlowOptions options) throws IOException { .apply( "BigQuery Write Rows" + i, BigQueryIO.writeTableRows() - .to(tableRef) - .withSchema(getSchema()) - .withWriteDisposition(BigQueryIO.Write.WriteDisposition.WRITE_APPEND)); + .to(tableRef) + .withSchema(getSchema()) + .withWriteDisposition(BigQueryIO.Write.WriteDisposition.WRITE_APPEND)); } PipelineResult result = pipeline.run();