Commit bec43ca4cae7ec497e85224eed826b54068f3fbc

Authored by Joanne ago
1 parent 30b8ec88c8
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 @ bec43ca
... ... @@ -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 is not null and title is not null and" +
  34 + val whereStr = s"udate is not null and 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)