You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ie...@apache.org on 2017/08/23 17:10:03 UTC
[55/55] [abbrv] beam git commit: This closes #3114
This closes #3114
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/64ff21f3
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/64ff21f3
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/64ff21f3
Branch: refs/heads/master
Commit: 64ff21f35ee2946d38645fb0a51678628e49e62a
Parents: f0ce31b 0acd720
Author: Ismaël Mejía <ie...@gmail.com>
Authored: Wed Aug 23 19:08:32 2017 +0200
Committer: Ismaël Mejía <ie...@gmail.com>
Committed: Wed Aug 23 19:08:32 2017 +0200
----------------------------------------------------------------------
sdks/java/javadoc/ant.xml | 1 +
sdks/java/nexmark/README.md | 340 +++++
sdks/java/nexmark/pom.xml | 261 ++++
.../java/org/apache/beam/sdk/nexmark/Main.java | 303 +++++
.../org/apache/beam/sdk/nexmark/Monitor.java | 78 ++
.../beam/sdk/nexmark/NexmarkConfiguration.java | 721 +++++++++++
.../beam/sdk/nexmark/NexmarkLauncher.java | 1157 ++++++++++++++++++
.../apache/beam/sdk/nexmark/NexmarkOptions.java | 403 ++++++
.../apache/beam/sdk/nexmark/NexmarkPerf.java | 207 ++++
.../apache/beam/sdk/nexmark/NexmarkSuite.java | 112 ++
.../apache/beam/sdk/nexmark/NexmarkUtils.java | 674 ++++++++++
.../apache/beam/sdk/nexmark/model/Auction.java | 187 +++
.../beam/sdk/nexmark/model/AuctionBid.java | 85 ++
.../beam/sdk/nexmark/model/AuctionCount.java | 84 ++
.../beam/sdk/nexmark/model/AuctionPrice.java | 88 ++
.../org/apache/beam/sdk/nexmark/model/Bid.java | 177 +++
.../beam/sdk/nexmark/model/BidsPerSession.java | 87 ++
.../beam/sdk/nexmark/model/CategoryPrice.java | 97 ++
.../org/apache/beam/sdk/nexmark/model/Done.java | 80 ++
.../apache/beam/sdk/nexmark/model/Event.java | 171 +++
.../beam/sdk/nexmark/model/IdNameReserve.java | 98 ++
.../beam/sdk/nexmark/model/KnownSize.java | 26 +
.../beam/sdk/nexmark/model/NameCityStateId.java | 103 ++
.../apache/beam/sdk/nexmark/model/Person.java | 163 +++
.../beam/sdk/nexmark/model/SellerPrice.java | 89 ++
.../beam/sdk/nexmark/model/package-info.java | 22 +
.../apache/beam/sdk/nexmark/package-info.java | 21 +
.../sdk/nexmark/queries/AbstractSimulator.java | 211 ++++
.../beam/sdk/nexmark/queries/NexmarkQuery.java | 270 ++++
.../sdk/nexmark/queries/NexmarkQueryModel.java | 118 ++
.../apache/beam/sdk/nexmark/queries/Query0.java | 70 ++
.../beam/sdk/nexmark/queries/Query0Model.java | 64 +
.../apache/beam/sdk/nexmark/queries/Query1.java | 67 +
.../beam/sdk/nexmark/queries/Query10.java | 367 ++++++
.../beam/sdk/nexmark/queries/Query11.java | 79 ++
.../beam/sdk/nexmark/queries/Query12.java | 80 ++
.../beam/sdk/nexmark/queries/Query1Model.java | 76 ++
.../apache/beam/sdk/nexmark/queries/Query2.java | 79 ++
.../beam/sdk/nexmark/queries/Query2Model.java | 80 ++
.../apache/beam/sdk/nexmark/queries/Query3.java | 301 +++++
.../beam/sdk/nexmark/queries/Query3Model.java | 124 ++
.../apache/beam/sdk/nexmark/queries/Query4.java | 116 ++
.../beam/sdk/nexmark/queries/Query4Model.java | 186 +++
.../apache/beam/sdk/nexmark/queries/Query5.java | 138 +++
.../beam/sdk/nexmark/queries/Query5Model.java | 176 +++
.../apache/beam/sdk/nexmark/queries/Query6.java | 155 +++
.../beam/sdk/nexmark/queries/Query6Model.java | 133 ++
.../apache/beam/sdk/nexmark/queries/Query7.java | 90 ++
.../beam/sdk/nexmark/queries/Query7Model.java | 130 ++
.../apache/beam/sdk/nexmark/queries/Query8.java | 97 ++
.../beam/sdk/nexmark/queries/Query8Model.java | 148 +++
.../apache/beam/sdk/nexmark/queries/Query9.java | 44 +
.../beam/sdk/nexmark/queries/Query9Model.java | 44 +
.../beam/sdk/nexmark/queries/WinningBids.java | 412 +++++++
.../nexmark/queries/WinningBidsSimulator.java | 206 ++++
.../beam/sdk/nexmark/queries/package-info.java | 22 +
.../sdk/nexmark/sources/BoundedEventSource.java | 190 +++
.../beam/sdk/nexmark/sources/Generator.java | 609 +++++++++
.../sdk/nexmark/sources/GeneratorConfig.java | 298 +++++
.../nexmark/sources/UnboundedEventSource.java | 329 +++++
.../beam/sdk/nexmark/sources/package-info.java | 22 +
.../nexmark/src/main/resources/log4j.properties | 55 +
.../beam/sdk/nexmark/queries/QueryTest.java | 185 +++
.../nexmark/sources/BoundedEventSourceTest.java | 70 ++
.../beam/sdk/nexmark/sources/GeneratorTest.java | 110 ++
.../sources/UnboundedEventSourceTest.java | 105 ++
sdks/java/pom.xml | 1 +
67 files changed, 11892 insertions(+)
----------------------------------------------------------------------