코드 초기에 아래 코드를 넣어준다.
val sqlContext= new org.apache.spark.sql.SQLContext(sc)
import sqlContext.implicits._
참고 : https://stackoverflow.com/questions/33704831/value-todf-is-not-a-member-of-org-apache-spark-rdd-rdd
value toDF is not a member of org.apache.spark.rdd.RDD
Exception : val people = sc.textFile("resources/people.txt").map(_.split(",")).map(p => Person(p(0), p(1).trim.toInt)).toDF() value toDF is not a member of org.apache.spark.rdd.RDD[Person] He...
stackoverflow.com
Cloudera | The enterprise data cloud company
Cloudera delivers an Enterprise Data Cloud for any data, anywhere, from the Edge to AI.
www.cloudera.com
'Spark' 카테고리의 다른 글
| [Spark Streaming] trigger, window, sliding 이해 하기 (0) | 2019.08.22 |
|---|---|
| [Spark] YARN 위에서 Application 을 실행하는 단계 (0) | 2019.07.25 |
| [Spark] MongoDB 와 연동시 Aggregate Query하는 방법 (0) | 2019.07.13 |
| [Spark] MongoDB로부터 데이터 읽고 pagerank 알고리즘 구현하기 (0) | 2019.06.17 |
| [Scala] 공부하기 좋은 블로그 링크 (0) | 2019.06.17 |