Repository: bahir Updated Branches: refs/heads/master a7e9ecb64 -> dca8d4c2d
[MINOR] Fix data file path in the streaming-twitter sample app Closes #46 Project: http://git-wip-us.apache.org/repos/asf/bahir/repo Commit: http://git-wip-us.apache.org/repos/asf/bahir/commit/dca8d4c2 Tree: http://git-wip-us.apache.org/repos/asf/bahir/tree/dca8d4c2 Diff: http://git-wip-us.apache.org/repos/asf/bahir/diff/dca8d4c2 Branch: refs/heads/master Commit: dca8d4c2dca29947611afbb7f8a788481e53ea9b Parents: a7e9ecb Author: Dheeraj Dwivedi <[email protected]> Authored: Sat Jun 24 13:19:40 2017 +0530 Committer: Luciano Resende <[email protected]> Committed: Sat Jun 24 05:29:04 2017 -0700 ---------------------------------------------------------------------- .../examples/streaming/twitter/TwitterHashTagJoinSentiments.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/bahir/blob/dca8d4c2/streaming-twitter/examples/src/main/scala/org/apache/spark/examples/streaming/twitter/TwitterHashTagJoinSentiments.scala ---------------------------------------------------------------------- diff --git a/streaming-twitter/examples/src/main/scala/org/apache/spark/examples/streaming/twitter/TwitterHashTagJoinSentiments.scala b/streaming-twitter/examples/src/main/scala/org/apache/spark/examples/streaming/twitter/TwitterHashTagJoinSentiments.scala index 957e4c9..6243344 100644 --- a/streaming-twitter/examples/src/main/scala/org/apache/spark/examples/streaming/twitter/TwitterHashTagJoinSentiments.scala +++ b/streaming-twitter/examples/src/main/scala/org/apache/spark/examples/streaming/twitter/TwitterHashTagJoinSentiments.scala @@ -64,7 +64,7 @@ object TwitterHashTagJoinSentiments { val hashTags = stream.flatMap(status => status.getText.split(" ").filter(_.startsWith("#"))) // Read in the word-sentiment list and create a static RDD from it - val wordSentimentFilePath = "data/streaming/AFINN-111.txt" + val wordSentimentFilePath = "streaming-twitter/examples/data/AFINN-111.txt" val wordSentiments = ssc.sparkContext.textFile(wordSentimentFilePath).map { line => val Array(word, happinessValue) = line.split("\t") (word, happinessValue.toInt)
