我有这样一行代码:
val data = sc.textFile(filepath).zipWithIndex().map{case (k,v) => (v,k)}
我想创建一个以data
作为参数的函数,但是我需要指定它的类型,该如何确定这个类型?我知道在Spark中这是一个Pair RDD,但是我不确定它的具体类型。
我有这样一行代码:
val data = sc.textFile(filepath).zipWithIndex().map{case (k,v) => (v,k)}
我想创建一个以data
作为参数的函数,但是我需要指定它的类型,该如何确定这个类型?我知道在Spark中这是一个Pair RDD,但是我不确定它的具体类型。