스파크로 WHERE 절 서브쿼리 문제 풀기

스파크에서도 SQL 서브쿼리 및 조인이 가능하다! 

 

스파크 접속 

(base) [oracle@centos ~]$ spark-shell

 

스파크 종료 

scala> exit

혹은

scala> :quit

 

스파크에 접속하자 

 

WHERE 절 서브쿼리 

문제 1. ALLEN 보다 늦게 입사한 사원들의 이름, 입사일을 출력해보자 

scala> sql(""" select  ename, hiredate
                   from  emp
                   where  hiredate  > (  select  hiredate
                                                from  emp
                                                where  ename='ALLEN') """).show()

+------+----------+
| ename|  hiredate|
+------+----------+
|  KING|1981-11-17|
| BLAKE|1981-05-01|
| CLARK|1981-05-09|
| JONES|1981-04-01|
|MARTIN|1981-09-10|
|TURNER|1981-08-21|
| JAMES|1981-12-11|
|  WARD|1981-02-23|
|  FORD|1981-12-11|
| SCOTT|1982-12-22|
| ADAMS|1983-01-15|
|MILLER|1982-01-11|
+------+----------+

WHERE 절 서브쿼리를 이용한 셀프조인 하기 

문제 2. KING 에게 보고하는 사원들의 이름을 출력하시오.

(KING 의 사원번호가 mgr 번호인 사원들)

scala> sql(""" SELECT ename
     |           FROM emp
     |           WHERE mgr = (
     |                         SELECT empno
     |                          FROM emp
     |                          WHERE ename='KING' ) """).show()

+-----+
|ename|
+-----+
|BLAKE|
|CLARK|
|JONES|
+-----+