Class FileProvider
- java.lang.Object
-
- org.linuxforhealth.fhir.bulkdata.provider.impl.FileProvider
-
-
Constructor Summary
Constructors Constructor Description FileProvider(java.lang.String source)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
Closes the StorageProvider wrapped resources.long
getNumberOfLoaded()
long
getNumberOfParseFailures()
java.util.List<Resource>
getResources()
gets the read resources.long
getSize(java.lang.String workItem)
gets the size of the given work item.void
pushEndOfJobOperationOutcomes(java.io.ByteArrayOutputStream baos, java.lang.String folder, java.lang.String fileName)
Pushes End of Job OperationOutcomes and closes the Outcomes StorageProvidervoid
readResources(long numOfLinesToSkip, java.lang.String workItem)
reads from a given workitem (or file) in a source and skips a certain noumber of linesvoid
registerTransient(long executionId, ExportTransientUserData transientUserData, java.lang.String exportPathPrefix, java.lang.String fhirResourceType)
void
registerTransient(ImportTransientUserData transientUserData)
void
writeResources(java.lang.String mediaType, java.util.List<ReadResultDTO> dtos)
wraps the complexity of writing FHIR Resources out to a target-
Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.linuxforhealth.fhir.bulkdata.provider.Provider
createSource, pushOperationOutcomes
-
-
-
-
Method Detail
-
getSize
public long getSize(java.lang.String workItem) throws FHIRException
Description copied from interface:Provider
gets the size of the given work item.- Specified by:
getSize
in interfaceProvider
- Returns:
- Throws:
FHIRException
-
readResources
public void readResources(long numOfLinesToSkip, java.lang.String workItem) throws FHIRException
Description copied from interface:Provider
reads from a given workitem (or file) in a source and skips a certain noumber of lines- Specified by:
readResources
in interfaceProvider
- Throws:
FHIRException
-
getResources
public java.util.List<Resource> getResources() throws FHIRException
Description copied from interface:Provider
gets the read resources.- Specified by:
getResources
in interfaceProvider
- Returns:
- Throws:
FHIRException
-
getNumberOfParseFailures
public long getNumberOfParseFailures() throws FHIRException
- Specified by:
getNumberOfParseFailures
in interfaceProvider
- Throws:
FHIRException
-
registerTransient
public void registerTransient(ImportTransientUserData transientUserData)
- Specified by:
registerTransient
in interfaceProvider
-
getNumberOfLoaded
public long getNumberOfLoaded() throws FHIRException
- Specified by:
getNumberOfLoaded
in interfaceProvider
- Throws:
FHIRException
-
registerTransient
public void registerTransient(long executionId, ExportTransientUserData transientUserData, java.lang.String exportPathPrefix, java.lang.String fhirResourceType) throws java.lang.Exception
- Specified by:
registerTransient
in interfaceProvider
- Throws:
java.lang.Exception
-
close
public void close() throws java.lang.Exception
Description copied from interface:Provider
Closes the StorageProvider wrapped resources.
-
writeResources
public void writeResources(java.lang.String mediaType, java.util.List<ReadResultDTO> dtos) throws java.lang.Exception
Description copied from interface:Provider
wraps the complexity of writing FHIR Resources out to a target- Specified by:
writeResources
in interfaceProvider
- Throws:
java.lang.Exception
-
pushEndOfJobOperationOutcomes
public void pushEndOfJobOperationOutcomes(java.io.ByteArrayOutputStream baos, java.lang.String folder, java.lang.String fileName) throws FHIRException
Description copied from interface:Provider
Pushes End of Job OperationOutcomes and closes the Outcomes StorageProvider- Specified by:
pushEndOfJobOperationOutcomes
in interfaceProvider
- Parameters:
baos
- the byte array output stream that is passed infolder
- the folder where the file is to be storedfileName
- the output filename to be used- Throws:
FHIRException
-
-