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

+ 5 - 5
energy/history/mysql_to_hdfs.sh

@@ -13,7 +13,7 @@ import_no_partition() {
   --connect $1 \
   --username $2 \
   --password $3 \
-  --target-dir $4   \
+  --target-dir $4$7   \
   --delete-target-dir \
   --columns "$5"  \
   --query "$6  and  \$CONDITIONS" \
@@ -31,19 +31,19 @@ import_no_partition() {
 }
 
 ods_energy_15_min_history(){
-  import_no_partition $url $username $password /warehouse/saga_dw/ods/ods_energy_15_min_history "building, func_id, meter, data_time, data_value, dt" "select building, func_id, meter, data_time, data_value, dt from energy_15_min_history where 1 = 1" ods_energy_15_min_history
+  import_no_partition $url $username $password /warehouse/saga_dw/ods/ods_tmp_data/ "building, func_id, meter, data_time, data_value, dt" "select building, func_id, meter, data_time, data_value, dt from energy_15_min_history where 1 = 1" ods_energy_15_min_history
 }
 
 ods_energy_5_min_history(){
-  import_no_partition $url $username $password /warehouse/saga_dw/ods/ods_energy_5_min_history "building, func_id, meter, data_time, data_value, dt" "select building, func_id, meter, data_time, data_value, dt from energy_5_min_history where 1 = 1" ods_energy_5_min_history
+  import_no_partition $url $username $password /warehouse/saga_dw/ods/ods_tmp_data/ "building, func_id, meter, data_time, data_value, dt" "select building, func_id, meter, data_time, data_value, dt from energy_5_min_history where 1 = 1" ods_energy_5_min_history
 }
 
 ods_energy_15_min_fjd_history(){
-  import_no_partition $url $username $password /warehouse/saga_dw/ods/ods_energy_15_min_fjd_history "building, func_id, meter, data_time, data_value, dt" "select building, func_id, meter, data_time, data_value, dt from energy_15_min_fjd_history where 1 = 1" ods_energy_15_min_fjd_history
+  import_no_partition $url $username $password /warehouse/saga_dw/ods/ods_tmp_data/ "building, func_id, meter, data_time, data_value, dt" "select building, func_id, meter, data_time, data_value, dt from energy_15_min_fjd_history where 1 = 1" ods_energy_15_min_fjd_history
 }
 
 ods_energy_5_min_fjd_history(){
-  import_no_partition $url $username $password /warehouse/saga_dw/ods/ods_energy_5_min_fjd_history "building, func_id, meter, data_time, data_value, dt" "select building, func_id, meter, data_time, data_value, dt from energy_5_min_fjd_history where 1 = 1" ods_energy_5_min_fjd_history
+  import_no_partition $url $username $password /warehouse/saga_dw/ods/ods_tmp_data/ "building, func_id, meter, data_time, data_value, dt" "select building, func_id, meter, data_time, data_value, dt from energy_5_min_fjd_history where 1 = 1" ods_energy_5_min_fjd_history
 }
 
 case $1 in