Package org.linuxforhealth.fhir.bucket.scanner

Class COSReader

java.lang.Object

org.linuxforhealth.fhir.bucket.scanner.BaseFileReader

org.linuxforhealth.fhir.bucket.scanner.COSReader

public class COSReader
extends BaseFileReader

Grabs work from the bucket database and dispatches items to the thread pool.

Constructor Summary

Constructors

Constructor	Description
COSReader(java.util.concurrent.ExecutorService commonPool, FileType fileType, COSClient client, java.util.function.Consumer<ResourceEntry> resourceHandler, int maxInflight, DataAccess da, boolean incremental, int recycleSeconds, boolean incrementalExact, double bundleCostFactor, java.util.Collection<BucketPath> bucketPaths)	Public constructor

Method Summary

Modifier and Type	Method	Description
protected void	processThr(BucketLoaderJob job)	Process this job in a thread-pool thread

Methods inherited from class org.linuxforhealth.fhir.bucket.scanner.BaseFileReader

init, mainAllocationLoop, markJobDone, processJSON, processNDJSON, signalStop, validateInput, waitForStop

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

COSReader

public COSReader(java.util.concurrent.ExecutorService commonPool,
                 FileType fileType,
                 COSClient client,
                 java.util.function.Consumer<ResourceEntry> resourceHandler,
                 int maxInflight,
                 DataAccess da,
                 boolean incremental,
                 int recycleSeconds,
                 boolean incrementalExact,
                 double bundleCostFactor,
                 java.util.Collection<BucketPath> bucketPaths)

Public constructor

Parameters:

commonPool - thread pool shared by the readers and request handler

fileType - the file type this read is responsible for processing

client -

resourceHandler -

poolSize -

da -

incremental -

recycleSeconds -

Method Detail

processThr

protected void processThr(BucketLoaderJob job)

Description copied from class: BaseFileReader

Process this job in a thread-pool thread

Specified by:

processThr in class BaseFileReader