This closes #4807: [BEAM-3147] Nexmark Generator refactor [Nexmark] Extract BidGenerator from Generator [Nexmark] Extract AuctionGenerator, PriceGenerator from Generator [Nexmark] Extract PersonGenerator, StringsGenerator, LongGenerator from Generator [Nexmark] Extract GeneratorCheckpoint into a separate class. Move getNextEvent() call to the top of the stack.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a52dbeac Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a52dbeac Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a52dbeac Branch: refs/heads/master Commit: a52dbeacaf544014c4c406f9477ede9f3fb45654 Parents: f10399d d8a6fad Author: Kenneth Knowles <[email protected]> Authored: Fri Nov 17 12:36:46 2017 -0800 Committer: Kenneth Knowles <[email protected]> Committed: Fri Nov 17 12:36:46 2017 -0800 ---------------------------------------------------------------------- .../apache/beam/sdk/nexmark/NexmarkUtils.java | 4 +- .../beam/sdk/nexmark/queries/WinningBids.java | 2 +- .../sdk/nexmark/sources/BoundedEventSource.java | 2 + .../beam/sdk/nexmark/sources/Generator.java | 609 ------------------- .../sdk/nexmark/sources/GeneratorConfig.java | 298 --------- .../nexmark/sources/UnboundedEventSource.java | 23 +- .../nexmark/sources/generator/Generator.java | 271 +++++++++ .../sources/generator/GeneratorCheckpoint.java | 82 +++ .../sources/generator/GeneratorConfig.java | 339 +++++++++++ .../generator/model/AuctionGenerator.java | 142 +++++ .../sources/generator/model/BidGenerator.java | 76 +++ .../sources/generator/model/LongGenerator.java | 37 ++ .../generator/model/PersonGenerator.java | 139 +++++ .../sources/generator/model/PriceGenerator.java | 32 + .../generator/model/StringsGenerator.java | 68 +++ .../sources/generator/model/package-info.java | 22 + .../nexmark/sources/generator/package-info.java | 26 + .../nexmark/sources/BoundedEventSourceTest.java | 1 + .../beam/sdk/nexmark/sources/GeneratorTest.java | 2 + .../sources/UnboundedEventSourceTest.java | 6 +- 20 files changed, 1261 insertions(+), 920 deletions(-) ----------------------------------------------------------------------
