Jelajahi Sumber

建表语句更新

wudianlong 2 tahun lalu
induk
melakukan
6b8618c41c
1 mengubah file dengan 82 tambahan dan 0 penghapusan
  1. 82 0
      energy/dayTask/energy_hive.sql

+ 82 - 0
energy/dayTask/energy_hive.sql

@@ -83,6 +83,7 @@ LOCATION
 TBLPROPERTIES (
     'orc.compress'='lzo');
 
+/** 能源数据按小时 */
 create table saga_dw.dwd_energy_15_min_hour
 (
     building         string,
@@ -105,6 +106,87 @@ create table saga_dw.dwd_energy_15_min_hour
         'orc.compress' = 'lzo');
 
 
+/** CO2 15min 分精度 */
+create table ods_co2_15_min
+(
+    building   string,
+    func_id    string,
+    meter      string,
+    data_time  string,
+    data_value decimal(30, 15)
+) COMMENT '能源原始数据15min差值数据'
+    PARTITIONED BY (`dt` string)
+    ROW FORMAT DELIMITED FIELDS TERMINATED BY '\001'
+    STORED AS TEXTFILE
+    LOCATION
+        'hdfs://sagaCluster:8020/warehouse/saga_dw/ods/ods_co2_15_min'
+    TBLPROPERTIES (
+        'orc.compress'='lzo');
 
+/** PM2.5 15min 分精度 */
+create table ods_pm25_15_min
+(
+    building   string,
+    func_id    string,
+    meter      string,
+    data_time  string,
+    data_value decimal(30, 15)
+) COMMENT '能源原始数据15min差值数据'
+    PARTITIONED BY (`dt` string)
+    ROW FORMAT DELIMITED FIELDS TERMINATED BY '\001'
+    STORED AS TEXTFILE
+    LOCATION
+        'hdfs://sagaCluster:8020/warehouse/saga_dw/ods/ods_pm25_15_min'
+    TBLPROPERTIES (
+        'orc.compress'='lzo');
 
+/** 甲醛 15 分钟分精度 */
+create table ods_hcho_15_min
+(
+    building   string,
+    func_id    string,
+    meter      string,
+    data_time  string,
+    data_value decimal(30, 15)
+) COMMENT '能源原始数据15min差值数据'
+    PARTITIONED BY (`dt` string)
+    ROW FORMAT DELIMITED FIELDS TERMINATED BY '\001'
+    STORED AS TEXTFILE
+    LOCATION
+        'hdfs://sagaCluster:8020/warehouse/saga_dw/ods/ods_hcho_15_min'
+    TBLPROPERTIES (
+        'orc.compress'='lzo');
+
+/** 温度 15 分钟分精度 */
+create table ods_temperature_15_min
+(
+    building   string,
+    func_id    string,
+    meter      string,
+    data_time  string,
+    data_value decimal(30, 15)
+) COMMENT '能源原始数据15min差值数据'
+    PARTITIONED BY (`dt` string)
+    ROW FORMAT DELIMITED FIELDS TERMINATED BY '\001'
+    STORED AS TEXTFILE
+    LOCATION
+        'hdfs://sagaCluster:8020/warehouse/saga_dw/ods/ods_temperature_15_min'
+    TBLPROPERTIES (
+        'orc.compress'='lzo');
 
+/** 湿度 15 分钟分精度 */
+create table ods_humidity_15_min
+(
+    building   string,
+    func_id    string,
+    meter      string,
+    data_time  string,
+    data_value decimal(30, 15)
+) COMMENT '能源原始数据15min差值数据'
+    PARTITIONED BY (`dt` string)
+    ROW FORMAT DELIMITED FIELDS TERMINATED BY '\001'
+    STORED AS TEXTFILE
+    LOCATION
+        'hdfs://sagaCluster:8020/warehouse/saga_dw/ods/ods_humidity_15_min'
+    TBLPROPERTIES (
+        'orc.compress'='lzo');