wudianlong 2 years ago
parent
commit
6f3cda6a97
1 changed files with 4 additions and 4 deletions
  1. 4 4
      energy/dayTask/mysql_to_hdfs.sh

+ 4 - 4
energy/dayTask/mysql_to_hdfs.sh

@@ -40,19 +40,19 @@ mysql_to_hdfs_lzo() {
 }
 
 ods_energy_15_min(){
-  import_no_partition $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/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
 }
 
 ods_energy_5_min(){
-  import_no_partition $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/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
 }
 
 ods_energy_15_min_fjd(){
-  import_no_partition $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/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
 }
 
 ods_energy_5_min_fjd(){
-  import_no_partition $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/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
 }
 
 case $1 in