beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lc...@apache.org
Subject [3/3] beam git commit: [BEAM-2196] support UDF
Date Tue, 16 May 2017 16:06:40 GMT
[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 <lcwik@google.com>
Authored: Tue May 16 09:06:28 2017 -0700
Committer: Luke Cwik <lcwik@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(-)
----------------------------------------------------------------------



Mime
View raw message