You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by xu...@apache.org on 2017/11/07 15:54:53 UTC
[2/2] beam git commit: This closes #4065
This closes #4065
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f80bf2fd
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f80bf2fd
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f80bf2fd
Branch: refs/heads/master
Commit: f80bf2fdff655b62deb458b1e57d867bfbf03f41
Parents: 269bf89 4fe7480
Author: James Xu <xu...@gmail.com>
Authored: Tue Nov 7 23:11:03 2017 +0800
Committer: James Xu <xu...@gmail.com>
Committed: Tue Nov 7 23:11:03 2017 +0800
----------------------------------------------------------------------
sdks/java/extensions/sql/pom.xml | 8 +
.../sql/impl/interpreter/BeamSqlFnExecutor.java | 9 +-
.../operator/BeamSqlReinterpretExpression.java | 55 -----
.../date/BeamSqlDatetimeMinusExpression.java | 107 +++++++++
.../BeamSqlReinterpretExpression.java | 58 +++++
.../DatetimeReinterpretConversions.java | 59 +++++
.../IntegerReinterpretConversions.java | 44 ++++
.../reinterpret/ReinterpretConversion.java | 114 +++++++++
.../operator/reinterpret/Reinterpreter.java | 101 ++++++++
.../operator/reinterpret/package-info.java | 22 ++
.../impl/interpreter/BeamSqlFnExecutorTest.java | 14 ++
.../BeamSqlReinterpretExpressionTest.java | 116 +++++++---
.../BeamSqlDatetimeMinusExpressionTest.java | 232 +++++++++++++++++++
.../DatetimeReinterpretConversionsTest.java | 73 ++++++
.../IntegerReinterpretConversionsTest.java | 81 +++++++
.../reinterpret/ReinterpretConversionTest.java | 116 ++++++++++
.../operator/reinterpret/ReinterpreterTest.java | 155 +++++++++++++
.../BeamSqlDateFunctionsIntegrationTest.java | 52 +++++
18 files changed, 1330 insertions(+), 86 deletions(-)
----------------------------------------------------------------------