#1.在Oracle上建立要处理的表
create table SOURCE_TABLE_NAME as
SELECT t.*,rownum as row_num FROM SOURCE_TABLE_NAME_O t ;
alter table SOURCE_TABLE_NAME
add constraint SOURCE_TABLE_NAME_P primary key (ROW_NUM);
#2.在Oracle上建立处理结果表
DEST_TABLE_NAME
#3.oracle导入到hadoop
nohup
sqoop import
--hive-import
--connect jdbc:oracle:thin:@192.168.1.14:1521:oradb1
--username USER1
--password "密码"
--verbose -m 32
--table SOURCE_TABLE_NAME
--hive-table db_hive.SOURCE_TABLE_NAME
--fields-terminated-by 't'
--lines-terminated-by 'n' &
#4.计算
hive -e "drop table db_hive.DEST_TABLE_NAME ;
create table db_hive.DEST_TABLE_NAME row format delimited fields terminated by 't' STORED AS TEXTFILE as
select
max(Dn) as Dn,
最后
以上就是受伤自行车最近收集整理的关于oracle数据如何导入hadoop,hadoop hive 与 Oracle 互相导入数据的全部内容,更多相关oracle数据如何导入hadoop,hadoop内容请搜索靠谱客的其他文章。
发表评论 取消回复