This is an automated email from the ASF dual-hosted git repository. sblackmon pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/streams.git
commit 2818d7edf220eafb7edb935f13705e561a2fe695 Merge: 3806660 5edc80a Author: Steve Blackmon <[email protected]> AuthorDate: Thu Jan 18 11:29:18 2018 -0600 Merge pull request #417 from apache/STREAMS-574 STREAMS-574: Merge streams-examples into streams repo pom.xml | 59 +- streams-examples/pom.xml | 42 + .../flink-twitter-collection/README.md | 8 + .../flink-twitter-collection/pom.xml | 467 +++++++++ .../main/jsonschema/FlinkBatchConfiguration.json | 12 + .../jsonschema/FlinkStreamingConfiguration.json | 40 + .../main/jsonschema/StreamsFlinkConfiguration.json | 49 + .../TwitterFollowingPipelineConfiguration.json | 29 + .../TwitterPostsPipelineConfiguration.json | 29 + .../TwitterSpritzerPipelineConfiguration.json | 29 + ...witterUserInformationPipelineConfiguration.json | 29 + .../resources/FlinkTwitterFollowingPipeline.dot | 37 + .../main/resources/FlinkTwitterPostsPipeline.dot | 37 + .../resources/FlinkTwitterSpritzerPipeline.dot | 33 + .../FlinkTwitterUserInformationPipeline.dot | 37 + .../apache/streams/examples/flink/FlinkBase.scala | 221 +++++ .../collection/FlinkTwitterFollowingPipeline.scala | 178 ++++ .../collection/FlinkTwitterPostsPipeline.scala | 175 ++++ .../collection/FlinkTwitterSpritzerPipeline.scala | 175 ++++ .../FlinkTwitterUserInformationPipeline.scala | 184 ++++ .../site/markdown/FlinkTwitterFollowingPipeline.md | 52 + .../src/site/markdown/FlinkTwitterPostsPipeline.md | 48 + .../site/markdown/FlinkTwitterSpritzerPipeline.md | 48 + .../FlinkTwitterUserInformationPipeline.md | 48 + .../src/site/markdown/index.md | 32 + .../flink-twitter-collection/src/site/site.xml | 28 + .../src/test/resources/1000twitterids.txt | 1000 ++++++++++++++++++++ .../FlinkTwitterFollowingPipelineFollowersIT.conf | 36 + .../FlinkTwitterFollowingPipelineFriendsIT.conf | 35 + .../resources/FlinkTwitterPostsPipelineIT.conf | 31 + .../resources/FlinkTwitterSpritzerPipelineIT.conf | 31 + .../FlinkTwitterUserInformationPipelineIT.conf | 31 + .../src/test/resources/asf.txt | 1 + .../FlinkTwitterFollowingPipelineFollowersIT.scala | 73 ++ .../FlinkTwitterFollowingPipelineFriendsIT.scala | 73 ++ .../twitter/test/FlinkTwitterPostsPipelineIT.scala | 73 ++ .../test/FlinkTwitterSpritzerPipelineIT.scala | 74 ++ .../FlinkTwitterUserInformationPipelineIT.scala | 73 ++ streams-examples/streams-examples-flink/pom.xml | 44 + .../elasticsearch-hdfs/README.md | 8 + .../elasticsearch-hdfs/pom.xml | 322 +++++++ .../apache/streams/example/ElasticsearchHdfs.java | 73 ++ .../apache/streams/example/HdfsElasticsearch.java | 73 ++ .../jsonschema/ElasticsearchHdfsConfiguration.json | 13 + .../jsonschema/HdfsElasticsearchConfiguration.json | 13 + .../src/main/resources/ElasticsearchHdfs.dot | 35 + .../src/main/resources/HdfsElasticsearch.dot | 35 + .../src/site/markdown/ElasticsearchHdfs.md | 49 + .../src/site/markdown/HdfsElasticsearch.md | 51 + .../elasticsearch-hdfs/src/site/markdown/index.md | 32 + .../elasticsearch-hdfs/src/site/site.xml | 25 + .../streams/example/test/ElasticsearchHdfsIT.java | 102 ++ .../streams/example/test/HdfsElasticsearchIT.java | 109 +++ .../src/test/resources/ElasticsearchHdfsIT.conf | 31 + .../src/test/resources/HdfsElasticsearchIT.conf | 33 + .../src/test/resources/log4j.properties | 26 + .../src/test/resources/logback.xml | 46 + .../src/test/resources/testBackup.json | 26 + .../src/test/resources/testRestore.json | 22 + .../src/test/resources/testng.xml | 36 + .../elasticsearch-reindex/README.md | 8 + .../elasticsearch-reindex/pom.xml | 278 ++++++ .../streams/example/ElasticsearchReindex.java | 78 ++ .../ElasticsearchReindexConfiguration.json | 13 + .../src/main/resources/ElasticsearchReindex.dot | 35 + .../src/main/resources/application.json | 29 + .../src/main/resources/log4j.properties | 26 + .../src/main/resources/logback.xml | 46 + .../src/site/markdown/ElasticsearchReindex.md | 49 + .../src/site/markdown/index.md | 32 + .../elasticsearch-reindex/src/site/site.xml | 25 + .../example/test/ElasticsearchReindexChildIT.java | 112 +++ .../example/test/ElasticsearchReindexIT.java | 111 +++ .../example/test/ElasticsearchReindexParentIT.java | 125 +++ .../resources/ElasticsearchReindexChildIT.conf | 37 + .../src/test/resources/ElasticsearchReindexIT.conf | 36 + .../resources/ElasticsearchReindexParentIT.conf | 37 + .../src/test/resources/testng.xml | 42 + .../mongo-elasticsearch-sync/README.md | 8 + .../mongo-elasticsearch-sync/pom.xml | 282 ++++++ .../streams/example/MongoElasticsearchSync.java | 77 ++ .../MongoElasticsearchSyncConfiguration.json | 13 + .../src/main/resources/MongoElasticsearchSync.dot | 36 + .../src/site/markdown/MongoElasticsearchSync.md | 50 + .../src/site/markdown/index.md | 31 + .../mongo-elasticsearch-sync/src/site/site.xml | 26 + .../example/test/MongoElasticsearchSyncIT.java | 104 ++ .../test/resources/MongoElasticsearchSyncIT.conf | 35 + .../src/test/resources/testng.xml | 30 + streams-examples/streams-examples-local/pom.xml | 49 + .../twitter-follow-neo4j/README.md | 8 + .../twitter-follow-neo4j/pom.xml | 256 +++++ .../apache/streams/example/TwitterFollowNeo4j.java | 104 ++ .../TwitterFollowNeo4jConfiguration.json | 13 + .../src/main/resources/TwitterFollowNeo4j.dot | 39 + .../src/site/markdown/TwitterFollowNeo4j.md | 45 + .../src/site/markdown/index.md | 31 + .../twitter-follow-neo4j/src/site/site.xml | 28 + .../streams/example/test/TwitterFollowNeo4jIT.java | 119 +++ .../src/test/resources/TwitterFollowNeo4jIT.conf | 32 + .../twitter-history-elasticsearch/README.md | 8 + .../twitter-history-elasticsearch/pom.xml | 284 ++++++ .../example/TwitterHistoryElasticsearch.java | 84 ++ .../TwitterHistoryElasticsearchConfiguration.json | 13 + .../main/resources/TwitterHistoryElasticsearch.dot | 39 + .../site/markdown/TwitterHistoryElasticsearch.md | 53 ++ .../src/site/markdown/index.md | 42 + .../src/site/site.xml | 28 + .../test/TwitterHistoryElasticsearchIT.java | 104 ++ .../resources/TwitterHistoryElasticsearchIT.conf | 31 + .../twitter-userstream-elasticsearch/README.md | 8 + .../twitter-userstream-elasticsearch/pom.xml | 237 +++++ .../example/TwitterUserstreamElasticsearch.java | 147 +++ ...witterUserstreamElasticsearchConfiguration.json | 13 + .../resources/TwitterUserstreamElasticsearch.dot | 46 + .../markdown/TwitterUserstreamElasticsearch.md | 43 + .../src/site/markdown/index.md | 31 + .../src/site/site.xml | 28 + .../test/TwitterUserstreamElasticsearchIT.java | 106 +++ .../TwitterUserstreamElasticsearchIT.conf | 32 + 120 files changed, 8772 insertions(+), 1 deletion(-) -- To stop receiving notification emails like this one, please contact "[email protected]" <[email protected]>.
