[스칼라] SQL 쿼리 결과를 RDD에 저장

sqlContext.sql주는 DataFrame, 당신은 호출 할 수 있습니다 .rdd()를 얻을 RDD[Row].

이것을 시도 할 수 있습니다.

 val queryResult = sqlContext.sql("select encounter.Member_ID AS patientID, encounter.Encounter_DateTime AS date, diag.code from encounter join diag on encounter.Encounter_ID = diag.Encounter_ID")

 val rdd: RDD[Row] = queryResult.rdd
 

제거 show에 기능을 DataFrame하기 때문에 이 표준 출력에 DataFrame의 내용을 표시

출처
https://stackoverflow.com/questions/39940116