Package com.semedy.reasoner.edb.ramstore

Class MainMemoryRelation

java.lang.Object

com.semedy.reasoner.edb.ramstore.MainMemoryRelation

All Implemented Interfaces:

BaseRelation, Relation

Direct Known Subclasses:

MixedRelation

public class MainMemoryRelation
extends Object
implements Relation

Field Summary

Fields

Modifier and Type	Field	Description
MainMemoryBaseRelation	_baseRelation	the base relation contains the tuples

Constructor Summary

Constructors

Constructor	Description
MainMemoryRelation(MainMemoryBaseRelation baseRelation)
MainMemoryRelation(String name, int arity, boolean duplicates, long[] grounds)

Method Summary

Modifier and Type	Method	Description
void	addSubRelation(Relation R)
boolean	addTuple(int tuple)	add a tuple to the relation
boolean	addTuple(long[] tuple)	add a tuple to the relation
boolean	addTuple(TupleBuffer tuple)	add a tuple to the relation
boolean	checkSanity(String message, boolean shadow)	check the sanity of a relation
void	clear()	remove all tuples
void	close()	Close the relation.
boolean	containsTuple(int t)	Is tuple contained in relation?
boolean	containsTuple(long[] t)	Is tuple contained in relation?
boolean	containsTuple(TupleBuffer t)	Is tuple contained in relation?
Index	createIndex(int[] indexedpositions)	Get or create a simple (not sorted index) by the argument positions in indexed positions.
SortedIndex	createSortedIndex(int[] indexedpositions)	ret or create a sorted index given by the argument positions in indexed positions
void	delete()	remove all tuples and release files
void	deSelect()	release ressources because relation is currently not used
TupleEnumerator	elements()	returns an enumerator for all tuples
TupleEnumerator	elements(long[] filter)	returns an filteres enumerator for all tuples
void	flush()	Flush the relation.
int	getArity()	returns the arity of the relation
CacheInfo	getCacheInfo()	get the caching info
String	getDataFilePath()	get standard path for binary file
int	getDirectEncodedType(int i)	get the type of the direct encoded argument
String	getFilename()	returns the file name for the relation
long[]	getGrounds()	get the grounds
String	getIdentifier()	returns a unique identifier for the relation
Index	getIndex(int[] indexedPositions)	Get an index given by the argument positions in indexed positions (if it already exists).
TupleStore	getInputBuffer()	get an input buffer for relation
int	getInternalArity()	returns the internal arity of tuples
long	getMaxValue(int argument)	returns the maximal value at that argument position
long	getMinValue(int argument)	returns the minimal value at that argument position
String	getName()	get a unique name of the relation
long	getNumberOfDifferentValues(int argument)	Returns the number of different values at the argument positions.
long	getNumberOfDifferentValues(int argument, long value)	Returns the number of values occurring at the argument positions Used for statistics
String	getPredicateSymbol()	returns the predicate symbol for the relation
SortedIndex	getSortedIndex(int[] indexedPositions)	Get a sorted index given by the argument positions in indexed positions (if it already exists).
TupleStore	getTupleStore()	returns tuple store
gnu.trove.map.TLongIntMap	getValues()	get values and their occurrencies for first argument
boolean	hasDuplicates()	may relation contain duplicates?
boolean	isDirectEncoded(int i)	are all values at argument i direct encoded
boolean	isEmpty()	Is the relation empty?
long[]	isOverwrittenByTuple(long[] buffer)	returns the tuple which will be overwritten by tuple.
boolean	isPersistent()	Is the relation persistent?
boolean	isTemporary()	Is the relation temporary only?
long	lastModificationTime()	last modification time
boolean	mayContainDuplicates()	Might there be duplicates?
long[]	overwriteTuple(long[] buffer)	Overwrite last argument of tuple.
TupleBuffer	overwriteTuple(TupleBuffer buffer)	Overwrite last argument of tuple.
void	readBinaryFromBackup(String filepath)	read tuples from a binary backup file
void	readTupleFile(String filepath)	read tuples from a (compressed) binary file
void	registerListener(RelationListener listener)	register a listener for adding, removing, modifying tuples
boolean	removeTuple(int tuple)	remove a tuple from the relation
boolean	removeTuple(long[] buffer)	remove a tuple from the relation
boolean	removeTuple(TupleBuffer buffer)	remove a tuple from the relation
void	select()	initialize it before using it
long	size()	returns the number of tuples in relation
long	sizeInBytes()	size in bytes, usded for cache management
String	toString()
void	transactionBegin()	begin transaction
void	transactionCommit()	commit last changes
void	transactionRollback()	rbort last changes
void	union(BaseRelation R)	add all tuples of R to this
void	writeBinary(String filepath)	write tuples to a binary file
void	writeBinaryToBackup(String filepath)	write tuples to a binary backup file
void	writeBinaryWithGrounds(String filepath)	write complete tuples to a binary file

