D-Net
/
AriadnePlus
4
0
Fork 0
Code Issues Pull Requests 1 Releases Wiki Activity

removed progress bar handler attached to resultset client (not used here)

This commit is contained in:
Enrico Ottonello 2020-10-10 16:53:37 +02:00
parent 2aafbc8506
commit 8b3f8896a5
2 changed files with 0 additions and 54 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
dnet-ariadneplus/src/main/java/eu/dnetlib/ariadneplus/workflows/nodes/EnrichGraphDBContentJobNode.java
View File

@ -38,11 +38,6 @@ public class EnrichGraphDBContentJobNode extends AsyncJobNode {
private static final Log log = LogFactory.getLog(EnrichGraphDBContentJobNode.class); private static final Log log = LogFactory.getLog(EnrichGraphDBContentJobNode.class);
private String eprParam;
@Autowired
private ResultSetClient resultSetClient;
private String sparqlUpdateQuery; private String sparqlUpdateQuery;
private String publisherEndpoint; private String publisherEndpoint;
private String datasourceInterface; private String datasourceInterface;
@ -117,36 +112,14 @@ public class EnrichGraphDBContentJobNode extends AsyncJobNode {
this.publisherEndpoint = publisherEndpoint; this.publisherEndpoint = publisherEndpoint;
} }
public ResultSetClient getResultSetClient() {
return resultSetClient;
}
public void setResultSetClient(final ResultSetClient resultSetClient) {
this.resultSetClient = resultSetClient;
}
public String getEprParam() {
return eprParam;
}
public void setEprParam(String eprParam) {
this.eprParam = eprParam;
}
public String getDatasourceInterface() { public String getDatasourceInterface() {
return datasourceInterface; return datasourceInterface;
} }
public void setDatasourceInterface(String datasourceInterface) { public void setDatasourceInterface(String datasourceInterface) {
this.datasourceInterface = datasourceInterface; this.datasourceInterface = datasourceInterface;
} }
@Override
protected void beforeStart(Token token) {
token.setProgressProvider(new ResultsetProgressProvider(token.getEnv().getAttribute(getEprParam(), ResultSet.class), this.resultSetClient));
}
public String getDatasource() { public String getDatasource() {
return datasource; return datasource;
} }

27
dnet-ariadneplus/src/main/java/eu/dnetlib/ariadneplus/workflows/nodes/IndexOnESJobNode.java
View File

@ -37,11 +37,6 @@ public class IndexOnESJobNode extends AsyncJobNode {
private static final Log log = LogFactory.getLog(IndexOnESJobNode.class); private static final Log log = LogFactory.getLog(IndexOnESJobNode.class);
private String eprParam;
@Autowired
private ResultSetClient resultSetClient;
private String publisherEndpoint; private String publisherEndpoint;
private String datasourceInterface; private String datasourceInterface;
private String datasource; private String datasource;
@ -122,36 +117,14 @@ public class IndexOnESJobNode extends AsyncJobNode {
this.publisherEndpoint = publisherEndpoint; this.publisherEndpoint = publisherEndpoint;
} }
public ResultSetClient getResultSetClient() {
return resultSetClient;
}
public void setResultSetClient(final ResultSetClient resultSetClient) {
this.resultSetClient = resultSetClient;
}
public String getEprParam() {
return eprParam;
}
public void setEprParam(String eprParam) {
this.eprParam = eprParam;
}
public String getDatasourceInterface() { public String getDatasourceInterface() {
return datasourceInterface; return datasourceInterface;
} }
public void setDatasourceInterface(String datasourceInterface) { public void setDatasourceInterface(String datasourceInterface) {
this.datasourceInterface = datasourceInterface; this.datasourceInterface = datasourceInterface;
} }
@Override
protected void beforeStart(Token token) {
token.setProgressProvider(new ResultsetProgressProvider(token.getEnv().getAttribute(getEprParam(), ResultSet.class), this.resultSetClient));
}
public String getDatasource() { public String getDatasource() {
return datasource; return datasource;
} }