[ https://issues.apache.org/jira/browse/BEAM-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Xu Mingmin closed BEAM-2288. ---------------------------- > Refine DSL interface > -------------------- > > Key: BEAM-2288 > URL: https://issues.apache.org/jira/browse/BEAM-2288 > Project: Beam > Issue Type: Improvement > Components: dsl-sql > Reporter: Xu Mingmin > Assignee: Xu Mingmin > Fix For: Not applicable > > > As part of BEAM-2010, it update the interface to explain SQL query, to link > with Pipeline, so below part is supported: > {code} > //prepare environment of BeamSQL > BeamSQLEnvironment sqlEnv = BeamSQLEnvironment.create(); > //register table metadata > sqlEnv.addTableMetadata(String tableName, BeamSqlTable tableMetadata); > //register UDF > sqlEnv.registerUDF(String functionName, Method udfMethod); > //explain a SQL statement, SELECT only, and return as a PCollection; > PCollection<BeamSQLRow> phase1Stream = sqlEnv.explainSQL(pipeline, String > sqlStatement); > {code} -- This message was sent by Atlassian JIRA (v6.3.15#6346)