https://devcafe.co.kr/w/index.php?action=history&feed=atom&title=%EC%8A%A4%ED%8C%8C%ED%81%AC_SQL_%ED%85%8C%EC%9D%B4%EB%B8%94_%EC%83%9D%EC%84%B1_%EB%B0%A9%EB%B2%95 2026-04-07T20:19:37Z 이 문서의 편집 역사 MediaWiki 1.42.1 https://devcafe.co.kr/w/index.php?title=%EC%8A%A4%ED%8C%8C%ED%81%AC_SQL_%ED%85%8C%EC%9D%B4%EB%B8%94_%EC%83%9D%EC%84%B1_%EB%B0%A9%EB%B2%95&diff=442&oldid=prev 2024-10-14T18:24:24Z

<p>새 문서: === 스파크 SQL 테이블 생성 방법 === # 스파크 쉘 실행 (cmd창) #:&lt;source lang=shell&gt;c:\spark-shell&lt;/source&gt; # hive SQL을 스칼라에서 사용하도록 선언 #:&lt;source lang=sql&gt;val sqlContext = new org.apache.spark.sql.hive.HiveContext(sc)&lt;/source&gt; # emp 테이블을 생성하는 명령어 #:&lt;source lang=sql&gt;sqlContext.sql(&quot;create table IF NOT EXISTS emp (empno int, ename string, job string, mgr int, hiredate string, sal int, comm int, deptno int) ROW FORMAT...</p> <p><b>새 문서</b></p><div>=== 스파크 SQL 테이블 생성 방법 ===<br /> # 스파크 쉘 실행 (cmd창)<br /> #:&lt;source lang=shell&gt;c:\spark-shell&lt;/source&gt;<br /> # hive SQL을 스칼라에서 사용하도록 선언 <br /> #:&lt;source lang=sql&gt;val sqlContext = new org.apache.spark.sql.hive.HiveContext(sc)&lt;/source&gt;<br /> # emp 테이블을 생성하는 명령어<br /> #:&lt;source lang=sql&gt;sqlContext.sql(&quot;create table IF NOT EXISTS emp (empno int, ename string, job string, mgr int, hiredate string, sal int, comm int, deptno int) ROW FORMAT DELIMITED FIELDS TERMINATED BY &#039;,&#039; LINES TERMINATED BY &#039;\n&#039;&quot;)&lt;/source&gt;<br /> # emp 테이블에 emp2.txt를 로드(입력)<br /> #:&lt;source lang=sql&gt;sqlContext.sql(&quot;LOAD DATA LOCAL INPATH &#039;/home/scott/emp2.txt&#039; INTO TABLE emp&quot;)&lt;/source&gt;<br /> # 입력된 데이터 조회SQL <br /> #:&lt;source lang=sql&gt;sql(&quot;select * from emp&quot;).show()&lt;/source&gt;<br /> * 출력된 결과 <br /> &lt;source lang=sql&gt;<br /> scala&gt; sql(&quot;select * from emp&quot;).show()<br /> +-----+------+-------+----+--------+------+----+------+<br /> |empno| ename| job| mgr|hiredate| sal|comm|deptno|<br /> +-----+------+-------+----+--------+------+----+------+<br /> | 111|scoot1|manager| 222|20220101| 10000|null| 123|<br /> | 112|scoot2| |null|20220101| 20000|null| 123|<br /> | 113|scoot3| |null|20220101| 30000|null| 123|<br /> | 114|scoot4| |null|20220101| 40000|null| 123|<br /> | 115|scoot5| |null|20220101| 50000|null| 123|<br /> | 116|scoot6| |null|20220101| 60000|null| 123|<br /> | 117|scoot7| |null|20220101| 70000|null| 123|<br /> | 118|scoot8| |null|20220101| 80000|null| 123|<br /> | 119|scoot9| |null|20220101| 90000|null| 123|<br /> | 222| cykim| |null|20220101|100000|null| 123|<br /> +-----+------+-------+----+--------+------+----+------+<br /> &lt;/source&gt;</div>

Devcafe