-- 1.创建Oracle外部表 生成dmp文件
CREATE TABLE zzh_ext
ORGANIZATION EXTERNAL (
TYPE oracle_datapump
DEFAULT DIRECTORY bda
LOCATION ('zzh_ext.dmp')
) PARALLEL 1
AS SELECt * FROM zzh;
-- 2.将dmp文件上传至HDFS
hadoop fs –mkdir /user/ora12c/zzh
hadoop fs –put zzh_ext.dmp /user/ora12c/zzh
-- 3.创建hive表
CREATE EXTERNAL TABLE zzh
ROW FORMAT
SERDE 'oracle.hadoop.hive.datapump.DPSerDe'
STORED AS
INPUTFORMAT 'oracle.hadoop.hive.datapump.DPInputFormat'
OUTPUTFORMAT 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
LOCATION '/user/ora12c/zzh '
-- 4. 登录到 bda 任意一个节点,切换bdd用户到以下目录
# su bdd
$ cd /u01/Oracle/Middleware/BDD1.6.0.37.40/dataprocessing/edp_cli
$ ./data_processing_CLI --database default --table zzh
... ...
data_processing_CLI finished with state SUCCESS



