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 2017/11/17 20:51:50 UTC
[6/6] beam git commit: This closes #4807: [BEAM-3147] Nexmark
Generator refactor
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 <ke...@apache.org>
Authored: Fri Nov 17 12:36:46 2017 -0800
Committer: Kenneth Knowles <ke...@apache.org>
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(-)
----------------------------------------------------------------------