Staging a PCollection in Beam | Dataflow Runner

2022-10-18 Thread Ravi Kapoor
Hi Team, Can we stage a PCollection or PCollection data? Lets say to save the expensive operations between two complex BQ tables time and again and materialize it in some temp view which will be deleted after the session. Is it possible to do that in the Beam Pipeline? We can later use the temp

Go, Java, & Python Project Starter / Example Using Terraform to build Dataflow Custom Templates

2022-10-18 Thread Damon Douglas via dev
Hello Everyone, You can ignore this email if you do not use the Dataflow runner. Happy to announce that the Go SDK was just added to a previously shared example starter project that provisions Dataflow Custom Templates within a terraform workflow on Cloud Build. https://github.com/GoogleCloudPla

[ANNOUNCE] Apache Beam 2.42.0 Released

2022-10-18 Thread Robert Burke
The Apache Beam team is pleased to announce the release of version 2.42.0. Apache Beam is an open source unified programming model to define and execute data processing pipelines, including ETL, batch and stream (continuous) processing. See https://beam.apache.org You can download the release her

Beam High Priority Issue Report (63)

2022-10-18 Thread beamactions
This is your daily summary of Beam's current high priority issues that may need attention. See https://beam.apache.org/contribute/issue-priorities for the meaning and expectations around issue priorities. Unassigned P1 Issues: https://github.com/apache/beam/issues/22743 [Bug]: Test flake: