2016-08-24 75 views
0

我這個代碼實現:從數據解析一行到類中時出錯。星火Mllib

scala> import org.apache.spark._ 

scala> import org.apache.spark.rdd.RDD 
import org.apache.spark.rdd.RDD 

scala> import org.apache.spark.util.IntParam 
import org.apache.spark.util.IntParam 

scala> import org.apache.spark.graphx._ 
import org.apache.spark.graphx._ 

scala> import org.apache.spark.graphx.util.GraphGenerators 
import org.apache.spark.graphx.util.GraphGenerators 

scala> case class Transactions(ID:Long,Chain:Int,Dept:Int,Category:Int,Company:Long,Brand:Long,Date:String,ProductSize:Int,ProductMeasure:String,PurchaseQuantity:Int,PurchaseAmount:Double) 
defined class Transactions 

當我嘗試運行此:

def parseTransactions(str:String): Transactions = { 
    | val line = str.split(",") 
    | Transactions(line(0),line(1),line(2),line(3),line(4),line(5),line(6),line(7),line(8),line(9),line(10)) 
    | } 

我得到這個錯誤:38:錯誤:類型不匹配; 找到:字符串 要求:長

任何人都知道爲什麼我得到這個錯誤?我正在對上面提到的模式進行社交網絡分析。

非常感謝!

回答

0

您正在創建數組,從「,」分離值返回字符串數組。在分配給案例類參數之前將其轉換爲適當的類型。

val line = str.split(",") 
line(0).toLong