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 done

Constructors 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 completes
void	DataAccess.markJobDone(BucketLoaderJob job)
protected void	ImmediateLocalFileReader.markJobDone(BucketLoaderJob job)	Callback when the last record in the job completes
protected 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 reader
void	ImmediateLocalFileReader.processNDJSON(BucketLoaderJob job, java.io.BufferedReader br)	Read the resources from the given reader
protected abstract void	BaseFileReader.processThr(BucketLoaderJob job)	Process this job in a thread-pool thread
protected 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