Procházet zdrojové kódy

扩充日志信息

xufei před 4 roky
rodič
revize
bdb3cb5bdb

+ 6 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/CompanyCourtAnnouncement.scala

@@ -85,7 +85,12 @@ case class CompanyCourtAnnouncement(s: SparkSession, sourceTable: String,
       "score", "total", "extraScore")
       .createOrReplaceTempView(s"${sourceTable}_tmp_view")
 
-    sql(s"select * from ${sourceTable}_tmp_view").show(100)
+    logger.info(
+      s"""
+         |- - - - - - - - - - - - - - - - - - - - - - - - -
+         |${showString(sql(s"select * from ${sourceTable}_tmp_view"))}
+         |- - - - - - - - - - - - - - - - - - - - - - - - -
+       """.stripMargin)
 
     sql(s"insert overwrite table ${sourceTable}_score  select * from ${sourceTable}_tmp_view")