Hi Experts, We have a dynamically configurable list of transformations to be performed on an input stream. Each input element will be transformed by one of those transformations. Each transformation can be expressed as a SQL.
Wondering can this be achieved by BeamSQL? Say, for each input, it will look up which SQL to use and apply it only to this input? With my limited knowledge of BeamSQL, I guess BeamSQL takes SQL and converts it to a pipeline, which is in turn optimized for underlying runners. So this question may be related to whether we can dynamically reconfig a running pipeline in beam. (Like MergeHub+ in Akka?) Thanks
