Hi,
What kind of can't find symbol are you receiving?
On the other hand, I would try to change guava dependency version to 14.0.1.
In Spark 1.3.0, guava version is 14.0.1 but is not included inside spark
artifact because it's marked like provided.
Structure seems fine. Only need to type at the end of your program:
ssc.start();
ssc.awaitTermination();
Check method arguments. I advise you to check the spark java api streaming.
https://spark.apache.org/docs/1.3.0/api/java/
Regards.
--
View this message in context:
JavaDStream.saveAsTextFiles not exists in Spark Java Api. If you want to
persist every RDD in your JavaDStream you should do something like this:
words.foreachRDD(new Function2JavaRDDlt;String, Time, Void() {
@Override
public Void call(JavaRDDSparkFlumeEvent rddWords, Time arg1) throws