Class LocalFileReader


  • public class LocalFileReader
    extends BaseFileReader
    Grabs work from the bucket database and dispatches items to the thread pool.
    • 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 -