Package com.semedy.reasoner.reasoning.processes

Class ReasoningRelation

java.lang.Object

com.semedy.reasoner.reasoning.processes.ReasoningRelation

All Implemented Interfaces:

Closeable, AutoCloseable, Cloneable

public class ReasoningRelation
extends Object
implements Closeable, Cloneable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	ReasoningRelation.TuplesOrigin

Field Summary

Fields

Modifier and Type	Field	Description
static boolean	bulk

Constructor Summary

Constructors

Constructor	Description
ReasoningRelation(int arity, BaseRelation tuples, ReasoningMonitor monitor, boolean cepReasoning)
ReasoningRelation(int arity, Relation tuples, ReasoningMonitor monitor, boolean cepReasoning)
ReasoningRelation(int arity, TupleStore tuplestore, ReasoningMonitor monitor, boolean cepReasoning)
ReasoningRelation(Relation T, String p, ReasoningMonitor monitor, boolean streamReasoningWithRetracts)	create a reasoning relation out of an edb relation
ReasoningRelation(String name, int arity, TupleStore tuplestore, boolean duplicates, ReasoningMonitor monitor, boolean cepReasoning)

Method Summary

Modifier and Type	Method	Description
boolean	addTuple(int tupleaddress)
boolean	addTuple(long[] tuple)
boolean	addTuple(TupleBuffer tuple)
JoinStatistics	blockJoin(InterruptFlag interrupt, ReasoningRelation[] relations)
void	clear()
Object	clone()
void	close()
TupleEnumerator	elements()
int	getArity()
BaseRelation	getBaseRelation()	get the base relation
long[]	getFilter()
long[]	getGrounds()
String	getIdentifier()
String	getName()
ReasoningRelation.TuplesOrigin	getOrigin()
String	getPredicate()	get the predicate the relation stands for
int[]	getProjection()
TupleStore	getTupleStore()
boolean	hasDuplicates()	may relation contain duplicates ?
boolean	isDirectEncoded(int arg)	are all values at argument direct encoded
boolean	isEmpty()	is relation empty
boolean	isPersistent()
JoinStatistics	join(InterruptFlag interrupt, int[] compare1, ReasoningRelation R, int[] compare2, int[] source1, int[] dest1, int[] source2, int[] dest2, long[] externalFilter1, long[] externalFilter2, int destarity, Receiver receiver, com.semedy.reasoner.reasoning.processes.EvaluationThread evalThread, boolean streamReasoning, com.semedy.reasoner.reasoning.processes.SystemMonitor.JoinType joinType)
void	project(int[] map, int newArity)	project to selected arguments E.g. if map = [2,1] this means that argument at position 2 gets mapped to position 0 and argument at position 1 gets mapped to argument at position 1
boolean	removeTuple(int tupleaddress)
boolean	removeTuple(long[] tuple)
boolean	removeTuple(TupleBuffer tuple)
boolean	select(long[] filter)
boolean	setGrounds(long[] grounds)
void	setName(String name)
void	setOrigin(ReasoningRelation.TuplesOrigin s)
void	setPredicate(String predicate)	set the predicate the relation represents
void	shrinkArity(int arity)
long	size()
long	sizeInBytes()
String	toString()
void	union(ReasoningRelation tuples)

Methods inherited from class java.lang.Object

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

Field Details

bulk

public static boolean bulk

Constructor Details

ReasoningRelation

public ReasoningRelation(int arity,
 BaseRelation tuples,
 ReasoningMonitor monitor,
 boolean cepReasoning)

ReasoningRelation

public ReasoningRelation(int arity,
 Relation tuples,
 ReasoningMonitor monitor,
 boolean cepReasoning)

ReasoningRelation

public ReasoningRelation(int arity,
 TupleStore tuplestore,
 ReasoningMonitor monitor,
 boolean cepReasoning)

ReasoningRelation

public ReasoningRelation(String name,
 int arity,
 TupleStore tuplestore,
 boolean duplicates,
 ReasoningMonitor monitor,
 boolean cepReasoning)

ReasoningRelation

