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
All Methods Instance Methods Concrete Methods 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
-
-
-
-
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 handlerresourceHandler
-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 classBaseFileReader
-
-