Class ChunkReader

  • All Implemented Interfaces:
    javax.batch.api.chunk.ItemReader

    @Dependent
    public class ChunkReader
    extends javax.batch.api.chunk.AbstractItemReader
    BulkData Import - ChunkReader
    • 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.
    • Constructor Detail

      • ChunkReader

        public ChunkReader()
    • Method Detail

      • readItem

        public Object readItem()
                        throws Exception
        Specified by:
        readItem in interface javax.batch.api.chunk.ItemReader
        Specified by:
        readItem in class javax.batch.api.chunk.AbstractItemReader
        Throws:
        Exception
      • open

        public void open​(Serializable checkpoint)
                  throws Exception
        Specified by:
        open in interface javax.batch.api.chunk.ItemReader
        Overrides:
        open in class javax.batch.api.chunk.AbstractItemReader
        Throws:
        Exception
      • close

        public void close()
                   throws Exception
        Specified by:
        close in interface javax.batch.api.chunk.ItemReader
        Overrides:
        close in class javax.batch.api.chunk.AbstractItemReader
        Throws:
        Exception
      • checkpointInfo

        public Serializable checkpointInfo()
                                    throws Exception
        Specified by:
        checkpointInfo in interface javax.batch.api.chunk.ItemReader
        Overrides:
        checkpointInfo in class javax.batch.api.chunk.AbstractItemReader
        Throws:
        Exception