Methods inherited from class java.lang.Object

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

Field Details

_baseRelation

public MainMemoryBaseRelation _baseRelation

the base relation contains the tuples

Constructor Details

MainMemoryRelation

public MainMemoryRelation(String name,
 int arity,
 boolean duplicates,
 long[] grounds)

MainMemoryRelation

public MainMemoryRelation(MainMemoryBaseRelation baseRelation)

Method Details

getValues

public gnu.trove.map.TLongIntMap getValues()

get values and their occurrencies for first argument

Returns:

sizeInBytes

public long sizeInBytes()

size in bytes, usded for cache management

Specified by:

sizeInBytes in interface BaseRelation

Returns:

getTupleStore

public TupleStore getTupleStore()

returns tuple store

Returns:

elements

public TupleEnumerator elements()
                         throws IOException,
EDBException

Description copied from interface: BaseRelation

returns an enumerator for all tuples

Specified by:

elements in interface BaseRelation

Returns:

returns enumerator for tuples

Throws:

IOException

EDBException

size

public long size()
          throws IOException,
EDBException

Description copied from interface: BaseRelation

returns the number of tuples in relation

Specified by:

size in interface BaseRelation

Returns:

number of tuples in relation

Throws:

IOException

EDBException

addTuple

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

Description copied from interface: BaseRelation

add a tuple to the relation

Specified by:

addTuple in interface BaseRelation

Parameters:

tuple - the tuple to add

Returns:

tuple has been added

Throws:

IOException

EDBException

containsTuple

public boolean containsTuple(long[] t)
                      throws IOException

Description copied from interface: BaseRelation

Is tuple contained in relation?

Specified by:

containsTuple in interface BaseRelation

Parameters:

t - to be checked

Returns:

tuple is contained

Throws:

IOException

containsTuple

public boolean containsTuple(TupleBuffer t)
                      throws IOException

Description copied from interface: BaseRelation

Is tuple contained in relation?

Specified by:

containsTuple in interface BaseRelation

Parameters:

t - to be checked

Returns:

tuple is contained

Throws:

IOException

containsTuple

public boolean containsTuple(int t)
                      throws IOException

Description copied from interface: BaseRelation

Is tuple contained in relation?

Specified by:

containsTuple in interface BaseRelation

Parameters:

t - to be checked

Returns:

tuple is contained

Throws:

IOException

getNumberOfDifferentValues

public long getNumberOfDifferentValues(int argument)
                                throws IOException,
EDBException

Description copied from interface: Relation

Returns the number of different values at the argument positions.
Used for statistics.

Specified by:

getNumberOfDifferentValues in interface Relation

Parameters:

argument - , argument position

Returns:

Throws:

EDBException

IOException

getNumberOfDifferentValues

public long getNumberOfDifferentValues(int argument,
 long value)
                                throws IOException,
EDBException

Description copied from interface: Relation

Returns the number of values occurring at the argument positions
Used for statistics

Specified by:

getNumberOfDifferentValues in interface Relation

Parameters:

argument - , argument position

value - , the concrete value

Returns:

Throws:

EDBException

IOException

toString

public String toString()

Overrides:

toString in class Object

addTuple

public boolean addTuple(TupleBuffer tuple)
                 throws IOException,
EDBException

Description copied from interface: BaseRelation

add a tuple to the relation

Specified by:

