Commit 9d7e85f6 authored by 高雅喆's avatar 高雅喆

nd data input test

parent 935dd341
...@@ -214,7 +214,7 @@ object NdDataInput { ...@@ -214,7 +214,7 @@ object NdDataInput {
val tidb_inupt = sc.sql( val tidb_inupt = sc.sql(
s""" s"""
|SELECT |SELECT
| ltrim('meigou|',service_id) as sid,ltrim('diary|',cid) as cid | split(service_id,'|')[1] as sid,split(cid,'|')[1] as cid
|FROM nd_data_meigou_cid |FROM nd_data_meigou_cid
|where stat_date > '${date8}' |where stat_date > '${date8}'
""".stripMargin """.stripMargin
...@@ -223,12 +223,6 @@ object NdDataInput { ...@@ -223,12 +223,6 @@ object NdDataInput {
tidb_inupt.show() tidb_inupt.show()
println(tidb_inupt.count()) println(tidb_inupt.count())
val result01 = sc.sql(
s"""
|select a.sid as sid, a.cid as cid, b.tag_id as
""".stripMargin
)
} }
......
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