forked from D-Net/dnet-hadoop
minor
This commit is contained in:
parent
a8100baed6
commit
c28333d43f
|
@ -64,7 +64,7 @@ public class PrepareResultInstRepoAssociation {
|
||||||
"where datainfo.deletedbyinference = false " +
|
"where datainfo.deletedbyinference = false " +
|
||||||
"and relClass = '" + RELATION_RESULT_ORGANIZATION_REL_CLASS +"' " +
|
"and relClass = '" + RELATION_RESULT_ORGANIZATION_REL_CLASS +"' " +
|
||||||
"group by source";
|
"group by source";
|
||||||
|
|
||||||
|
|
||||||
spark.sql(query)
|
spark.sql(query)
|
||||||
.as(Encoders.bean(ResultOrganizationSet.class))
|
.as(Encoders.bean(ResultOrganizationSet.class))
|
||||||
|
|
Loading…
Reference in New Issue