[BEAM-2520] This closes #3491
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d89d1ee1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d89d1ee1 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d89d1ee1 Branch: refs/heads/DSL_SQL Commit: d89d1ee1a3085269cdf44ec50e29a95c8f43757b Parents: 25fea4e 5ca54e9 Author: Tyler Akidau <[email protected]> Authored: Wed Jul 12 15:57:53 2017 -0700 Committer: Tyler Akidau <[email protected]> Committed: Wed Jul 12 15:57:53 2017 -0700 ---------------------------------------------------------------------- .../java/org/apache/beam/dsls/sql/BeamSql.java | 114 ++++++++++----- .../org/apache/beam/dsls/sql/BeamSqlEnv.java | 6 +- .../beam/dsls/sql/BeamSqlDslUdfUdafTest.java | 137 +++++++++++++++++++ 3 files changed, 221 insertions(+), 36 deletions(-) ----------------------------------------------------------------------