public ReasoningRelation(Relation T,
 String p,
 ReasoningMonitor monitor,
 boolean streamReasoningWithRetracts)
                  throws EDBException,
IOException

create a reasoning relation out of an edb relation

Parameters:

T -

p -

streamReasoningWithRetracts -

Throws:

IOException

EDBException

Method Details

hasDuplicates

public boolean hasDuplicates()

may relation contain duplicates ?

Returns:

setPredicate

public void setPredicate(String predicate)

set the predicate the relation represents

Parameters:

predicate -

getPredicate

public String getPredicate()

get the predicate the relation stands for

Returns:

getBaseRelation

public BaseRelation getBaseRelation()

get the base relation

Returns:

isDirectEncoded

public boolean isDirectEncoded(int arg)

are all values at argument direct encoded

Parameters:

arg -

Returns:

sizeInBytes

public long sizeInBytes()

clone

public Object clone()

toString

public String toString()

Overrides:

toString in class Object

size

public long size()
          throws IOException,
EDBException

Throws:

IOException

EDBException

shrinkArity

public void shrinkArity(int arity)

setOrigin

public void setOrigin(ReasoningRelation.TuplesOrigin s)

getOrigin

public ReasoningRelation.TuplesOrigin getOrigin()

setGrounds

public boolean setGrounds(long[] grounds)

select

public boolean select(long[] filter)

addTuple

public boolean addTuple(int tupleaddress)
                 throws IOException,
EDBException

Throws:

IOException

EDBException

addTuple

public boolean addTuple(long[] tuple)
                 throws IOException,
EDBException

Throws:

IOException

EDBException

addTuple

public boolean addTuple(TupleBuffer tuple)
                 throws IOException,
EDBException

Throws:

IOException

EDBException

removeTuple

public boolean removeTuple(int tupleaddress)
                    throws IOException,
EDBException

Throws:

IOException

EDBException

removeTuple

public boolean removeTuple(long[] tuple)
                    throws IOException,
EDBException

Throws:

IOException

EDBException

removeTuple

public boolean removeTuple(TupleBuffer tuple)
                    throws IOException,
EDBException

Throws:

IOException

EDBException

isPersistent

public boolean isPersistent()

blockJoin

public JoinStatistics blockJoin(InterruptFlag interrupt,
 ReasoningRelation[] relations)
                         throws EDBException,
IOException

Throws:

EDBException

IOException

project

public void project(int[] map,
 int newArity)
             throws EDBException,
IOException

project to selected arguments
E.g. if map = [2,1] this means that argument at position 2 gets mapped to position 0
and argument at position 1 gets mapped to argument at position 1

Parameters:

map -

newArity -

Throws:

IOException

EDBException

getProjection

public int[] getProjection()

getGrounds

public long[] getGrounds()

getName

public String getName()

setName

public void setName(String name)

getIdentifier

public String getIdentifier()

getFilter

public long[] getFilter()

getTupleStore

public TupleStore getTupleStore()

getArity

public int getArity()

clear

public void clear()
           throws IOException,
EDBException

Throws:

IOException

EDBException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

union

public void union(ReasoningRelation tuples)
           throws IOException,
EDBException

Throws:

IOException

EDBException

elements

public TupleEnumerator elements()
                         throws IOException,
EDBException

Throws:

IOException

EDBException

isEmpty

public boolean isEmpty()
                throws IOException,
EDBException

is relation empty

Parameters:

R -

Returns:

Throws:

IOException

EDBException

join

public JoinStatistics join(InterruptFlag interrupt,
 int[] compare1,
 ReasoningRelation R,
 int[] compare2,
 int[] source1,
 int[] dest1,
 int[] source2,
 int[] dest2,
 long[] externalFilter1,
 long[] externalFilter2,
 int destarity,
 Receiver receiver,
 com.semedy.reasoner.reasoning.processes.EvaluationThread evalThread,
 boolean streamReasoning,
 com.semedy.reasoner.reasoning.processes.SystemMonitor.JoinType joinType)
                    throws InterruptedException,
IOException,
SemReasonerException

Throws:

InterruptedException

IOException

SemReasonerException