forked from D-Net/dnet-hadoop
added to all the entities the check that deletedbyinference = false
This commit is contained in:
parent
26cf32c066
commit
ad6d0ca9eb
|
@ -110,9 +110,11 @@ public class SparkSelectValidRelationsJob implements Serializable {
|
||||||
"UNION ALL " +
|
"UNION ALL " +
|
||||||
"SELECT id " +
|
"SELECT id " +
|
||||||
"FROM project " +
|
"FROM project " +
|
||||||
|
"WHERE datainfo.deletedbyinference = false AND datainfo.invisible = false " +
|
||||||
"UNION ALL " +
|
"UNION ALL " +
|
||||||
"SELECT id " +
|
"SELECT id " +
|
||||||
"FROM datasource ")
|
"FROM datasource " +
|
||||||
|
"WHERE datainfo.deletedbyinference = false AND datainfo.invisible = false " )
|
||||||
.createOrReplaceTempView("identifiers");
|
.createOrReplaceTempView("identifiers");
|
||||||
|
|
||||||
spark
|
spark
|
||||||
|
|
Loading…
Reference in New Issue