Process streaming data from BigQuery table using Dataflow -


like example shown in https://github.com/googlecloudplatform/dataflowjavasdk-examples/blob/master/src/main/java/com/google/cloud/dataflow/examples/cookbook/triggerexample.java

there bigquery table new data gets appended eveny 15 minutes. there timestamp column in table. possible perform streaming analysis fixedwindow time-based trigger data being added bigquery table? similar above example uses pub/sub?

streaming data out of bigquery tricky -- unlike pubsub, bigquery not have "subscribe notifications" api. there way can stream upstream bigquery -- i.e., can stream whoever pushing 15-minute updates?


Comments

Popular posts from this blog

html - Outlook 2010 Anchor (url/address/link) -

javascript - Why does running this loop 9 times take 100x longer than running it 8 times? -

Getting gateway time-out Rails app with Nginx + Puma running on Digital Ocean -