Impala table create and insert from csv file

 

-- 1번. 테이블 삭제

DROP TABLE IF EXISTS KJPARK.FILE_TBL;

 

-- 2번. '/user/kjpark/file'에 읽어들일 csv 파일을 저장해 놓는다.(단 헤더는 삭제한다.)

 

-- 3번. 테이블 적재

CREATE TABLE KJPARK.FILE_TBL (COMP_ID string,

                                                             COMP_TYPE string,

COMP_TITLE string,

CUST_TYPE string)

ROW FORMAT DELIMITED FIELDS TERMINATED BY ','

STORED AS TEXTFILE

LOCATION '/user/32200157/file/';

 

-- 4번. 새로 고침

INVALIDATE METADATA KJPARK.FILE_TBL;

 

-- 5번. 자료 확인

SELECT *

FROM KJPARK.FILE_TBL

LIMIT 10;