Class BulkDataImportSvcImpl

java.lang.Object
ca.uhn.fhir.jpa.bulk.imprt.svc.BulkDataImportSvcImpl
All Implemented Interfaces:
ca.uhn.fhir.jpa.bulk.imprt.api.IBulkDataImportSvc

public class BulkDataImportSvcImpl extends Object implements ca.uhn.fhir.jpa.bulk.imprt.api.IBulkDataImportSvc
  • Constructor Details

  • Method Details

    • start

      @PostConstruct public void start()
    • createNewJob

      public String createNewJob(ca.uhn.fhir.jpa.bulk.imprt.model.BulkImportJobJson theJobDescription, @Nonnull List<ca.uhn.fhir.jpa.bulk.imprt.model.BulkImportJobFileJson> theInitialFiles)
      Specified by:
      createNewJob in interface ca.uhn.fhir.jpa.bulk.imprt.api.IBulkDataImportSvc
    • addFilesToJob

      public void addFilesToJob(String theJobId, List<ca.uhn.fhir.jpa.bulk.imprt.model.BulkImportJobFileJson> theFiles)
      Specified by:
      addFilesToJob in interface ca.uhn.fhir.jpa.bulk.imprt.api.IBulkDataImportSvc
    • markJobAsReadyForActivation

      public void markJobAsReadyForActivation(String theJobId)
      Specified by:
      markJobAsReadyForActivation in interface ca.uhn.fhir.jpa.bulk.imprt.api.IBulkDataImportSvc
    • activateNextReadyJob

      public boolean activateNextReadyJob()
      To be called by the job scheduler
      Specified by:
      activateNextReadyJob in interface ca.uhn.fhir.jpa.bulk.imprt.api.IBulkDataImportSvc
    • setJobToStatus

      public void setJobToStatus(String theJobId, ca.uhn.fhir.jpa.bulk.imprt.model.BulkImportJobStatusEnum theStatus)
      Specified by:
      setJobToStatus in interface ca.uhn.fhir.jpa.bulk.imprt.api.IBulkDataImportSvc
    • setJobToStatus

      public void setJobToStatus(String theJobId, ca.uhn.fhir.jpa.bulk.imprt.model.BulkImportJobStatusEnum theStatus, String theStatusMessage)
      Specified by:
      setJobToStatus in interface ca.uhn.fhir.jpa.bulk.imprt.api.IBulkDataImportSvc
    • fetchJob

      public ca.uhn.fhir.jpa.bulk.imprt.model.BulkImportJobJson fetchJob(String theJobId)
      Specified by:
      fetchJob in interface ca.uhn.fhir.jpa.bulk.imprt.api.IBulkDataImportSvc
    • getJobStatus

      public ca.uhn.fhir.jpa.bulk.imprt.api.IBulkDataImportSvc.JobInfo getJobStatus(String theJobId)
      Specified by:
      getJobStatus in interface ca.uhn.fhir.jpa.bulk.imprt.api.IBulkDataImportSvc
    • fetchFile

      public ca.uhn.fhir.jpa.bulk.imprt.model.BulkImportJobFileJson fetchFile(String theJobId, int theFileIndex)
      Specified by:
      fetchFile in interface ca.uhn.fhir.jpa.bulk.imprt.api.IBulkDataImportSvc
    • getFileDescription

      public String getFileDescription(String theJobId, int theFileIndex)
      Specified by:
      getFileDescription in interface ca.uhn.fhir.jpa.bulk.imprt.api.IBulkDataImportSvc
    • deleteJobFiles

      public void deleteJobFiles(String theJobId)
      Specified by:
      deleteJobFiles in interface ca.uhn.fhir.jpa.bulk.imprt.api.IBulkDataImportSvc