You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2018/01/03 18:06:08 UTC
[beam] 01/01: Merge pull request #4128: [BEAM-3181][Nexmark][SQL]
Implement query0
This is an automated email from the ASF dual-hosted git repository.
kenn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 0892e23940a584a170e2668d86b7bdc50c03e024
Merge: 5b6fe77 21cd637
Author: Kenn Knowles <ke...@kennknowles.com>
AuthorDate: Wed Jan 3 10:06:02 2018 -0800
Merge pull request #4128: [BEAM-3181][Nexmark][SQL] Implement query0
sdks/java/nexmark/build.gradle | 6 +
sdks/java/nexmark/pom.xml | 23 +++
.../apache/beam/sdk/nexmark/NexmarkLauncher.java | 121 ++++++++++++----
.../apache/beam/sdk/nexmark/NexmarkOptions.java | 7 +
.../org/apache/beam/sdk/nexmark/model/Auction.java | 8 +-
.../org/apache/beam/sdk/nexmark/model/Person.java | 6 +-
.../beam/sdk/nexmark/model/sql/BeamRecordSize.java | 134 +++++++++++++++++
.../beam/sdk/nexmark/model/sql/ToBeamRecord.java | 82 +++++++++++
.../model/sql/adapter/ModelAdaptersMapping.java | 124 ++++++++++++++++
.../model/sql/adapter/ModelFieldsAdapter.java | 42 ++++++
.../nexmark/model/sql/adapter/package-info.java | 26 ++++
.../beam/sdk/nexmark/model/sql/package-info.java | 26 ++++
.../beam/sdk/nexmark/queries/NexmarkQuery.java | 5 +-
.../sdk/nexmark/queries/sql/NexmarkSqlQuery.java | 55 +++++++
.../beam/sdk/nexmark/queries/sql/SqlQuery0.java | 97 +++++++++++++
.../beam/sdk/nexmark/queries/sql/package-info.java | 26 ++++
.../sdk/nexmark/model/sql/BeamRecordSizeTest.java | 112 +++++++++++++++
.../sdk/nexmark/model/sql/ToBeamRecordTest.java | 109 ++++++++++++++
.../sql/adapter/ModelAdaptersMappingTest.java | 159 +++++++++++++++++++++
.../sdk/nexmark/queries/sql/SqlQuery0Test.java | 70 +++++++++
20 files changed, 1200 insertions(+), 38 deletions(-)
--
To stop receiving notification emails like this one, please contact
"commits@beam.apache.org" <co...@beam.apache.org>.