addTuple in interface BaseRelation

Parameters:

tuple - the tuple to add

Returns:

tuple has been added

Throws:

IOException

EDBException

getCacheInfo

public CacheInfo getCacheInfo()

Description copied from interface: BaseRelation

get the caching info

Specified by:

getCacheInfo in interface BaseRelation

Returns:

object containing caching info

addTuple

public boolean addTuple(int tuple)
                 throws IOException,
EDBException

Description copied from interface: BaseRelation

add a tuple to the relation

Specified by:

addTuple in interface BaseRelation

Parameters:

tuple - the tuple to add

Returns:

tuple has been added

Throws:

IOException

EDBException

clear

public void clear()
           throws IOException,
EDBException

Description copied from interface: BaseRelation

remove all tuples

Specified by:

clear in interface BaseRelation

Throws:

IOException

EDBException

isEmpty

public boolean isEmpty()
                throws IOException

Description copied from interface: BaseRelation

Is the relation empty?

Specified by:

isEmpty in interface BaseRelation

Returns:

relation is empty

Throws:

IOException

delete

public void delete()
            throws IOException

Description copied from interface: Relation

remove all tuples and release files

Specified by:

delete in interface Relation

Throws:

IOException

writeBinary

public void writeBinary(String filepath)
                 throws IOException,
EDBException

Description copied from interface: Relation

write tuples to a binary file

Specified by:

writeBinary in interface BaseRelation

Specified by:

writeBinary in interface Relation

Throws:

IOException

EDBException

readTupleFile

public void readTupleFile(String filepath)
                   throws IOException,
EDBException

Description copied from interface: Relation

read tuples from a (compressed) binary file

Specified by:

readTupleFile in interface BaseRelation

Specified by:

readTupleFile in interface Relation

Parameters:

filepath - , the file path to read from

Throws:

IOException

EDBException

getDataFilePath

public String getDataFilePath()

Description copied from interface: Relation

get standard path for binary file

Specified by:

getDataFilePath in interface Relation

Returns:

removeTuple

public boolean removeTuple(int tuple)
                    throws IOException,
EDBException

Description copied from interface: BaseRelation

remove a tuple from the relation

Specified by:

removeTuple in interface BaseRelation

Parameters:

tuple - , address of tuple in tuple store

Returns:

true, if tuple has been removed

Throws:

IOException

EDBException

getArity

public int getArity()

Description copied from interface: BaseRelation

returns the arity of the relation

Specified by:

getArity in interface BaseRelation

Returns:

arity of relation

createSortedIndex

public SortedIndex createSortedIndex(int[] indexedpositions)
                              throws IOException,
EDBException

Description copied from interface: BaseRelation

ret or create a sorted index given by the argument positions in indexed positions

Specified by:

createSortedIndex in interface BaseRelation

Returns:

Throws:

IOException

EDBException

createIndex

public Index createIndex(int[] indexedpositions)
                  throws IOException,
EDBException

Description copied from interface: BaseRelation

Get or create a simple (not sorted index) by the argument positions in indexed positions.

Specified by:

createIndex in interface BaseRelation

Parameters:

indexedpositions - , positions which are indexed

Returns:

index

Throws:

IOException

EDBException

getIndex

public Index getIndex(int[] indexedPositions)

Description copied from interface: BaseRelation

Get an index given by the argument positions in indexed positions (if it already exists).
Returns null if it does not exist.

Specified by:

getIndex in interface BaseRelation

Parameters:

indexedPositions - the indexed positions

Returns:

the corresponding index or null if none is available

getSortedIndex

public SortedIndex getSortedIndex(int[] indexedPositions)

Description copied from interface: BaseRelation

Get a sorted index given by the argument positions in indexed positions (if it already exists).
Returns null if it does not exist.

Specified by:

getSortedIndex in interface BaseRelation

Parameters:

indexedPositions - the indexed positions

Returns:

the corresponding index or null if none is available

isPersistent

public boolean isPersistent()

Description copied from interface: BaseRelation

Is the relation persistent?

Specified by:

isPersistent in interface BaseRelation

Returns:

is the relation persistent

close

public void close()
           throws IOException

