Package org.linuxforhealth.fhir.bucket.scanner

Class LocalFileReader

java.lang.Object

org.linuxforhealth.fhir.bucket.scanner.BaseFileReader

org.linuxforhealth.fhir.bucket.scanner.LocalFileReader

public class LocalFileReader
extends BaseFileReader

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

Constructor Summary

Constructors

Constructor	Description
LocalFileReader(java.util.concurrent.ExecutorService commonPool, FileType fileType, 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

LocalFileReader

public LocalFileReader(java.util.concurrent.ExecutorService commonPool,
                       FileType fileType,
                       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

resourceHandler -

poolSize -

da -

incremental -

recycleSeconds -

incrementalExact -

bundleCostFactor -

bucketPaths -

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