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

Class ChunkWriter

java.lang.Object

javax.batch.api.chunk.AbstractItemWriter

com.ibm.fhir.jbatch.bulkdata.load.ChunkWriter

All Implemented Interfaces:

javax.batch.api.chunk.ItemWriter

@Dependent
public class ChunkWriter
extends javax.batch.api.chunk.AbstractItemWriter

Bulk import Chunk implementation - the Writer.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) String	cosApiKeyProperty	The IBM COS API key or S3 access key.
(package private) com.ibm.cloud.objectstorage.services.s3.AmazonS3	cosClient
(package private) String	cosCredentialIbm	If use IBM credential or S3 secret keys.
(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	cosOperationOutcomesBucketName	The IBM COS or S3 bucket name for import OperationOutcomes.
(package private) String	cosSrvinstId	The IBM COS service instance id or S3 secret key.
(package private) String	fhirDatastoreId	Fhir data store id.
(package private) String	fhirTenant	Tenant id.
(package private) String	fhirValidation	If validate FHIR resources.
(package private) String	importPartitionResourceType	Resource Type to process.
(package private) String	incomingUrl
(package private) boolean	isValidationOn
(package private) javax.batch.runtime.context.StepContext	stepCtx

Constructor Summary

Constructors

Constructor	Description
ChunkWriter()

Method Summary

Modifier and Type	Method	Description
void	open(Serializable checkpoint)
void	writeItems(List<Object> arg0)

Methods inherited from class javax.batch.api.chunk.AbstractItemWriter

checkpointInfo, close

Methods inherited from class java.lang.Object

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

Field Detail

cosClient

com.ibm.cloud.objectstorage.services.s3.AmazonS3 cosClient

isValidationOn

boolean isValidationOn

stepCtx

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

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.

cosOperationOutcomesBucketName

@Inject
String cosOperationOutcomesBucketName

The IBM COS or S3 bucket name for import OperationOutcomes.

cosCredentialIbm

@Inject
String cosCredentialIbm

If use IBM credential or S3 secret keys.

fhirTenant

@Inject
String fhirTenant

Tenant id.

fhirDatastoreId

@Inject
String fhirDatastoreId

Fhir data store id.

importPartitionResourceType

@Inject
String importPartitionResourceType

Resource Type to process.

fhirValidation

@Inject
String fhirValidation

If validate FHIR resources.

incomingUrl

@Inject
String incomingUrl

Constructor Detail

ChunkWriter

public ChunkWriter()

Method Detail

writeItems

public void writeItems(List<Object> arg0)
                throws Exception

Specified by:

writeItems in interface javax.batch.api.chunk.ItemWriter

Specified by:

writeItems in class javax.batch.api.chunk.AbstractItemWriter

Throws:

Exception

open

public void open(Serializable checkpoint)
          throws Exception

Specified by:

open in interface javax.batch.api.chunk.ItemWriter

Overrides:

open in class javax.batch.api.chunk.AbstractItemWriter

Throws:

Exception