Class BulkDataClient
- java.lang.Object
-
- org.linuxforhealth.fhir.operation.bulkdata.client.BulkDataClient
-
public class BulkDataClient extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description BulkDataClient(java.lang.String bulkdataSource, java.lang.String outcomeSource, java.lang.String incomingUrl, java.lang.String baseUri, ConfigurationAdapter adapter)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description javax.ws.rs.core.Response.Status
delete(java.lang.String job)
deletes the given job.void
handleStandardResponseStatus(int httpStatus)
PollingLocationResponse
status(java.lang.String job)
java.lang.String
submitExport(Instant since, java.util.Set<java.lang.String> types, OperationConstants.ExportType exportType, java.lang.String outputFormat, java.lang.String typeFilters, java.lang.String groupId)
Submit the export job.java.lang.String
submitImport(java.lang.String inputFormat, java.lang.String inputSource, java.util.List<Input> inputs, StorageDetail storageDetail)
submit import job with bulkdata.void
verifyTenant(JobParameter jobParameters)
verifies the tenant based on the job parameters.
-
-
-
Constructor Detail
-
BulkDataClient
public BulkDataClient(java.lang.String bulkdataSource, java.lang.String outcomeSource, java.lang.String incomingUrl, java.lang.String baseUri, ConfigurationAdapter adapter)
- Parameters:
bulkdataSource
- the sourceoutcomeSource
-incomingUrl
-baseUri
-adapter
-
-
-
Method Detail
-
submitExport
public java.lang.String submitExport(Instant since, java.util.Set<java.lang.String> types, OperationConstants.ExportType exportType, java.lang.String outputFormat, java.lang.String typeFilters, java.lang.String groupId) throws java.lang.Exception
Submit the export job.- Parameters:
since
-types
-exportType
-outputFormat
-typeFilters
-groupId
-- Returns:
- Throws:
java.lang.Exception
-
status
public PollingLocationResponse status(java.lang.String job) throws java.lang.Exception
- Parameters:
job
-- Returns:
- a PollingLocationResponse or null if the job is still running
- Throws:
java.lang.Exception
-
handleStandardResponseStatus
public void handleStandardResponseStatus(int httpStatus) throws FHIROperationException
- Throws:
FHIROperationException
-
delete
public javax.ws.rs.core.Response.Status delete(java.lang.String job) throws FHIROperationException
deletes the given job.- Parameters:
job
-- Returns:
- status code
- Throws:
FHIROperationException
-
verifyTenant
public void verifyTenant(JobParameter jobParameters) throws FHIROperationException
verifies the tenant based on the job parameters.- Parameters:
jobParameters
-- Throws:
FHIROperationException
-
submitImport
public java.lang.String submitImport(java.lang.String inputFormat, java.lang.String inputSource, java.util.List<Input> inputs, StorageDetail storageDetail) throws java.lang.Exception
submit import job with bulkdata.- Parameters:
inputFormat
-inputSource
-inputs
-storageDetail
-- Returns:
- Throws:
java.lang.Exception
-
-