【发布时间】:2014-08-22 13:57:58
【问题描述】:
我正在使用 Mahout FPGrowth 算法,但坚持对数据进行预处理。
FPGrowth 算法的输入为: val 数据:List[JPair[JList[String], JLong]]
在我工作的早期阶段,我使用硬编码的输入数据对其进行了测试。
val data: List[JPair[JList[String], JLong]] = List(
new JPair(List("bread", "beer", "fries", "butter"), 1L),
new JPair(List("milk", "bread"), 1L),
new JPair(List("butter", "beer", "fries"), 1L),
new JPair(List("bread", "beer"), 1L),
new JPair(List("milk", "butter", "bread", "beer"), 1L)
)
那行得通。但我想自动填写列表。我在 scala 中读到,这可以通过 ListBuffers 实现。我试图在 foreach 步骤中填充 ListBuffer。但这不起作用。
parsedData.foreach( p => ListBuf += new JPair(p.str, 1L) )
val ItemSet = ListBuf.toList
在应用程序的末尾,列表 (ItemSet) 仍然是空的。
有人有想法吗??
【问题讨论】:
标签: scala apache-spark scala-collections