Package com.semedy.reasoner.reasoning.processes

Class End

java.lang.Object

com.semedy.reasoner.reasoning.processes.ProcessImp

com.semedy.reasoner.reasoning.processes.End

All Implemented Interfaces:

Receiver, Process

public class End
extends ProcessImp
implements Receiver

a cap for a dead end in the data flow graph

Constructor Summary

Constructors

Constructor	Description
End(InterruptFlag interruptflag, int arity, ReasoningMonitor monitor)

Method Summary

Modifier and Type	Method	Description
int	getArity()	arity of the tuples
TupleStore	getTupleStore()	get the basic tuple store
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
void	tuplesFinished(boolean isBottomUp)	finish delivering single tuples
void	tuplesFinished(String annotation, ReasoningRelation R1, ReasoningRelation R2)	Finish delivering single tuples.

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

addNextReceiver, addRelation, clear, dispose, evaluate, evaluationFinished, evaluationFinished, getPriority, getStratum, isNotQueuedSetQueued, isQueued, nextReceiver, operationFinished, receiveRelation, setDataFlowGraph, setQueued, setStratum

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.semedy.reasoner.api.reasoning.Receiver

receiveRelation

Constructor Details

End

public End(InterruptFlag interruptflag,
 int arity,
 ReasoningMonitor monitor)

Method Details

getArity

public int getArity()

Description copied from interface: Receiver

arity of the tuples

Specified by:

getArity in interface Process

Specified by:

getArity in interface Receiver

Overrides:

getArity in class ProcessImp

Returns:

the arity of the receiver

startTuples

public Receiver startTuples(Receiver source,
 boolean check4Duplicates)

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

receiveTuple

public boolean receiveTuple(int tuple)
                     throws SemReasonerException

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

receiveTuple

public boolean receiveTuple(long[] tuple)
                     throws SemReasonerException

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

receiveTuple

public boolean receiveTuple(TupleBuffer tuple)
                     throws SemReasonerException

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

getTupleStore

public TupleStore getTupleStore()

Description copied from interface: Receiver

get the basic tuple store

Specified by:

getTupleStore in interface Process

Specified by:

getTupleStore in interface Receiver

Overrides:

getTupleStore in class ProcessImp

Returns:

the tuple store

tuplesFinished

public void tuplesFinished(String annotation,
 ReasoningRelation R1,
 ReasoningRelation R2)
                    throws ReasoningException,
InterruptedException

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

R1 - , the relations which have been combined

R2 - , the relations which have been combined

Throws:

ReasoningException

InterruptedException

tuplesFinished

public void tuplesFinished(boolean isBottomUp)
                    throws ReasoningException,
InterruptedException

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

InterruptedException