wudianlong 2 lat temu
rodzic
commit
40727be06c
1 zmienionych plików z 5 dodań i 5 usunięć
  1. 5 5
      energy/dayTask/mysql_to_hdfs.sh

+ 5 - 5
energy/dayTask/mysql_to_hdfs.sh

@@ -20,7 +20,7 @@ mysql_to_hdfs_lzo() {
 	--connect $1 \
 	--username $2 \
 	--password $3 \
-	--target-dir /warehouse/saga_dw/ods/tmp/$7/$do_date \
+	--target-dir $4$7/$do_date \
 	--delete-target-dir \
 	--columns $5 \
 	--query "$6 and \$CONDITIONS" \
@@ -40,19 +40,19 @@ mysql_to_hdfs_lzo() {
 }
 
 ods_energy_15_min(){
-  mysql_to_hdfs_lzo $url $username $password /warehouse/saga_dw/ods/ods_energy_15_min "building, func_id, meter, data_time, data_value" "select building, func_id, meter, data_time, data_value from energy_15_min where where dt = '$do_date'" 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 where dt = '$do_date'" ods_energy_15_min
 }
 
 ods_energy_5_min(){
-  mysql_to_hdfs_lzo $url $username $password /warehouse/saga_dw/ods/ods_energy_5_min "building, func_id, meter, data_time, data_value" "select building, func_id, meter, data_time, data_value from energy_5_min where where dt = '$do_date'" ods_energy_5_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_5_min where where dt = '$do_date'" ods_energy_5_min
 }
 
 ods_energy_15_min_fjd(){
-  mysql_to_hdfs_lzo $url $username $password /warehouse/saga_dw/ods/ods_energy_15_min_fjd "building, func_id, meter, data_time, data_value" "select building, func_id, meter, data_time, data_value from energy_15_min_fjd where where dt = '$do_date'" ods_energy_15_min_fjd
+  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_fjd where where dt = '$do_date'" ods_energy_15_min_fjd
 }
 
 ods_energy_5_min_fjd(){
-  mysql_to_hdfs_lzo $url $username $password /warehouse/saga_dw/ods/ods_energy_5_min_fjd "building, func_id, meter, data_time, data_value" "select building, func_id, meter, data_time, data_value from energy_5_min_fjd where where dt = '$do_date'" ods_energy_5_min_fjd
+  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_5_min_fjd where where dt = '$do_date'" ods_energy_5_min_fjd
 }
 
 case $1 in