|
@@ -22,7 +22,7 @@ mysql_to_hdfs_lzo() {
|
|
|
--password $3 \
|
|
|
--target-dir $4$7/$do_date \
|
|
|
--delete-target-dir \
|
|
|
- --columns $5 \
|
|
|
+ --columns "$5" \
|
|
|
--query "$6 and \$CONDITIONS" \
|
|
|
--num-mappers 1 \
|
|
|
--hive-drop-import-delims \
|
|
@@ -39,16 +39,6 @@ mysql_to_hdfs_lzo() {
|
|
|
--null-non-string '\\N'
|
|
|
}
|
|
|
|
|
|
-mysql_to_hdfs(){
|
|
|
- echo $1
|
|
|
- echo $2
|
|
|
- echo $3
|
|
|
- echo $4$7/$do_date
|
|
|
- echo $5
|
|
|
- echo $6
|
|
|
- echo $7
|
|
|
-}
|
|
|
-
|
|
|
ods_energy_15_min(){
|
|
|
mysql_to_hdfs_lzo $url $username $password /warehouse/saga_dw/ods/tmp/ "building, func_id, meter, data_time, data_value" "select building, func_id, meter, data_time, data_value from energy_15_min where dt = '$do_date'" ods_energy_15_min
|
|
|
}
|
|
@@ -66,9 +56,6 @@ ods_energy_5_min_fjd(){
|
|
|
}
|
|
|
|
|
|
case $1 in
|
|
|
-"test")
|
|
|
- mysql_to_hdfs $url $username $password /warehouse/saga_dw/ods/tmp/ "building, func_id, meter, data_time, data_value" "select building, func_id, meter, data_time, data_value from energy_5_min_fjd where dt = '$do_date'" ods_energy_5_min_fjd
|
|
|
- ;;
|
|
|
"energy_15_min")
|
|
|
ods_energy_15_min
|
|
|
ods_energy_15_min_fjd
|