无法在scala代码中使用collectAsMap()

Question

 val titleMap = movies.map(line => line.split("\\|")).take(2)

//converting movie-id and movie name as map(key-pair)

val title1 = titleMap.map(array=>(array(0).toInt,array(1)))

val titles = movies.map(line => line.split("\\|").take(2)).map(array
=> (array(0).toInt,
    array(1))).collectAsMap()

"title1“有什么问题，我不能在这里应用collectAsMap函数，在出现”标题“的情况下，我也可以应用相同的东西

Answer 1

title1的类型不是RDD，所以它没有方法collectAsMap()。

titles的类型是RDD，因此它有方法collectAsMap()。

建议阅读safety，system类型