How to circumvent usage of PeriodicImpulse in Beam to periodically load some query results
I currently have a Beam pipeline executing in Dataflow as a streaming job, which reads from a Kafka Topic and uses a PeriodicImpulse to load a whitelist from a BigQuery table.