Uses of Class
com.ibm.fhir.bucket.api.BucketLoaderJob
-
Packages that use BucketLoaderJob Package Description com.ibm.fhir.bucket.api com.ibm.fhir.bucket.persistence com.ibm.fhir.bucket.scanner -
-
Uses of BucketLoaderJob in com.ibm.fhir.bucket.api
Methods in com.ibm.fhir.bucket.api that return BucketLoaderJob Modifier and Type Method Description BucketLoaderJob
ResourceEntry. getJob()
Method parameters in com.ibm.fhir.bucket.api with type arguments of type BucketLoaderJob Modifier and Type Method Description void
BucketLoaderJob. registerCallback(java.util.function.Consumer<BucketLoaderJob> cb)
Register a Consumer to call back when the job is doneConstructors in com.ibm.fhir.bucket.api with parameters of type BucketLoaderJob Constructor Description ResourceEntry(BucketLoaderJob job, Resource resource, int lineNumber, int cost)
Public constructor -
Uses of BucketLoaderJob in com.ibm.fhir.bucket.persistence
Constructor parameters in com.ibm.fhir.bucket.persistence with type arguments of type BucketLoaderJob Constructor Description AllocateJobs(java.lang.String schemaName, java.util.List<BucketLoaderJob> jobList, FileType fileType, long loaderInstanceId, int free, java.util.Collection<BucketPath> bucketPaths)
Public constructor -
Uses of BucketLoaderJob in com.ibm.fhir.bucket.scanner
Methods in com.ibm.fhir.bucket.scanner with parameters of type BucketLoaderJob Modifier and Type Method Description protected void
BaseFileReader. markJobDone(BucketLoaderJob job)
Callback when the last record in the job completesvoid
DataAccess. markJobDone(BucketLoaderJob job)
protected void
ImmediateLocalFileReader. markJobDone(BucketLoaderJob job)
Callback when the last record in the job completesprotected boolean
ImmediateLocalFileReader. process(BucketLoaderJob job, Resource resource, int lineNumber, java.lang.String line)
Process the resource parsed from the input stream.protected void
BaseFileReader. processJSON(BucketLoaderJob job, java.io.Reader reader)
Process a JSON stream (as opposed to an NDJSON stream)protected void
BaseFileReader. processNDJSON(BucketLoaderJob job, java.io.BufferedReader br)
Read the resources from the given readervoid
ImmediateLocalFileReader. processNDJSON(BucketLoaderJob job, java.io.BufferedReader br)
Read the resources from the given readerprotected abstract void
BaseFileReader. processThr(BucketLoaderJob job)
Process this job in a thread-pool threadprotected void
COSReader. processThr(BucketLoaderJob job)
protected void
LocalFileReader. processThr(BucketLoaderJob job)
Method parameters in com.ibm.fhir.bucket.scanner with type arguments of type BucketLoaderJob Modifier and Type Method Description void
DataAccess. allocateJobs(java.util.List<BucketLoaderJob> jobList, FileType fileType, int free, int recycleSeconds, java.util.Collection<BucketPath> bucketPaths)
Allocate up to free jobs to this loader instance
-