Class Progress

    • Constructor Detail

      • Progress

        public Progress()
    • Method Detail

      • processDocument

        public void processDocument​(@NotNull
                                    @NotNull NodeDocument document,
                                    @NotNull
                                    @NotNull BlockingQueue<Result> results)
                             throws InterruptedException
        Description copied from interface: DocumentProcessor
        Process the given document and publish the result to the results queue. An implementation is not required to publish a result for each processed document.
        Specified by:
        processDocument in interface DocumentProcessor
        Parameters:
        document - the document to process.
        results - the queue to publish results if necessary.
        Throws:
        InterruptedException - if publishing a result is interrupted.
      • newProgressResult

        protected Result newProgressResult​(long numDocs,
                                           Path path)