Commit 30b8ec88c884414b0886ffbf3c267181ad704d99

Authored by Joanne ago
1 parent cb5d3bfb42
Exists in master

typo in cidvalidation

Showing 1 changed file with 1 additions and 1 deletions Side-by-side Diff

app/com/piki_ds/preprocess/CidValidation.scala View file @ 30b8ec8
... ... @@ -31,7 +31,7 @@
31 31  
32 32 def getCidByStatus(sQLContext: SQLContext, filterStatus:Array[String]) = {
33 33 import org.apache.spark.sql.functions._
34   - val whereStr = s"udate id not null and title is not null and" +
  34 + val whereStr = s"udate id is not null and title is not null and" +
35 35 s" contents_type in ('ALBUM', 'ALBUM.A', 'CHST', 'CHST.A','TOON','TOON.A') and " +
36 36 s"status in (${filterStatus.map(x=>s"'$x'").mkString(",")})"
37 37 val mgc = getDBDump(sQLContext,"MG_CONTENTS").where(whereStr)