Description copied from interface: BaseRelation

Close the relation. Must be called to finalize the relation correctly

Specified by:

close in interface BaseRelation

Throws:

IOException

getInputBuffer

public TupleStore getInputBuffer()

Description copied from interface: BaseRelation

get an input buffer for relation

Specified by:

getInputBuffer in interface BaseRelation

Returns:

a tuple store which serves as buffer for input tuples

removeTuple

public boolean removeTuple(TupleBuffer buffer)
                    throws IOException,
EDBException

Description copied from interface: BaseRelation

remove a tuple from the relation

Specified by:

removeTuple in interface BaseRelation

Parameters:

buffer - , tuple to be removed

Returns:

true, if tuple has been removed

Throws:

IOException

EDBException

removeTuple

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

Description copied from interface: BaseRelation

remove a tuple from the relation

Specified by:

removeTuple in interface BaseRelation

Parameters:

buffer - , tuple to be removed

Returns:

true, if tuple has been removed

Throws:

IOException

EDBException

overwriteTuple

public long[] overwriteTuple(long[] buffer)
                      throws IOException,
EDBException

Description copied from interface: BaseRelation

Overwrite last argument of tuple.
First arguments are unique keys for tuple
Especially useful for triples [subject,predicate,object]
and object is changed

Specified by:

overwriteTuple in interface BaseRelation

Parameters:

buffer - , overwrite tuple

Returns:

the overwritten tuple

Throws:

IOException

EDBException

overwriteTuple

public TupleBuffer overwriteTuple(TupleBuffer buffer)
                           throws IOException,
EDBException

Description copied from interface: BaseRelation

Overwrite last argument of tuple.
First arguments are unique keys for tuple
Especially useful for triples [subject,predicate,object]
and object is changed

Specified by:

overwriteTuple in interface BaseRelation

Parameters:

buffer - , overwrite tuple

Returns:

the overwritten tuple

Throws:

IOException

EDBException

isOverwrittenByTuple

public long[] isOverwrittenByTuple(long[] buffer)
                            throws IOException,
EDBException

Description copied from interface: BaseRelation

returns the tuple which will be overwritten by tuple.

Specified by:

isOverwrittenByTuple in interface BaseRelation

Returns:

Throws:

IOException

EDBException

select

public void select()
            throws IOException,
EDBException

Description copied from interface: Relation

initialize it before using it

Specified by:

select in interface BaseRelation

Specified by:

select in interface Relation

Throws:

IOException

EDBException

getPredicateSymbol

public String getPredicateSymbol()

Description copied from interface: Relation

returns the predicate symbol for the relation

Specified by:

getPredicateSymbol in interface Relation

Returns:

getFilename

public String getFilename()

Description copied from interface: Relation

returns the file name for the relation

Specified by:

getFilename in interface Relation

Returns:

getIdentifier

public String getIdentifier()

Description copied from interface: BaseRelation

returns a unique identifier for the relation

Specified by:

getIdentifier in interface BaseRelation

Returns:

unique identifier for relation

deSelect

public void deSelect()
              throws IOException

Description copied from interface: Relation

release ressources because relation is currently not used

Specified by:

deSelect in interface Relation

Throws:

IOException

transactionRollback

public void transactionRollback()
                         throws IOException,
EDBException

Description copied from interface: Relation

rbort last changes

Specified by:

transactionRollback in interface Relation

Throws:

EDBException

IOException

transactionCommit

public void transactionCommit()
                       throws IOException,
EDBException

Description copied from interface: Relation

commit last changes

Specified by:

transactionCommit in interface Relation

Throws:

EDBException

IOException

getMinValue

public long getMinValue(int argument)
                 throws IOException,
EDBException

Description copied from interface: BaseRelation

returns the minimal value at that argument position

Specified by:

getMinValue in interface BaseRelation

Parameters:

argument - , argument position @return, minimal value

Throws:

IOException

EDBException

getMaxValue

public long getMaxValue(int argument)
                 throws IOException,
EDBException

Description copied from interface: BaseRelation

returns the maximal value at that argument position

Specified by:

getMaxValue in interface BaseRelation

