public class LogRDFizer
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.io.BufferedWriter |
bw |
org.openrdf.repository.RepositoryConnection |
con |
long |
endpointSize |
static int |
maxRunTime |
static long |
queryNo |
int |
runtimeErrorCount |
static java.io.BufferedWriter |
tobw |
Constructor and Description |
---|
LogRDFizer() |
Modifier and Type | Method and Description |
---|---|
long |
getQueryResultSize(java.lang.String queryStr,
java.lang.String localEndpoint,
java.lang.String sesameQueryType)
Get result size of the given query
|
java.lang.String |
getRDFUserExecutions(com.hp.hpl.jena.query.Query query,
java.util.Set<java.lang.String> submissions,
java.lang.String separator)
Get all executions (IP,Time) of the given query
|
void |
initializeRepoConnection(java.lang.String endpointUrl)
Initialize repository for a SPARQL endpoint
|
static void |
main(java.lang.String[] args) |
void |
RDFizeASK(com.hp.hpl.jena.query.Query query,
java.lang.String localEndpoint,
java.lang.String graph,
java.util.Set<java.lang.String> submissions,
java.lang.String separator,
java.lang.String baseURI)
RDFized ASK query
|
void |
RDFizeConstruct(com.hp.hpl.jena.query.Query query,
java.lang.String localEndpoint,
java.lang.String graph,
java.util.Set<java.lang.String> submissions,
java.lang.String separator,
java.lang.String baseURI)
RDFized CONSTRUCT query
|
void |
RDFizeDescribe(com.hp.hpl.jena.query.Query query,
java.lang.String localEndpoint,
java.lang.String graph,
java.util.Set<java.lang.String> submissions,
java.lang.String separator,
java.lang.String baseURI)
RDFized DESCRIBE query
|
void |
rdfizeLog(java.util.Map<java.lang.String,java.util.Set<java.lang.String>> queryToSubmissions,
java.lang.String localEndpoint,
java.lang.String publicEndpoint,
java.lang.String graph,
java.lang.String baseURI,
java.lang.String outputFile,
java.lang.String separator)
RDFize Log
|
void |
RDFizeSelect(com.hp.hpl.jena.query.Query query,
java.lang.String localEndpoint,
java.lang.String graph,
java.util.Set<java.lang.String> submissions,
java.lang.String separator,
java.lang.String baseURI)
RDFized SELECT query
|
void |
writePrefixes(java.lang.String baseURI)
Write RDF Prefixes
|
public static java.io.BufferedWriter bw
public org.openrdf.repository.RepositoryConnection con
public static java.io.BufferedWriter tobw
public static long queryNo
public static int maxRunTime
public int runtimeErrorCount
public long endpointSize
public static void main(java.lang.String[] args) throws java.io.IOException, org.openrdf.repository.RepositoryException, org.openrdf.query.MalformedQueryException, org.openrdf.query.QueryEvaluationException
java.io.IOException
org.openrdf.repository.RepositoryException
org.openrdf.query.MalformedQueryException
org.openrdf.query.QueryEvaluationException
public void rdfizeLog(java.util.Map<java.lang.String,java.util.Set<java.lang.String>> queryToSubmissions, java.lang.String localEndpoint, java.lang.String publicEndpoint, java.lang.String graph, java.lang.String baseURI, java.lang.String outputFile, java.lang.String separator) throws java.io.IOException, org.openrdf.repository.RepositoryException, org.openrdf.query.MalformedQueryException, org.openrdf.query.QueryEvaluationException
queryToSubmissions
- A map which store a query string (single line) as key and all the corresponding submissions as List. Where a submission is a combination
of User encrypted ip and the data,time of the query request. The I.P and the time is separated by a separatorlocalEndpoint
- Endpoint which will be used for feature generationpublicEndpoint
- Public endpoint of the loggraph
- named Graph, can be nullbaseURI
- Base URI of the log datasetoutputFile
- The output RDF fileseparator
- Submission separator. Explained abovejava.io.IOException
org.openrdf.repository.RepositoryException
org.openrdf.query.MalformedQueryException
org.openrdf.query.QueryEvaluationException
public void RDFizeSelect(com.hp.hpl.jena.query.Query query, java.lang.String localEndpoint, java.lang.String graph, java.util.Set<java.lang.String> submissions, java.lang.String separator, java.lang.String baseURI) throws java.io.IOException, org.openrdf.repository.RepositoryException, org.openrdf.query.MalformedQueryException
query
- QuerylocalEndpoint
- Local endpointgraph
- Named Graph, can be nullsubmissions
- List of all submissions (I.P:ExecutionTime) of the given queryseparator
- Separator string between I.P and execution timebaseURI
- Base URIjava.io.IOException
org.openrdf.repository.RepositoryException
org.openrdf.query.MalformedQueryException
public void RDFizeDescribe(com.hp.hpl.jena.query.Query query, java.lang.String localEndpoint, java.lang.String graph, java.util.Set<java.lang.String> submissions, java.lang.String separator, java.lang.String baseURI) throws java.io.IOException, org.openrdf.repository.RepositoryException, org.openrdf.query.MalformedQueryException
query
- QuerylocalEndpoint
- Local endpointgraph
- Named Graph, can be nullsubmissions
- List of all submissions (I.P:ExecutionTime) of the given queryseparator
- Separator string between I.P and execution timebaseURI
- Base Urijava.io.IOException
org.openrdf.repository.RepositoryException
org.openrdf.query.MalformedQueryException
public void RDFizeConstruct(com.hp.hpl.jena.query.Query query, java.lang.String localEndpoint, java.lang.String graph, java.util.Set<java.lang.String> submissions, java.lang.String separator, java.lang.String baseURI) throws java.io.IOException, org.openrdf.repository.RepositoryException, org.openrdf.query.MalformedQueryException
query
- QuerylocalEndpoint
- Local endpointgraph
- Named Graph, can be nullsubmissions
- List of all submissions (I.P:ExecutionTime) of the given queryseparator
- Separator string between I.P and execution timebaseURI
- Base URIjava.io.IOException
org.openrdf.repository.RepositoryException
org.openrdf.query.MalformedQueryException
public void RDFizeASK(com.hp.hpl.jena.query.Query query, java.lang.String localEndpoint, java.lang.String graph, java.util.Set<java.lang.String> submissions, java.lang.String separator, java.lang.String baseURI) throws java.io.IOException, org.openrdf.repository.RepositoryException, org.openrdf.query.MalformedQueryException
query
- QuerylocalEndpoint
- Local endpointgraph
- Named Graph, can be nullsubmissions
- List of all submissions (I.P:ExecutionTime) of the given queryseparator
- Separator string between I.P and execution timebaseURI
- Base URIjava.io.IOException
org.openrdf.repository.RepositoryException
org.openrdf.query.MalformedQueryException
public java.lang.String getRDFUserExecutions(com.hp.hpl.jena.query.Query query, java.util.Set<java.lang.String> submissions, java.lang.String separator)
query
- Querysubmissions
- Query submissions in form of IP:Timeseparator
- String separator between IP:Timepublic long getQueryResultSize(java.lang.String queryStr, java.lang.String localEndpoint, java.lang.String sesameQueryType) throws org.openrdf.repository.RepositoryException, org.openrdf.query.MalformedQueryException, java.io.IOException
queryStr
- QuerylocalEndpoint
- Endpoint url where this query has to be executedsesameQueryType
- Query type {SELECT, ASK, CONSTRUCT, DESCRIBE}org.openrdf.repository.RepositoryException
org.openrdf.query.MalformedQueryException
java.io.IOException
public void writePrefixes(java.lang.String baseURI) throws java.io.IOException
baseURI
- Base URI of the log datasetjava.io.IOException
public void initializeRepoConnection(java.lang.String endpointUrl) throws org.openrdf.repository.RepositoryException
endpointUrl
- Endpoint Urlorg.openrdf.repository.RepositoryException