You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ta...@apache.org on 2017/08/09 02:08:59 UTC
[2/2] beam git commit: [BEAM-2730] This closes #3692
[BEAM-2730] This closes #3692
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/66286749
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/66286749
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/66286749
Branch: refs/heads/DSL_SQL
Commit: 66286749f2d64eb3f25d99b4d9bf56c49d9f62b6
Parents: 926c70a fa36b12
Author: Tyler Akidau <ta...@apache.org>
Authored: Tue Aug 8 19:07:56 2017 -0700
Committer: Tyler Akidau <ta...@apache.org>
Committed: Tue Aug 8 19:07:56 2017 -0700
----------------------------------------------------------------------
.../apache/beam/sdk/coders/BeamRecordCoder.java | 10 +-
.../org/apache/beam/sdk/values/BeamRecord.java | 24 ++---
.../extensions/sql/example/BeamSqlExample.java | 5 +-
.../extensions/sql/impl/rel/BeamJoinRel.java | 7 +-
.../extensions/sql/impl/rel/BeamValuesRel.java | 7 +-
.../transform/BeamAggregationTransforms.java | 26 +++--
.../sql/impl/transform/BeamJoinTransforms.java | 20 ++--
.../sql/impl/transform/BeamSqlProjectFn.java | 9 +-
.../sql/schema/BeamSqlRecordType.java | 5 +-
.../extensions/sql/schema/BeamTableUtils.java | 41 +++----
.../sql/BeamSqlDslAggregationTest.java | 107 ++++---------------
.../beam/sdk/extensions/sql/BeamSqlDslBase.java | 56 +++-------
.../extensions/sql/BeamSqlDslProjectTest.java | 48 ++++-----
.../extensions/sql/BeamSqlDslUdfUdafTest.java | 8 +-
.../beam/sdk/extensions/sql/TestUtils.java | 6 +-
.../interpreter/BeamSqlFnExecutorTestBase.java | 8 +-
.../sql/schema/BeamSqlRowCoderTest.java | 16 +--
.../sql/schema/kafka/BeamKafkaCSVTableTest.java | 12 +--
18 files changed, 132 insertions(+), 283 deletions(-)
----------------------------------------------------------------------