[BEAM-2196] support UDF This closes #3136
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/36a436ca Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/36a436ca Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/36a436ca Branch: refs/heads/DSL_SQL Commit: 36a436ca01cf744fea143a977158faf716a8b65f Parents: 0e08c87 4a7c107 Author: Luke Cwik <lc...@google.com> Authored: Tue May 16 09:06:28 2017 -0700 Committer: Luke Cwik <lc...@google.com> Committed: Tue May 16 09:06:28 2017 -0700 ---------------------------------------------------------------------- .../dsls/sql/interpreter/BeamSQLFnExecutor.java | 13 ++- .../operator/BeamSqlUdfExpression.java | 86 ++++++++++++++++++++ .../beam/dsls/sql/planner/BeamQueryPlanner.java | 5 +- .../beam/dsls/sql/planner/BeamSqlRunner.java | 12 +++ .../operator/BeamSqlUdfExpressionTest.java | 51 ++++++++++++ .../sql/planner/BeamGroupByExplainTest.java | 11 +++ .../sql/planner/BeamGroupByPipelineTest.java | 12 +++ 7 files changed, 188 insertions(+), 2 deletions(-) ----------------------------------------------------------------------