Hi all, I'm working on https://issues.apache.org/jira/browse/BEAM-301(Add a Beam SQL DSL). The skeleton is already in https://github.com/XuMingmin/beam/tree/BEAM-301, using Java SDK in the back-end. The goal is to provide a SQL interface over Beam, based on Calcite, including: 1). a translator to create Beam pipeline from SQL, (SELECT/INSERT/FILTER/GROUP-BY/JOIN/...); 2). an interactive client to submit queries; (All-SQL mode) 3). a SQL API which reduce the work to create a Pipeline; (Semi-SQL mode)
As we see many folks are interested in this feature, would like to create a feature branch to have more involvement. Looking for comments and feedback. Thanks! ---- Mingmin
