[BEAM-2748] This closes #3707
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/be01be5c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/be01be5c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/be01be5c Branch: refs/heads/DSL_SQL Commit: be01be5cb5ebf494718c09d0518ac77fdc2b4efd Parents: 3e25ffb ffbd4c2 Author: Tyler Akidau <taki...@apache.org> Authored: Wed Aug 9 13:27:52 2017 -0700 Committer: Tyler Akidau <taki...@apache.org> Committed: Wed Aug 9 13:27:52 2017 -0700 ---------------------------------------------------------------------- .../apache/beam/sdk/extensions/sql/BeamSql.java | 17 +++++++++++++++++ .../apache/beam/sdk/extensions/sql/BeamSqlEnv.java | 9 +++++++++ .../interpreter/operator/BeamSqlUdfExpression.java | 4 +++- .../sdk/extensions/sql/BeamSqlDslUdfUdafTest.java | 13 ++++++++++++- 4 files changed, 41 insertions(+), 2 deletions(-) ----------------------------------------------------------------------