edu.uci.ics.crawler4j.frontier

Class WorkQueues

java.lang.Object

edu.uci.ics.crawler4j.frontier.WorkQueues

Direct Known Subclasses:

InProcessPagesDB

public class WorkQueues
extends Object

Author:

Yasser Ganjisaffar

Field Summary

Fields

Modifier and Type	Field and Description
protected com.sleepycat.je.Environment	env
protected Object	mutex
protected boolean	resumable
protected com.sleepycat.je.Database	urlsDB
protected WebURLTupleBinding	webURLBinding

Constructor Summary

Constructors

Constructor and Description
WorkQueues(com.sleepycat.je.Environment env, String dbName, boolean resumable)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	delete(int count)
List<WebURL>	get(int max)
protected com.sleepycat.je.DatabaseEntry	getDatabaseEntryKey(WebURL url)
long	getLength()
void	put(WebURL url)
void	sync()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

urlsDB

protected com.sleepycat.je.Database urlsDB

env

protected com.sleepycat.je.Environment env

resumable

protected boolean resumable

webURLBinding

protected WebURLTupleBinding webURLBinding

mutex

protected final Object mutex

Constructor Detail

WorkQueues

public WorkQueues(com.sleepycat.je.Environment env,
          String dbName,
          boolean resumable)
           throws com.sleepycat.je.DatabaseException

Throws:

com.sleepycat.je.DatabaseException

Method Detail

get

public List<WebURL> get(int max)
                 throws com.sleepycat.je.DatabaseException

Throws:

com.sleepycat.je.DatabaseException

delete

public void delete(int count)
            throws com.sleepycat.je.DatabaseException

Throws:

com.sleepycat.je.DatabaseException

getDatabaseEntryKey

protected com.sleepycat.je.DatabaseEntry getDatabaseEntryKey(WebURL url)

put

public void put(WebURL url)
         throws com.sleepycat.je.DatabaseException

Throws:

com.sleepycat.je.DatabaseException

getLength

public long getLength()

sync

public void sync()

close

public void close()