Package com.ibm.fhir.bulkdata.provider

Interface Provider

All Known Implementing Classes:

FileProvider, HttpsProvider, S3Provider

public interface Provider

Wraps the Complexities of a Source for the Given Type

Method Summary

Modifier and Type	Method	Description
void	close()
default void	createSource()	creates the base output location for the type.
long	getNumberOfLoaded()
long	getNumberOfParseFailures()
List<Resource>	getResources()	gets the read resources.
long	getSize(String workItem)	gets the size of the given work item.
default void	pushOperationOutcomes()	Pushes the Operation Outcomes
void	readResources(long numOfLinesToSkip, String workItem)	reads from a given workitem (or file) in a source and skips a certain noumber of lines
void	registerTransient(long executionId, ExportTransientUserData transientUserData, String cosBucketPathPrefix, String fhirResourceType, boolean isExportPublic)
void	registerTransient(ImportTransientUserData transientUserData)
default void	writeResources(String mediaType, List<ReadResultDTO> dtos)	wraps the complexity of writing FHIR Resources out to a target

Method Detail

getSize

long getSize(String workItem)
      throws FHIRException

gets the size of the given work item.

Parameters:

workItem -

Returns:

Throws:

FHIRException

readResources

void readResources(long numOfLinesToSkip,
                   String workItem)
            throws FHIRException

reads from a given workitem (or file) in a source and skips a certain noumber of lines

Parameters:

numOfLinesToSkip -

workItem -

Throws:

FHIRException

getResources

List<Resource> getResources()
                     throws FHIRException

gets the read resources.

Returns:

Throws:

FHIRException

writeResources

default void writeResources(String mediaType,
                            List<ReadResultDTO> dtos)
                     throws Exception

wraps the complexity of writing FHIR Resources out to a target

Parameters:

mediaType -

dtos -

Throws:

Exception

createSource

default void createSource()
                   throws FHIRException

creates the base output location for the type.

Throws:

FHIRException

getNumberOfParseFailures

long getNumberOfParseFailures()
                       throws FHIRException

Throws:

FHIRException

getNumberOfLoaded

long getNumberOfLoaded()
                throws FHIRException

Throws:

FHIRException

registerTransient

void registerTransient(ImportTransientUserData transientUserData)

registerTransient

void registerTransient(long executionId,
                       ExportTransientUserData transientUserData,
                       String cosBucketPathPrefix,
                       String fhirResourceType,
                       boolean isExportPublic)
                throws Exception

Throws:

Exception

pushOperationOutcomes

default void pushOperationOutcomes()
                            throws FHIRException

Pushes the Operation Outcomes

Throws:

FHIRException

close

void close()
    throws Exception

Throws:

Exception