public class CrawlDocInfoService extends Object implements Closeable
Constructor and Description |
---|
CrawlDocInfoService(Crawler crawler,
Class<? extends CrawlDocInfo> type) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
boolean |
forEachActive(BiPredicate<String,CrawlDocInfo> predicate) |
boolean |
forEachCached(BiPredicate<String,CrawlDocInfo> predicate) |
boolean |
forEachProcessed(BiPredicate<String,CrawlDocInfo> predicate) |
boolean |
forEachQueued(BiPredicate<String,CrawlDocInfo> predicate) |
long |
getActiveCount() |
Optional<CrawlDocInfo> |
getCached(String id) |
Optional<CrawlDocInfo> |
getProcessed(String id) |
long |
getProcessedCount() |
CrawlDocInfo.Stage |
getProcessingStage(String id) |
long |
getQueueCount() |
boolean |
isActiveEmpty() |
boolean |
isProcessedEmpty() |
boolean |
isQueueEmpty() |
boolean |
open() |
Optional<CrawlDocInfo> |
pollQueue() |
void |
processed(CrawlDocInfo docInfo) |
void |
queue(CrawlDocInfo docInfo) |
public CrawlDocInfoService(Crawler crawler, Class<? extends CrawlDocInfo> type)
public boolean open()
public CrawlDocInfo.Stage getProcessingStage(String id)
public long getActiveCount()
public boolean isActiveEmpty()
public boolean forEachActive(BiPredicate<String,CrawlDocInfo> predicate)
public long getProcessedCount()
public boolean isProcessedEmpty()
public Optional<CrawlDocInfo> getProcessed(String id)
public void processed(CrawlDocInfo docInfo)
public boolean forEachProcessed(BiPredicate<String,CrawlDocInfo> predicate)
public boolean isQueueEmpty()
public long getQueueCount()
public void queue(CrawlDocInfo docInfo)
public Optional<CrawlDocInfo> pollQueue()
public boolean forEachQueued(BiPredicate<String,CrawlDocInfo> predicate)
public Optional<CrawlDocInfo> getCached(String id)
public boolean forEachCached(BiPredicate<String,CrawlDocInfo> predicate)
public void close()
close
in interface Closeable
close
in interface AutoCloseable
Copyright © 2014–2023 Norconex Inc.. All rights reserved.