You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by sb...@apache.org on 2018/01/18 17:29:21 UTC
[streams] 01/01: Merge pull request #417 from apache/STREAMS-574
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 <sb...@apache.org>
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
"commits@streams.apache.org" <co...@streams.apache.org>.