ca.uqac.dim.turtledb

Class CentralizedCommunicator

java.lang.Object

ca.uqac.dim.turtledb.Communicator

ca.uqac.dim.turtledb.CentralizedCommunicator

All Implemented Interfaces:

java.lang.Runnable

public class CentralizedCommunicator
extends Communicator

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	CentralizedCommunicator.CentralizedQueryProcessor

Nested classes/interfaces inherited from class ca.uqac.dim.turtledb.Communicator

Communicator.QueryExecutionException

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.List<Relation>	m_results
protected java.util.Map<java.lang.String,Engine>	m_sites
protected static int	MAX_LOOPS

Constructor Summary

Constructors

Constructor and Description
CentralizedCommunicator()

Method Summary

Modifier and Type	Method and Description
void	addSite(Engine e)
QueryProcessor	getQueryProcessor(QueryPlan qp)
QueryProcessor	getQueryProcessor(Relation query)
QueryProcessor	getQueryProcessor(Relation query, java.lang.String site)
Engine	getSite(java.lang.String name)
protected boolean	loop() Iterates through one loop of communication and processing between sites.
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

m_sites

protected java.util.Map<java.lang.String,Engine> m_sites

m_results

protected java.util.List<Relation> m_results

MAX_LOOPS

protected static final int MAX_LOOPS

See Also:

Constant Field Values

Constructor Detail

CentralizedCommunicator

public CentralizedCommunicator()

Method Detail

run

public void run()

addSite

public void addSite(Engine e)

getSite

public Engine getSite(java.lang.String name)

loop

protected boolean loop()

Iterates through one loop of communication and processing between sites. The method returns false when no site has processed new data, i.e. when there is nothing left to do.

Returns:

True if any site has produced new data, false otherwise

getQueryProcessor

public QueryProcessor getQueryProcessor(Relation query)

Specified by:

getQueryProcessor in class Communicator

getQueryProcessor

public QueryProcessor getQueryProcessor(Relation query,
                                        java.lang.String site)

getQueryProcessor

public QueryProcessor getQueryProcessor(QueryPlan qp)

Specified by:

getQueryProcessor in class Communicator