Class ChunkReader
- java.lang.Object
-
- javax.batch.api.chunk.AbstractItemReader
-
- com.ibm.fhir.jbatch.bulkdata.load.ChunkReader
-
- All Implemented Interfaces:
javax.batch.api.chunk.ItemReader
@Dependent public class ChunkReader extends javax.batch.api.chunk.AbstractItemReader
BulkData Import - ChunkReader
-
-
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 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
cosSrvinstId
The IBM COS service instance id or S3 secret key.(package private) String
dataSourceStorageType
The data source storage type.(package private) String
fhirDatastoreId
Data store id.(package private) String
fhirTenant
Tenant id.(package private) String
importPartitionResourceType
Resource type to process.(package private) String
importPartitionWorkitem
Work item to process.(package private) javax.batch.runtime.context.StepContext
stepCtx
-
Constructor Summary
Constructors Constructor Description ChunkReader()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Serializable
checkpointInfo()
void
close()
void
open(Serializable checkpoint)
Object
readItem()
-
-
-
Field Detail
-
stepCtx
@Inject javax.batch.runtime.context.StepContext stepCtx
-
dataSourceStorageType
@Inject String dataSourceStorageType
The data source storage type.
-
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 or S3 secret keys.
-
importPartitionWorkitem
@Inject String importPartitionWorkitem
Work item to process.
-
importPartitionResourceType
@Inject String importPartitionResourceType
Resource type to process.
-
fhirTenant
@Inject String fhirTenant
Tenant id.
-
fhirDatastoreId
@Inject String fhirDatastoreId
Data store id.
-
-
Method Detail
-
readItem
public Object readItem() throws Exception
- Specified by:
readItem
in interfacejavax.batch.api.chunk.ItemReader
- Specified by:
readItem
in classjavax.batch.api.chunk.AbstractItemReader
- Throws:
Exception
-
open
public void open(Serializable checkpoint) throws Exception
- Specified by:
open
in interfacejavax.batch.api.chunk.ItemReader
- Overrides:
open
in classjavax.batch.api.chunk.AbstractItemReader
- Throws:
Exception
-
close
public void close() throws Exception
- Specified by:
close
in interfacejavax.batch.api.chunk.ItemReader
- Overrides:
close
in classjavax.batch.api.chunk.AbstractItemReader
- Throws:
Exception
-
checkpointInfo
public Serializable checkpointInfo() throws Exception
- Specified by:
checkpointInfo
in interfacejavax.batch.api.chunk.ItemReader
- Overrides:
checkpointInfo
in classjavax.batch.api.chunk.AbstractItemReader
- Throws:
Exception
-
-