forked from antonis.lempesis/dnet-hadoop
removed reference to isLookUp to get the communityMap
This commit is contained in:
parent
c378c38546
commit
1991a49f70
|
@ -47,15 +47,8 @@ public class SparkDumpCommunityProducts implements Serializable {
|
|||
|
||||
String communityMapPath = parser.get("communityMapPath");
|
||||
|
||||
final String isLookUpUrl = parser.get("isLookUpUrl");
|
||||
log.info("isLookUpUrl: {}", isLookUpUrl);
|
||||
|
||||
Class<? extends Result> inputClazz = (Class<? extends Result>) Class.forName(resultClassName);
|
||||
|
||||
queryInformationSystem = new QueryInformationSystem();
|
||||
queryInformationSystem.setIsLookUp(Utils.getIsLookUpService(isLookUpUrl));
|
||||
CommunityMap communityMap = queryInformationSystem.getCommunityMap();
|
||||
|
||||
DumpProducts dump = new DumpProducts();
|
||||
|
||||
dump
|
||||
|
@ -63,11 +56,6 @@ public class SparkDumpCommunityProducts implements Serializable {
|
|||
isSparkSessionManaged, inputPath, outputPath, communityMapPath, inputClazz, CommunityResult.class,
|
||||
false);
|
||||
|
||||
// dump
|
||||
// .run(
|
||||
// isSparkSessionManaged, inputPath, outputPath, communityMap, inputClazz, CommunityResult.class,
|
||||
// false);
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue