[BEAM-2247] This closes #3207
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c0171593 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c0171593 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c0171593 Branch: refs/heads/DSL_SQL Commit: c0171593b4dcba00c61c629426652d60cbca9e9d Parents: e68badd 2bb5799 Author: Jean-Baptiste Onofré <jbono...@apache.org> Authored: Tue Jun 13 13:39:23 2017 +0200 Committer: Jean-Baptiste Onofré <jbono...@apache.org> Committed: Tue Jun 13 13:39:23 2017 +0200 ---------------------------------------------------------------------- dsls/sql/pom.xml | 6 + .../dsls/sql/interpreter/BeamSqlFnExecutor.java | 48 +++++++- .../interpreter/operator/BeamSqlPrimitive.java | 4 + .../operator/BeamSqlReinterpretExpression.java | 55 +++++++++ .../date/BeamSqlCurrentDateExpression.java | 45 +++++++ .../date/BeamSqlCurrentTimeExpression.java | 47 ++++++++ .../date/BeamSqlDateCeilExpression.java | 55 +++++++++ .../date/BeamSqlDateFloorExpression.java | 55 +++++++++ .../operator/date/BeamSqlExtractExpression.java | 111 +++++++++++++++++ .../date/BeamSqlLocalTimeExpression.java | 53 ++++++++ .../date/BeamSqlLocalTimestampExpression.java | 49 ++++++++ .../interpreter/operator/date/package-info.java | 22 ++++ .../apache/beam/dsls/sql/schema/BeamSqlRow.java | 2 + .../sql/interpreter/BeamSqlFnExecutorTest.java | 83 +++++++++++++ .../BeamSqlReinterpretExpressionTest.java | 77 ++++++++++++ .../date/BeamSqlCurrentDateExpressionTest.java | 35 ++++++ .../date/BeamSqlCurrentTimeExpressionTest.java | 35 ++++++ .../date/BeamSqlDateCeilExpressionTest.java | 49 ++++++++ .../date/BeamSqlDateExpressionTestBase.java | 52 ++++++++ .../date/BeamSqlDateFloorExpressionTest.java | 50 ++++++++ .../date/BeamSqlExtractExpressionTest.java | 120 +++++++++++++++++++ .../date/BeamSqlLocalTimeExpressionTest.java | 40 +++++++ .../BeamSqlLocalTimestampExpressionTest.java | 40 +++++++ 23 files changed, 1128 insertions(+), 5 deletions(-) ----------------------------------------------------------------------
