Package com.ibm.fhir.jbatch.bulkdata.load

Class ImportPartitionMapper

java.lang.Object

com.ibm.fhir.jbatch.bulkdata.load.ImportPartitionMapper

All Implemented Interfaces:

javax.batch.api.partition.PartitionMapper

@Dependent
public class ImportPartitionMapper
extends Object
implements javax.batch.api.partition.PartitionMapper

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	ImportPartitionMapper.FhirDataSource

Field Summary

Fields

Modifier and Type	Field	Description
(package private) String	cosApiKeyProperty	The IBM COS API key or S3 access key.
(package private) String	cosBucketName	The IBM COS or S3 bucket name to import from.
(package private) String	cosCredentialIbm	If use IBM credential.
(package private) String	cosEndpointUrl	The IBM COS or S3 End point URL.
(package private) String	cosLocation	The IBM COS or S3 location.
(package private) String	cosSrvinstId	The IBM COS service instance id or S3 secret key.
(package private) String	dataSourcesInfo	The data sources info - base64 encoded data sources in Json array like following:
(package private) String	dataSourceStorageType	The data source storage type.
(package private) String	fhirDatastoreId	Fhir data store id.
(package private) String	fhirTenant	Fhir tenant id.
(package private) javax.batch.runtime.context.StepContext	stepCtx

Constructor Summary

Constructors

Constructor	Description
ImportPartitionMapper()

Method Summary

Modifier and Type	Method	Description
javax.batch.api.partition.PartitionPlan	mapPartitions()

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

stepCtx

@Inject
javax.batch.runtime.context.StepContext stepCtx

dataSourceStorageType

@Inject
String dataSourceStorageType

The data source storage type. e.g, https, file, aws-s3, ibm-cos

dataSourcesInfo

@Inject
String dataSourcesInfo

The data sources info - base64 encoded data sources in Json array like following:

https

       [{
         "type": "Patient",
         "url": "https://client.example.org/patient_file_2.ndjson?sig=RHIX5Xcg0Mq2rqI3OlWT"
        },{
         "type": "Observations",
         "url": "https://client.example.org/obseration_file_19.ndjson?sig=RHIX5Xcg0Mq2rqI3OlWT"
       }]
 

ibm-cos or aws-s3

       [{
          "type": "Patient",
          "url": "QHvFOj705i+9+WQXmuMHuiyH/QDCAZLl86aS6GydVp4=/Patient_1.ndjson"
        },{
          "type": "Observations",
          "url": "QHvFOj705i+9+WQXmuMHuiyH/QDCAZLl86aS6GydVp4=/Observation_1.ndjson"
        }]
 

file

       [{
          "type": "Patient",
          "url": "/tmp/Patient_1.ndjson"
        },{
          "type": "Observations",
          "url": "/tmp/Observation_1.ndjson"
        }]
 

cosApiKeyProperty

@Inject
String cosApiKeyProperty

The IBM COS API key or S3 access key.

cosSrvinstId

@Inject
String cosSrvinstId

The IBM COS service instance id or S3 secret key.

cosEndpointUrl

@Inject
String cosEndpointUrl

The IBM COS or S3 End point URL.

cosLocation

@Inject
String cosLocation

The IBM COS or S3 location.

cosBucketName

@Inject
String cosBucketName

The IBM COS or S3 bucket name to import from.

cosCredentialIbm

@Inject
String cosCredentialIbm

If use IBM credential.

fhirTenant

@Inject
String fhirTenant

Fhir tenant id.

fhirDatastoreId

@Inject
String fhirDatastoreId

Fhir data store id.

Constructor Detail

ImportPartitionMapper

public ImportPartitionMapper()

Method Detail

mapPartitions

public javax.batch.api.partition.PartitionPlan mapPartitions()
                                                      throws Exception

Specified by:

mapPartitions in interface javax.batch.api.partition.PartitionMapper

Throws:

Exception