|
@@ -81,7 +81,7 @@ case class JustiCase(s: SparkSession,
|
|
|
|UNION
|
|
|
|SELECT *
|
|
|
|FROM $project.inc_ods_$tableName
|
|
|
- |WHERE ds=inc_ods_ds AND ${toCol} != NULL
|
|
|
+ |WHERE ds=inc_ods_ds AND ${toCol} == NULL
|
|
|
|""".stripMargin))//.show(100)
|
|
|
.createOrReplaceTempView(s"tmp_graphx_$tableName")
|
|
|
|