adding context information to projects and datasources #407
|
@ -95,7 +95,7 @@ public class SparkAtomicActionScoreJob implements Serializable {
|
|||
|
||||
return projectScores.map((MapFunction<BipProjectModel, Project>) bipProjectScores -> {
|
||||
Project project = new Project();
|
||||
// project.setId(bipProjectScores.getProjectId());
|
||||
project.setId(bipProjectScores.getProjectId());
|
||||
project.setMeasures(bipProjectScores.toMeasures());
|
||||
return project;
|
||||
}, Encoders.bean(Project.class))
|
||||
|
|
|
@ -89,7 +89,7 @@ public class SparkBulkTagJob {
|
|||
|
||||
log.info("pathMap: {}", parser.get("pathMap"));
|
||||
String protoMappingPath = parser.get("pathMap");
|
||||
// log.info("pathMap: {}", new Gson().toJson(protoMappingParams));
|
||||
|
||||
|
||||
final String hdfsNameNode = parser.get("nameNode");
|
||||
log.info("nameNode: {}", hdfsNameNode);
|
||||
|
|
Loading…
Reference in New Issue