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
Post a Comment