Hive相关

# 注意事项：

-> Spark-SQL使用JDBC读取表, 默认使用一个executor去读， 如果转成并发， 需要设置分区索引去读;

1. 创建parquet存储表

CREATE TABLE IF NOT EXISTS bi_orginal.`param_code_dcs` (
`CODE_ID` string COMMENT ‘CODE ID‘,
`TYPE` string COMMENT ‘CODE类型‘,
`TYPE_NAME` string COMMENT ‘CODE类型中文说明‘,
`CODE_DESC` string COMMENT ‘CODE ID中文说明‘,
`NUM` string ,
`update_time` string
)
comment ‘param_code_dcs‘
STORED AS parquet

2.  向表中插入数据

insert overwrite table bi_orginal.`param_code_dcs`
SELECT CODE_ID, TYPE, TYPE_NAME, CODE_DESC, NUM, from_unixtime(unix_timestamp(),‘yyyy-MM-dd HH:mm:ss‘) FROM artemisdcs.d_f_artemisdcs_tc_code_dcs

Hive相关

原文：https://www.cnblogs.com/ruili07/p/10825767.html