Real-Time Stream Analytics with Google Cloud Dataflow: Common Use Cases & Patterns (Cloud Next '18)

[@kishorejagannath1244]

Great presentation of the concepts

[@joyjitpal]

Nice architecture

[@AshmitaPanja]

Wonderful content

[@joyjitpal]

Good one

[@adelinghanayem2369]

I didn't understand how do you change the schema dynamically, do you change the code and redeploy you are add the new function with using some command line tool or ?

[@coldkilla123]

I think in this case the cloud function that is invoked by the pubsub topic dynamically reinserts the failed write into the BQ instance without changing the pipeline. It doesn't really make sense given that they will then miss out on the other stages on their pipeline.

[@Spadedaps]

Trade secrets

[@neonoply2205]

If getFailedInsert() == True, it "mutate" the table else stop