|Good catch, Akanksha!|
Yes, RowType was renamed to Schema a while ago and BeamSQL doc seems was not updated.
Could you create a Jira issue for that?
As I see, in 2.5 BeamSQL had been changed to work with Schema.
The above mentioned line needs to be adapted to use schema.
From: Akanksha Sharma B
Sent: Wednesday, July 11, 2018 11:02:37 AM
Subject: Re: Schema class in 2.5 ?
I believe this design document can be helpful for you:
Can you please share some documentation about ongoing changes related to Schema class.
I am looking to understand why is it being introduced and how can I use it.
I was looking for something like RDD in Beam, i.e. Beam understands schema of data internally and thus can handle some conversions itself, e.g. to SqlRow, ParquetFile etc.