org.deri.cqels.engine

Class ExecContext

java.lang.Object

org.deri.cqels.engine.ExecContext

public class ExecContext
extends java.lang.Object

This class implements CQELS execution context

Author:

Danh Le Phuoc, Chan Le Van

Constructor Summary

Constructors

Constructor and Description
ExecContext(java.lang.String path, boolean cleanDataset)

Method Summary

Methods

Modifier and Type	Method and Description
java.util.Properties	cacheConfig() get cache configuration
Location	cacheLocation() get the cache location
void	createCache(java.lang.String cachePath) create cache with the specified path
void	createDataSet(java.lang.String location) create a dataset with a specified location
static boolean	deleteDir(java.io.File dir) to delete a directory
NodeTable	dictionary() get the dictionary
CQELSEngine	engine() get CQELS engine
Environment	env() get environment
java.lang.Object	get(java.lang.String key) get the value with the specified key
com.hp.hpl.jena.sparql.engine.ExecutionContext	getARQExCtx() get the ARQ context
DatasetGraphTDB	getDataset() get the dataset
void	initTDBGraph(java.lang.String directory) init TDB graph with the specified directory
void	loadDataset(java.lang.String graphUri, java.lang.String dataUri) load a dataset with the specified graph uri and data uri
void	loadDefaultDataset(java.lang.String dataUri) load a dataset with the specified data uri
com.hp.hpl.jena.sparql.engine.QueryIterator	loadGraphPattern(com.hp.hpl.jena.sparql.algebra.Op op) load graph pattern
com.hp.hpl.jena.sparql.engine.QueryIterator	loadGraphPattern(com.hp.hpl.jena.sparql.algebra.Op op, com.hp.hpl.jena.sparql.core.DatasetGraph ds) load graph pattern with the specified dataset
RoutingPolicy	policy() get routing policy
void	put(java.lang.String key, java.lang.Object value) put key and value to the map
ContinuousConstruct	registerConstruct(java.lang.String queryStr) register a construct query
ContinuousSelect	registerSelect(java.lang.String queryStr) register a select query
OpRouter	router(int idx)
void	router(int idx, OpRouter router)
void	setEngine(CQELSEngine engine) set CQELS engine
void	setPolicy(RoutingPolicy policy) set routing policy with the specified policy

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecContext

public ExecContext(java.lang.String path,
           boolean cleanDataset)

Parameters:

path - home path containing dataset

cleanDataset - a flag indicates whether the old dataset will be cleaned or not

Method Detail

deleteDir

public static boolean deleteDir(java.io.File dir)

to delete a directory

Parameters:

dir - directory will be deleted

getARQExCtx

public com.hp.hpl.jena.sparql.engine.ExecutionContext getARQExCtx()

get the ARQ context

createDataSet

public void createDataSet(java.lang.String location)

create a dataset with a specified location

Parameters:

location - the specified location string

loadDataset

public void loadDataset(java.lang.String graphUri,
               java.lang.String dataUri)

load a dataset with the specified graph uri and data uri

Parameters:

graphUri -

dataUri -

loadDefaultDataset

public void loadDefaultDataset(java.lang.String dataUri)

load a dataset with the specified data uri

Parameters:

dataUri -

getDataset

public DatasetGraphTDB getDataset()

get the dataset

Parameters:

dataUri -

createCache

public void createCache(java.lang.String cachePath)

create cache with the specified path

Parameters:

cachePath - path string

env

public Environment env()

get environment

engine

public CQELSEngine engine()

get CQELS engine

setEngine

public void setEngine(CQELSEngine engine)

set CQELS engine

Parameters:

engine -

policy

public RoutingPolicy policy()

get routing policy

setPolicy

public void setPolicy(RoutingPolicy policy)

set routing policy with the specified policy

Parameters:

policy - specified policy and mostly heuristic policy in this version

put

public void put(java.lang.String key,
       java.lang.Object value)

put key and value to the map

Parameters:

key -

value -

get

public java.lang.Object get(java.lang.String key)

get the value with the specified key

Parameters:

key -

initTDBGraph

public void initTDBGraph(java.lang.String directory)

init TDB graph with the specified directory

Parameters:

directory -

loadGraphPattern

public com.hp.hpl.jena.sparql.engine.QueryIterator loadGraphPattern(com.hp.hpl.jena.sparql.algebra.Op op)

load graph pattern

Parameters:

op - operator

Returns:

query iterator

loadGraphPattern

public com.hp.hpl.jena.sparql.engine.QueryIterator loadGraphPattern(com.hp.hpl.jena.sparql.algebra.Op op,
                                                           com.hp.hpl.jena.sparql.core.DatasetGraph ds)

load graph pattern with the specified dataset

Parameters:

op - operator

ds - specified dataset

Returns:

query iterator

cacheLocation

public Location cacheLocation()

get the cache location

Returns:

cache location

dictionary

public NodeTable dictionary()

get the dictionary

Returns:

dictionary

cacheConfig

public java.util.Properties cacheConfig()

get cache configuration

Returns:

cache configuration

router

public void router(int idx,
          OpRouter router)

Parameters:

idx -

router

public OpRouter router(int idx)

Parameters:

idx -

Returns:

router

registerSelect

public ContinuousSelect registerSelect(java.lang.String queryStr)

register a select query

Parameters:

queryStr - query string

Returns:

this method return an instance of ContinuousSelect interface

registerConstruct

public ContinuousConstruct registerConstruct(java.lang.String queryStr)

register a construct query

Parameters:

queryStr - query string

Returns:

this method return an instance of ContinuousConstruct interface