Parameters:

argument - , argument position

Returns:

max value at argument position

Throws:

IOException

EDBException

lastModificationTime

public long lastModificationTime()

Description copied from interface: Relation

last modification time

Specified by:

lastModificationTime in interface BaseRelation

Specified by:

lastModificationTime in interface Relation

Returns:

time of last modification

addSubRelation

public void addSubRelation(Relation R)

mayContainDuplicates

public boolean mayContainDuplicates()

Description copied from interface: BaseRelation

Might there be duplicates?

Specified by:

mayContainDuplicates in interface BaseRelation

Returns:

, might there be duplicates in relation

isDirectEncoded

public boolean isDirectEncoded(int i)

Description copied from interface: BaseRelation

are all values at argument i direct encoded

Specified by:

isDirectEncoded in interface BaseRelation

Parameters:

i - , argument index

Returns:

getDirectEncodedType

public int getDirectEncodedType(int i)

Description copied from interface: BaseRelation

get the type of the direct encoded argument

Specified by:

getDirectEncodedType in interface BaseRelation

Returns:

isTemporary

public boolean isTemporary()

Description copied from interface: BaseRelation

Is the relation temporary only?

Specified by:

isTemporary in interface BaseRelation

Returns:

is the relation persistent

flush

public void flush()
           throws IOException,
EDBException

Description copied from interface: BaseRelation

Flush the relation. Must be called to finalize the relation correctly

Specified by:

flush in interface BaseRelation

Throws:

IOException

EDBException

checkSanity

public boolean checkSanity(String message,
 boolean shadow)
                    throws IOException,
EDBException

Description copied from interface: Relation

check the sanity of a relation

Specified by:

checkSanity in interface Relation

shadow - , check in shadow tree

Throws:

IOException

EDBException

registerListener

public void registerListener(RelationListener listener)

Description copied from interface: BaseRelation

register a listener for adding, removing, modifying tuples

Specified by:

registerListener in interface BaseRelation

getGrounds

public long[] getGrounds()

Description copied from interface: Relation

get the grounds

Specified by:

getGrounds in interface Relation

Returns:

writeBinaryToBackup

public void writeBinaryToBackup(String filepath)
                         throws IOException,
EDBException

Description copied from interface: Relation

write tuples to a binary backup file

Specified by:

writeBinaryToBackup in interface Relation

Throws:

IOException

EDBException

writeBinaryWithGrounds

public void writeBinaryWithGrounds(String filepath)
                            throws IOException,
EDBException

Description copied from interface: Relation

write complete tuples to a binary file

Specified by:

writeBinaryWithGrounds in interface Relation

Throws:

IOException

EDBException

readBinaryFromBackup

public void readBinaryFromBackup(String filepath)
                          throws IOException,
EDBException

Description copied from interface: Relation

read tuples from a binary backup file

Specified by:

readBinaryFromBackup in interface Relation

Throws:

IOException

EDBException

union

public void union(BaseRelation R)
           throws IOException,
EDBException

Description copied from interface: BaseRelation

add all tuples of R to this

Specified by:

union in interface BaseRelation

Throws:

IOException

EDBException

getName

public String getName()

Description copied from interface: Relation

get a unique name of the relation

Specified by:

getName in interface Relation

Returns:

hasDuplicates

public boolean hasDuplicates()

Description copied from interface: BaseRelation

may relation contain duplicates?

Specified by:

hasDuplicates in interface BaseRelation

Returns:

transactionBegin

public void transactionBegin()
                      throws IOException,
EDBException

Description copied from interface: Relation

begin transaction

Specified by:

transactionBegin in interface Relation

Throws:

EDBException

IOException

getInternalArity

public int getInternalArity()

Description copied from interface: BaseRelation

returns the internal arity of tuples

Specified by:

getInternalArity in interface BaseRelation

Returns:

elements

public TupleEnumerator elements(long[] filter)
                         throws IOException,
EDBException

Description copied from interface: BaseRelation

returns an filteres enumerator for all tuples

Specified by:

elements in interface BaseRelation

Returns:

returns enumerator for tuples

Throws:

IOException

EDBException