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 <[email protected]> Authored: Wed Aug 23 19:08:32 2017 +0200 Committer: Ismaël MejÃa <[email protected]> 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(+) ----------------------------------------------------------------------
