This closes #3561
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bed209e4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bed209e4 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/bed209e4 Branch: refs/heads/DSL_SQL Commit: bed209e41a3b8c7380aa3bee22833b5b5583a235 Parents: a452b80 a49e478 Author: Jean-Baptiste Onofré <[email protected]> Authored: Mon Jul 17 17:14:12 2017 +0200 Committer: Jean-Baptiste Onofré <[email protected]> Committed: Mon Jul 17 17:14:12 2017 +0200 ---------------------------------------------------------------------- .../java/org/apache/beam/dsls/sql/BeamSql.java | 9 +++-- .../org/apache/beam/dsls/sql/BeamSqlEnv.java | 5 ++- .../apache/beam/dsls/sql/schema/BeamSqlUdf.java | 41 ++++++++++++++++++++ .../beam/dsls/sql/BeamSqlDslUdfUdafTest.java | 9 +++-- 4 files changed, 54 insertions(+), 10 deletions(-) ----------------------------------------------------------------------
