Package com.ibm.fhir.bucket.scanner

Class LocalFileReader

java.lang.Object

com.ibm.fhir.bucket.scanner.BaseFileReader

com.ibm.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 com.ibm.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