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 2016/10/09 21:35:47 UTC
[6/6] incubator-streams-examples git commit: Merge branch 'flink'
Merge branch 'flink'
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/commit/8fe6860f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/tree/8fe6860f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/diff/8fe6860f
Branch: refs/heads/master
Commit: 8fe6860f7e0587f595409914bba61ff6a74cbcf5
Parents: 6e93a8f 9dcdf64
Author: Steve Blackmon @steveblackmon <sb...@apache.org>
Authored: Sun Oct 9 16:35:21 2016 -0500
Committer: Steve Blackmon @steveblackmon <sb...@apache.org>
Committed: Sun Oct 9 16:35:21 2016 -0500
----------------------------------------------------------------------
flink/flink-twitter-collection/README.md | 8 +
flink/flink-twitter-collection/pom.xml | 473 +++++++++
.../jsonschema/FlinkBatchConfiguration.json | 12 +
.../jsonschema/FlinkStreamingConfiguration.json | 40 +
.../jsonschema/StreamsFlinkConfiguration.json | 48 +
.../TwitterFollowingPipelineConfiguration.json | 29 +
.../TwitterPostsPipelineConfiguration.json | 29 +
.../TwitterSpritzerPipelineConfiguration.json | 29 +
...terUserInformationPipelineConfiguration.json | 29 +
.../resources/FlinkTwitterFollowingPipeline.dot | 37 +
.../FlinkTwitterFollowingPipeline.dot.svg | 63 ++
.../resources/FlinkTwitterPostsPipeline.dot | 37 +
.../resources/FlinkTwitterPostsPipeline.dot.svg | 63 ++
.../resources/FlinkTwitterSpritzerPipeline.dot | 33 +
.../FlinkTwitterSpritzerPipeline.dot.svg | 47 +
.../FlinkTwitterUserInformationPipeline.dot | 37 +
.../FlinkTwitterUserInformationPipeline.dot.svg | 63 ++
.../streams/examples/flink/FlinkBase.scala | 200 ++++
.../FlinkTwitterFollowingPipeline.scala | 156 +++
.../collection/FlinkTwitterPostsPipeline.scala | 161 +++
.../FlinkTwitterSpritzerPipeline.scala | 150 +++
.../FlinkTwitterUserInformationPipeline.scala | 159 +++
.../markdown/FlinkTwitterFollowingPipeline.md | 43 +
.../site/markdown/FlinkTwitterPostsPipeline.md | 41 +
.../markdown/FlinkTwitterSpritzerPipeline.md | 41 +
.../FlinkTwitterUserInformationPipeline.md | 41 +
.../src/site/markdown/index.md | 48 +
.../site/resources/FlinkBatchConfiguration.json | 12 +
.../resources/FlinkStreamingConfiguration.json | 40 +
.../resources/FlinkTwitterFollowingPipeline.dot | 37 +
.../resources/FlinkTwitterPostsPipeline.dot | 37 +
.../resources/FlinkTwitterSpritzerPipeline.dot | 33 +
.../FlinkTwitterUserInformationPipeline.dot | 37 +
.../resources/StreamsFlinkConfiguration.json | 48 +
.../TwitterFollowingBatchConfiguration.json | 23 +
.../TwitterFollowingPipelineConfiguration.json | 29 +
.../TwitterPostsBatchConfiguration.json | 23 +
.../TwitterPostsPipelineConfiguration.json | 29 +
.../TwitterSpritzerPipelineConfiguration.json | 29 +
...witterUserInformationBatchConfiguration.json | 23 +
...terUserInformationPipelineConfiguration.json | 29 +
.../src/test/resources/1000twitterids.txt | 1000 ++++++++++++++++++
...linkTwitterFollowingPipelineFollowersIT.conf | 20 +
.../FlinkTwitterFollowingPipelineFriendsIT.conf | 19 +
.../resources/FlinkTwitterPostsPipelineIT.conf | 15 +
.../FlinkTwitterSpritzerPipelineIT.conf | 15 +
.../FlinkTwitterUserInformationPipelineIT.conf | 15 +
.../src/test/resources/asf.txt | 1 +
...inkTwitterFollowingPipelineFollowersIT.scala | 55 +
...FlinkTwitterFollowingPipelineFriendsIT.scala | 59 ++
.../test/FlinkTwitterPostsPipelineIT.scala | 61 ++
.../test/FlinkTwitterSpritzerPipelineIT.scala | 58 +
.../FlinkTwitterUserInformationPipelineIT.scala | 61 ++
flink/pom.xml | 44 +
local/elasticsearch-hdfs/pom.xml | 14 +-
local/elasticsearch-reindex/pom.xml | 2 +-
local/mongo-elasticsearch-sync/pom.xml | 12 +-
local/twitter-follow-graph/pom.xml | 10 +-
local/twitter-history-elasticsearch/pom.xml | 14 +-
local/twitter-userstream-elasticsearch/pom.xml | 14 +-
pom.xml | 29 +-
61 files changed, 4017 insertions(+), 47 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/8fe6860f/pom.xml
----------------------------------------------------------------------