Any particular reason you're not using the SqlTransform to do that? That'd probably be a good place to start code-wise (perhaps with something a bit newer than 2.29) to see how Beam uses Calcite today to produce a PTransform from a query plan.
On Wed, Jun 14, 2023 at 5:32 AM Soumyadeep Mukhopadhyay < soumyamy...@gmail.com> wrote: > Hello All, > > I have a use case where I need Apache Calcite to parse, validate the query > and then apply some planner rules. > > I was hoping to leverage the capabilities of the Apache Beam on top of > Calcite so that I can build on top of what we have already done, and apply > it at scale. One approach that came to mind was to either convert the > RelNode to something equivalent in Beam (like PTransform maybe? > https://beam.apache.org/releases/javadoc/2.29.0/org/apache/beam/sdk/extensions/sql/impl/rel/BeamRelNode.html > ). > > Any opinion/suggestion on this will be really appreciated! Thanks for your > time and consideration! If you feel this is not intended forum for me to > ask, please let me know! :) > > With regards, > Soumyadeep Mukhopadhyay. >
