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 <sblack...@apache.org> Authored: Sun Oct 9 16:35:21 2016 -0500 Committer: Steve Blackmon @steveblackmon <sblack...@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 ----------------------------------------------------------------------
