Skip to content

F
ffm-baseline
Commit 3ef41289 authored by 高雅喆's avatar 高雅喆
Browse files
Options

add esmm data

parent 630ff299
Hide whitespace changes
Inline Side-by-side
Showing with 3 additions and 2 deletions
eda/feededa/src/main/scala/com/gmei/EsmmData.scala
View file @ 3ef41289
...@@ -169,7 +169,7 @@ object EsmmData { ...@@ -169,7 +169,7 @@ object EsmmData {
""".stripMargin """.stripMargin
) )
union_data_ccity_name.createOrReplaceTempView("union_data_ccity_name") union_data_ccity_name.createOrReplaceTempView("union_data_ccity_name")
union_data_ccity_name.show() // union_data_ccity_name.show()
val union_data_scity_id = sc.sql( val union_data_scity_id = sc.sql(
s""" s"""
...@@ -184,8 +184,9 @@ object EsmmData { ...@@ -184,8 +184,9 @@ object EsmmData {
|and d.partition_date='${yesteday}' |and d.partition_date='${yesteday}'
""".stripMargin """.stripMargin
) )
union_data_scity_id.createOrReplaceTempView("union_data_scity_id") // union_data_scity_id.createOrReplaceTempView("union_data_scity_id")
union_data_scity_id.show() union_data_scity_id.show()
GmeiConfig.writeToJDBCTable(union_data_scity_id, table="esmm_data",SaveMode.Overwrite)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment