Project

General

Profile

« Previous | Next » 

Revision 54390

Added by Sandro La Bruzzo over 5 years ago

updated resolver and Trying to allow mdstore plugin to print progress information on UI

View differences:

MergeDLIRecord.java
6 6 
import eu.dnetlib.msro.workflows.procs.ProcessAware;
7 7 
import eu.dnetlib.msro.workflows.procs.Token;
8 8 
import eu.dnetlib.msro.workflows.procs.WorkflowProcess;
9 
import eu.dnetlib.msro.workflows.util.ProgressProvider;
9 10 
import eu.dnetlib.rmi.data.MDStoreService;
10 11 
import eu.dnetlib.rmi.enabling.ISLookUpService;
11 12 
import org.springframework.beans.factory.annotation.Autowired;
12 13 

  		




  13
  14
  
    
import java.util.List;


  		




  14
  15
  
    

  		




  15
  
  
    
public class MergeDLIRecord extends BlackboardJobNode implements ProcessAware {


  		




  
  16
  
    
public class MergeDLIRecord extends BlackboardJobNode implements ProcessAware, ProgressProvider {


  		




  16
  17
  
    

  		




  17
  18
  
    
    private final static String queryTemplate = "for $x in collection(' /db/DRIVER/RepositoryServiceResources/RepositoryServiceResourceType') where $x//RESOURCE_IDENTIFIER/@value/string()='%s' return $x//FIELD[./key='NamespacePrefix']/value/text()";


  		




  18
  19
  
    

  		




  ......




  28
  29
  
    

  		




  29
  30
  
    
    private String sparkPath;


  		




  30
  31
  
    

  		




  
  32
  
    
    private String numExecutor;


  		




  
  33
  
    

  		




  31
  34
  
    
    private boolean skipJob = false;


  		




  32
  35
  
    

  		




  33
  36
  
    
    private String sparkApplicationName;


  		




  ......




  62
  65
  
    
            job.getParameters().put("sparkPath", getSparkPath());


  		




  63
  66
  
    
            job.getParameters().put("sparkJobPath", getSparkJobPath());


  		




  64
  67
  
    
            job.getParameters().put("mongoDBName", getMongoDBName());


  		




  
  68
  
    
            job.getParameters().put("numExecutor", getNumExecutor());


  		




  65
  69
  
    
            job.getParameters().put("sparkApplicationName", process.getId());


  		




  66
  70
  
    
        }


  		




  67
  71
  
    

  		




  ......




  135
  139
  
    
    public void setDsId(String dsId) {


  		




  136
  140
  
    
        this.dsId = dsId;


  		




  137
  141
  
    
    }


  		




  
  142
  
    

  		




  
  143
  
    
    public String getNumExecutor() {


  		




  
  144
  
    
        return numExecutor;


  		




  
  145
  
    
    }


  		




  
  146
  
    

  		




  
  147
  
    
    public void setNumExecutor(String numExecutor) {


  		




  
  148
  
    
        this.numExecutor = numExecutor;


  		




  
  149
  
    
    }


  		




  
  150
  
    

  		




  
  151
  
    
    @Override


  		




  
  152
  
    
    public String getProgressDescription() {


  		




  
  153
  
    
        return null;


  		




  
  154
  
    
    }


  		




  138
  155
  
    
}


  		












Also available in:  Unified diff