Package com.semedy.reasoner.reasoning.processes

Class Scatter

java.lang.Object

com.semedy.reasoner.reasoning.processes.ProcessImp

com.semedy.reasoner.reasoning.processes.Scatter

All Implemented Interfaces:

Receiver, Process

public class Scatter
extends ProcessImp

Constructor Summary

Constructors

Constructor	Description
Scatter(InterruptFlag interruptFlag, int destarity, Rule rule, ReasoningMonitor monitor)

Method Summary

Modifier and Type	Method	Description
void	addNextReceiver(Receiver n)	attach a next receiver which receives input from this
List<Receiver>	getNeighbours()
boolean	receiveRelation(ReasoningRelation relation)	receive a whole relation
boolean	receiveTuple(int tuple)	receive a single tuple
boolean	receiveTuple(long[] tuple)	receive a single tuple
boolean	receiveTuple(TupleBuffer tuple)	receive a single tuple
Receiver	startTuples(Receiver source, boolean check4Duplicates)	start delivering single tuples
String	toString()
void	tuplesFinished(boolean isBottomUp)	finish delivering single tuples
void	tuplesFinished(String annotation, ReasoningRelation T1, ReasoningRelation T2)	Finish delivering single tuples.

Methods inherited from class com.semedy.reasoner.reasoning.processes.ProcessImp

addRelation, clear, dispose, evaluate, evaluationFinished, evaluationFinished, getArity, getPriority, getStratum, getTupleStore, isNotQueuedSetQueued, isQueued, nextReceiver, operationFinished, setDataFlowGraph, setQueued, setStratum

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

Scatter

public Scatter(InterruptFlag interruptFlag,
 int destarity,
 Rule rule,
 ReasoningMonitor monitor)

Parameters:

interruptFlag -

destarity -

rule -

monitor -

Method Details

addNextReceiver

public void addNextReceiver(Receiver n)

Description copied from interface: Process

attach a next receiver which receives input from this

Specified by:

addNextReceiver in interface Process

Overrides:

addNextReceiver in class ProcessImp

startTuples

public Receiver startTuples(Receiver source,
 boolean check4Duplicates)
                     throws IOException,
EDBException

Description copied from interface: Receiver

start delivering single tuples

Specified by:

startTuples in interface Receiver

Overrides:

startTuples in class ProcessImp

Parameters:

source - , the delivering process

check4Duplicates - , check for duplicates in the target store

Returns:

an object receiving the results

Throws:

IOException

EDBException

tuplesFinished

public void tuplesFinished(boolean isBottomUp)
                    throws SemReasonerException,
InterruptedException,
IOException

Description copied from interface: Receiver

finish delivering single tuples

Specified by:

tuplesFinished in interface Receiver

Overrides:

tuplesFinished in class ProcessImp

Parameters:

isBottomUp - TODO

Throws:

ReasoningException

SemReasonerException

InterruptedException

IOException

tuplesFinished

public void tuplesFinished(String annotation,
 ReasoningRelation T1,
 ReasoningRelation T2)
                    throws SemReasonerException,
InterruptedException,
IOException

Description copied from interface: Receiver

Finish delivering single tuples.
Cache result and annotate result.

Specified by:

tuplesFinished in interface Receiver

Overrides:

tuplesFinished in class ProcessImp

Parameters:

annotation - , an annotation used for caching

T1 - , the relations which have been combined

T2 - , the relations which have been combined

Throws:

ReasoningException

SemReasonerException

InterruptedException

IOException

receiveTuple

public boolean receiveTuple(int tuple)
                     throws SemReasonerException,
InterruptedException,
IOException

Description copied from interface: Receiver

receive a single tuple

Specified by:

receiveTuple in interface Receiver

Overrides:

receiveTuple in class ProcessImp

Parameters:

tuple - the tuple to be received

Returns:

true if tuple has been used (tuple cannot be free'd up)

Throws:

SemReasonerException

InterruptedException

IOException

receiveTuple

public boolean receiveTuple(long[] tuple)
                     throws SemReasonerException,
InterruptedException,
IOException

Description copied from interface: Receiver

receive a single tuple

Specified by:

receiveTuple in interface Receiver

Overrides:

receiveTuple in class ProcessImp

Parameters:

tuple - the tuple to be received

Returns:

true if tuple has been used (tuple cannot be free'd up)

Throws:

SemReasonerException

InterruptedException

IOException

receiveTuple

public boolean receiveTuple(TupleBuffer tuple)
                     throws SemReasonerException,
InterruptedException,
IOException

Description copied from interface: Receiver

receive a single tuple

Specified by:

receiveTuple in interface Receiver

Overrides:

receiveTuple in class ProcessImp

Parameters:

tuple - the tuple to be received

Returns:

true if tuple has been used (tuple cannot be free'd up)

Throws:

ReasoningException

SemReasonerException

InterruptedException

IOException

receiveRelation

public boolean receiveRelation(ReasoningRelation relation)
                        throws SemReasonerException,
InterruptedException,
IOException

Description copied from interface: Receiver

receive a whole relation

Specified by:

receiveRelation in interface Receiver

Overrides:

receiveRelation in class ProcessImp

Parameters:

relation - the whole relation to be received

Returns:

true, if relation is later on dissolved, false otherwise

Throws:

ReasoningException

InterruptedException

IOException

SemReasonerException

toString

public String toString()

Overrides:

toString in class Object

getNeighbours

public List<Receiver> getNeighbours()