Re: how to declare tuple return type

[wxhsdp <wx...@gmail.com>]

you need to import org.apache.spark.rdd.RDD to include RDD.
http://spark.apache.org/docs/latest/api/core/index.html#org.apache.spark.rdd.RDD

here are some examples you can learn
https://github.com/apache/spark/tree/master/mllib/src/main/scala/org/apache/spark/mllib



SK wrote
> I am a new user of Spark. I have a class that defines a function as
> follows. It returns a tuple : (Int, Int, Int).
> 
> class Sim extends VectorSim {
> override def  input(master:String): (Int,Int,Int) = {
>             sc = new SparkContext(master, "Test")
>             val ratings = sc.textFile(INP_FILE)
>                       .map(line=> {
>                         val fields = line.split("\t")
>                         (fields(0).toInt, fields(1).toInt,
> fields(2).toInt)
>                       })
>             ratings
>       }
> }
> 
> The class extends the trait VectorSim where the function  input() is
> declared as follows.
> 
> trait VectorSim {
>   def input (s:String): (Int, Int, Int)
> }
> 
> However, when I compile, I get a type mismatch saying input() returns
> RDD[(Int,Int,Int)].
> So I changed the return type to RDD[(Int,Int,Int)], but the compiler
> complains that there is no type called RDD. What is the right way to
>  declare the return type for a tuple that is (Int,Int,Int).
> 
> I am using spark 0.9.
> 
> thanks





--
View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/how-to-declare-tuple-return-type-tp4985p4993.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.