[스칼라] 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..
카테고리 없음
2021. 2. 19. 23:54