You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by lc...@apache.org on 2017/05/16 16:06:40 UTC

[3/3] beam git commit: [BEAM-2196] support UDF

[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(-)
----------------------------------------------------------------------