You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bahir.apache.org by lr...@apache.org on 2017/06/24 12:31:17 UTC
bahir git commit: [MINOR] Fix data file path in the streaming-twitter
sample app
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 <dh...@gmail.com>
Authored: Sat Jun 24 13:19:40 2017 +0530
Committer: Luciano Resende <lr...@apache.org>
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)