Update Beam examples archetypes This closes #936
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e9a08e45 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e9a08e45 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/e9a08e45 Branch: refs/heads/master Commit: e9a08e454b20c88c72ea4ce3138df77f898b26d7 Parents: e3768f6 76f0ff4 Author: Luke Cwik <[email protected]> Authored: Tue Sep 13 18:01:42 2016 -0700 Committer: Luke Cwik <[email protected]> Committed: Tue Sep 13 18:01:42 2016 -0700 ---------------------------------------------------------------------- .../apache/beam/examples/MinimalWordCount.java | 3 +- .../beam/examples/common/ExampleUtils.java | 2 +- pom.xml | 14 +- sdks/java/maven-archetypes/examples/pom.xml | 25 ++ .../main/resources/archetype-resources/pom.xml | 20 +- .../src/main/java/DebuggingWordCount.java | 32 +- .../src/main/java/MinimalWordCount.java | 50 ++- .../src/main/java/WindowedWordCount.java | 139 +++---- .../src/main/java/WordCount.java | 77 ++-- .../java/common/DataflowExampleOptions.java | 32 -- .../main/java/common/DataflowExampleUtils.java | 391 ------------------- .../common/ExampleBigQueryTableOptions.java | 11 +- .../src/main/java/common/ExampleOptions.java | 32 ++ ...xamplePubsubTopicAndSubscriptionOptions.java | 45 +++ .../java/common/ExamplePubsubTopicOptions.java | 17 +- .../src/main/java/common/ExampleUtils.java | 353 +++++++++++++++++ .../main/java/common/PubsubFileInjector.java | 153 -------- .../src/test/java/WordCountTest.java | 9 +- sdks/java/maven-archetypes/starter/pom.xml | 8 + .../main/resources/archetype-resources/pom.xml | 6 +- .../resources/projects/basic/reference/pom.xml | 6 +- 21 files changed, 641 insertions(+), 784 deletions(-) ----------------------------------------------------------------------
