Uses of Class
org.linuxforhealth.fhir.bucket.api.BucketLoaderJob
-
Packages that use BucketLoaderJob Package Description org.linuxforhealth.fhir.bucket.api org.linuxforhealth.fhir.bucket.persistence org.linuxforhealth.fhir.bucket.scanner -
-
Uses of BucketLoaderJob in org.linuxforhealth.fhir.bucket.api
Methods in org.linuxforhealth.fhir.bucket.api that return BucketLoaderJob Modifier and Type Method Description BucketLoaderJob
ResourceEntry. getJob()
Method parameters in org.linuxforhealth.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 org.linuxforhealth.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 org.linuxforhealth.fhir.bucket.persistence
Constructor parameters in org.linuxforhealth.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 org.linuxforhealth.fhir.bucket.scanner
Methods in org.linuxforhealth.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 org.linuxforhealth.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
-