1. 스파크 접속
scala> val sqlContext = new org.apache.spark.sql.hive.HiveContext(sc)2. hive SQL 을 스파크에서 사용하겠다고 지정
scala> val sqlContext = new org.apache.spark.sql.hive.HiveContext(sc)3. 원하는 sql 사용하면 됩니다.
만약 스파크 접속이 안되면?
만약 다 어그러지면
spark 빠져나와 (exit)
oracle 에서 jps
20046 sparksubmit 죽이기!
$kill -9 20046
여기서 안되면
reboot'스파크(SPARK)' 카테고리의 다른 글
| 스파크 SQL 기본 코드 예제 (group by, rank) (0) | 2022.09.20 |
|---|---|
| 스파크로 하이브(hive) SQL 사용하기(예제:emp 테이블) (1) | 2022.09.20 |
| 스파크에서 작업이 안되고 계속 에러가 날 때 조치 방법 (0) | 2022.09.20 |
| 스파크 설치하기 (1) | 2022.09.20 |
| 스파크란 무엇인가 (2) | 2022.09.20 |
