The Python SqlTransform was *first* added in Beam 2.22.0, I'd recommend using at least Beam 2.24.0 though. What version of Beam Python are you using?
What happens when you try to import it? Is there an error message you can share? Brian On Sun, Mar 7, 2021 at 7:59 PM Thirusenthilkumar <[email protected]> wrote: > Dear Apache Beam experts, > > Kindly help me to use SQL in apache beam with python SDK. > > Best Regards > Thirusenthilkumar P > > > > On Saturday, 6 March 2021, 01:04:14 GMT+5:30, Brian Hulette < > [email protected]> wrote: > > > Hi Thirusenthilkumar P, > I assume you're interested in using SQL from the Beam Python SDK? In that > case you'd just need to import SqlTransform, as seen in this example: > https://github.com/apache/beam/blob/master/sdks/python/apache_beam/examples/sql_taxi.py#L39 > Note it relies on the Java SDK, so you will need to have Java installed on > your machine. For future reference, you may be able to get faster support > on the [email protected] mailing list. > > Brian > > On Thu, Mar 4, 2021 at 7:26 PM Thirusenthilkumar <[email protected]> > wrote: > > Dear Brain, > > I was going through one of your video and it is interesting. I have couple > of beam pipelined with python SDK currently and want to implement the beam > SQL for some transformations. can you please let me know how to import beam > SQL? > > https://2020.beamsummit.org/sessions/simpler-python-pipelines/ > > Best Regards > Thirusenthilkumar P > >
