You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@beam.apache.org by Brian Hulette <bh...@apache.org> on 2021/03/08 16:10:27 UTC

Re: Ref needed for apache beam SQL

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 <se...@yahoo.co.uk>
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 <
> bhulette@apache.org> 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 user@beam.apache.org mailing list.
>
> Brian
>
> On Thu, Mar 4, 2021 at 7:26 PM Thirusenthilkumar <se...@yahoo.co.uk>
> 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
>
>