public class Frontier extends Configurable
| Modifier and Type | Field and Description |
|---|---|
protected Counters |
counters |
protected DocIDServer |
docIdServer |
protected InProcessPagesDB |
inProcessPages |
protected boolean |
isFinished |
protected static org.apache.log4j.Logger |
logger |
protected Object |
mutex |
protected long |
scheduledPages |
protected Object |
waitingList |
protected WorkQueues |
workQueues |
config| Constructor and Description |
|---|
Frontier(com.sleepycat.je.Environment env,
CrawlConfig config,
DocIDServer docIdServer) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
void |
finish() |
void |
getNextURLs(int max,
List<WebURL> result) |
long |
getNumberOfAssignedPages() |
long |
getNumberOfProcessedPages() |
long |
getQueueLength() |
boolean |
isFinished() |
void |
schedule(WebURL url) |
void |
scheduleAll(List<WebURL> urls) |
void |
setProcessed(WebURL webURL) |
void |
sync() |
getConfigprotected static final org.apache.log4j.Logger logger
protected WorkQueues workQueues
protected InProcessPagesDB inProcessPages
protected final Object mutex
protected final Object waitingList
protected boolean isFinished
protected long scheduledPages
protected DocIDServer docIdServer
protected Counters counters
public Frontier(com.sleepycat.je.Environment env,
CrawlConfig config,
DocIDServer docIdServer)
public void schedule(WebURL url)
public void setProcessed(WebURL webURL)
public long getQueueLength()
public long getNumberOfAssignedPages()
public long getNumberOfProcessedPages()
public void sync()
public boolean isFinished()
public void close()
public void finish()
Copyright © 2013. All Rights Reserved.