Skip to content

Commit

Permalink
Tidy up code- remove warnings.
Browse files Browse the repository at this point in the history
  • Loading branch information
afs committed Nov 14, 2010
1 parent ac2d87c commit 86ece5a
Show file tree
Hide file tree
Showing 15 changed files with 93 additions and 48 deletions.
5 changes: 5 additions & 0 deletions .settings/org.eclipse.jdt.core.prefs
@@ -0,0 +1,5 @@
#Wed Aug 25 19:14:39 BST 2010
org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.6
eclipse.preferences.version=1
org.eclipse.jdt.core.compiler.source=1.6
org.eclipse.jdt.core.compiler.compliance=1.6
36 changes: 21 additions & 15 deletions log4j.properties 100755 → 100644
@@ -1,15 +1,21 @@
#log4j.rootLogger=WARN, stdout log4j.rootLogger=INFO, stdlog
log4j.rootLogger=WARN, stderr

log4j.appender.stdlog=org.apache.log4j.ConsoleAppender
log4j.appender.stdout=org.apache.log4j.ConsoleAppender ## log4j.appender.stdlog.target=System.err
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout log4j.appender.stdlog.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%d{HH:mm:ss} %-5p %-20c{1} :: %m%n log4j.appender.stdlog.layout.ConversionPattern=%d{HH:mm:ss} %-5p %-25c{1} :: %m%n
##log4j.appender.stdout.layout.ConversionPattern=%-5p %-20c{1} :: %m%n

# Execution logging
log4j.appender.stderr=org.apache.log4j.ConsoleAppender log4j.logger.com.hp.hpl.jena.arq.info=INFO
log4j.appender.stderr.target=System.err log4j.logger.com.hp.hpl.jena.arq.exec=INFO
log4j.appender.stderr.layout=org.apache.log4j.PatternLayout
log4j.appender.stderr.layout.ConversionPattern=%d{HH:mm:ss} %-5p %-20c{1} :: %m%n # Everything else in Jena

log4j.logger.com.hp.hpl.jena=WARN
log4j.logger.benchmark=INFO log4j.logger.org.openjena=WARN

log4j.logger.org.openjena.riot=INFO

# Joseki server
log4j.logger.org.joseki=INFO


log4j.logger.benchmark=INFO
3 changes: 3 additions & 0 deletions mvn-update
@@ -0,0 +1,3 @@
#!/bin/bash

mvn dependency:resolve dependency:sources
3 changes: 2 additions & 1 deletion src/benchmark/generator/ParetoDistGenerator.java 100755 → 100644
Expand Up @@ -15,7 +15,8 @@ public ParetoDistGenerator(double alpha, int maxValue)
public int getValue() public int getValue()
{ {
int i; int i;
for(i=(int)pareto.inverseF(Math.random());i>max;i=(int)pareto.inverseF(Math.random())); for(i=(int)pareto.inverseF(Math.random());i>max;i=(int)pareto.inverseF(Math.random()))
{}
return i; return i;
} }
} }
9 changes: 6 additions & 3 deletions src/benchmark/serializer/NTriples.java 100755 → 100644
Expand Up @@ -25,7 +25,8 @@ public NTriples(String file, boolean forwardChaining)
nrTriples = 0l; nrTriples = 0l;
} }


public void gatherData(ObjectBundle bundle) { @Override
public void gatherData(ObjectBundle bundle) {
Iterator<BSBMResource> it = bundle.iterator(); Iterator<BSBMResource> it = bundle.iterator();


while(it.hasNext()) while(it.hasNext())
Expand Down Expand Up @@ -677,7 +678,8 @@ private String createURIref(String uri)






public void serialize() { @Override
public void serialize() {
//Close File //Close File
try { try {
fileWriter.flush(); fileWriter.flush();
Expand All @@ -688,7 +690,8 @@ public void serialize() {
} }
} }


public Long triplesGenerated() { @Override
public Long triplesGenerated() {
return nrTriples; return nrTriples;
} }
} }
9 changes: 6 additions & 3 deletions src/benchmark/serializer/SQLSerializer.java 100755 → 100644
Expand Up @@ -38,7 +38,8 @@ public SQLSerializer(String directory, boolean forwardChaining, String database)
initTables(); initTables();
} }


public void gatherData(ObjectBundle bundle) { @Override
public void gatherData(ObjectBundle bundle) {
Iterator<BSBMResource> it = bundle.iterator(); Iterator<BSBMResource> it = bundle.iterator();


try { try {
Expand Down Expand Up @@ -576,7 +577,8 @@ private void convertReview(Review review) throws IOException
tables.reviewDump.append(values); tables.reviewDump.append(values);
} }


public void serialize() { @Override
public void serialize() {
//Finish files and close //Finish files and close
try { try {
tables.productTypeDump.append(tables.endTable(tables.productTypeInsertCounter, "producttype")); tables.productTypeDump.append(tables.endTable(tables.productTypeInsertCounter, "producttype"));
Expand Down Expand Up @@ -625,7 +627,8 @@ public void serialize() {
} }
} }


public Long triplesGenerated() { @Override
public Long triplesGenerated() {
return nrTriples; return nrTriples;
} }


Expand Down
9 changes: 6 additions & 3 deletions src/benchmark/serializer/TriG.java 100755 → 100644
Expand Up @@ -77,7 +77,8 @@ private String createPrefixLine(String prefix, String namespace) {
} }




public void gatherData(ObjectBundle bundle) { @Override
public void gatherData(ObjectBundle bundle) {
Iterator<BSBMResource> it = bundle.iterator(); Iterator<BSBMResource> it = bundle.iterator();


//Write Graph and provenance data //Write Graph and provenance data
Expand Down Expand Up @@ -678,7 +679,8 @@ private String createURIref(String uri)






public void serialize() { @Override
public void serialize() {
//Write provenance data file end and close files //Write provenance data file end and close files
try { try {
provenanceGraphWriter.append("}\n"); provenanceGraphWriter.append("}\n");
Expand Down Expand Up @@ -712,7 +714,8 @@ public void serialize() {
} }
} }


public Long triplesGenerated() { @Override
public Long triplesGenerated() {
return nrTriples; return nrTriples;
} }
} }
9 changes: 6 additions & 3 deletions src/benchmark/serializer/Turtle.java 100755 → 100644
Expand Up @@ -72,7 +72,8 @@ private String createPrefixLine(String prefix, String namespace) {
} }




public void gatherData(ObjectBundle bundle) { @Override
public void gatherData(ObjectBundle bundle) {
Iterator<BSBMResource> it = bundle.iterator(); Iterator<BSBMResource> it = bundle.iterator();


try { try {
Expand Down Expand Up @@ -742,7 +743,8 @@ private String createURIref(String uri)






public void serialize() { @Override
public void serialize() {
//Close files //Close files
try { try {
dataFileWriter.flush(); dataFileWriter.flush();
Expand All @@ -768,7 +770,8 @@ public void serialize() {
} }
} }


public Long triplesGenerated() { @Override
public Long triplesGenerated() {
return nrTriples; return nrTriples;
} }


Expand Down
9 changes: 6 additions & 3 deletions src/benchmark/serializer/VirtSerializer.java 100755 → 100644
Expand Up @@ -36,7 +36,8 @@ public VirtSerializer (String directory, boolean forwardChaining) {
initTables(); initTables();
} }


public void gatherData(ObjectBundle bundle) { @Override
public void gatherData(ObjectBundle bundle) {
Iterator<BSBMResource> it = bundle.iterator(); Iterator<BSBMResource> it = bundle.iterator();


try { try {
Expand Down Expand Up @@ -574,7 +575,8 @@ private void convertReview(Review review) throws IOException
tables.reviewDump.append(values); tables.reviewDump.append(values);
} }


public void serialize() { @Override
public void serialize() {
//Finish files and close //Finish files and close
try { try {
tables.productTypeDump.flush(); tables.productTypeDump.flush();
Expand Down Expand Up @@ -613,7 +615,8 @@ public void serialize() {
} }
} }


public Long triplesGenerated() { @Override
public Long triplesGenerated() {
return nrTriples; return nrTriples;
} }


Expand Down
9 changes: 6 additions & 3 deletions src/benchmark/serializer/XMLSerializer.java 100755 → 100644
Expand Up @@ -78,7 +78,8 @@ else if(publisher.contains("ratingsite"))
} }




public void gatherData(ObjectBundle bundle) { @Override
public void gatherData(ObjectBundle bundle) {
Iterator<BSBMResource> it = bundle.iterator(); Iterator<BSBMResource> it = bundle.iterator();


String publisherType = getPublisherTypeString(bundle); String publisherType = getPublisherTypeString(bundle);
Expand Down Expand Up @@ -552,7 +553,8 @@ private String leafTagWA(int indentationSteps, String tag, String content, Strin
return sb.toString(); return sb.toString();
} }


public void serialize() { @Override
public void serialize() {
//Close files //Close files
try { try {
writeFooterData(); writeFooterData();
Expand All @@ -564,7 +566,8 @@ public void serialize() {
} }
} }


public Long triplesGenerated() { @Override
public Long triplesGenerated() {
return nrTriples; return nrTriples;
} }


Expand Down
12 changes: 8 additions & 4 deletions src/benchmark/testdriver/SPARQLConnection.java 100755 → 100644
Expand Up @@ -31,7 +31,8 @@ public SPARQLConnection(String serviceURL, String defaultGraph, int timeout) {
/* /*
* Execute Query with Query Object * Execute Query with Query Object
*/ */
public void executeQuery(Query query, byte queryType) { @Override
public void executeQuery(Query query, byte queryType) {
executeQuery(query.getQueryString(), queryType, query.getNr(), query.getQueryMix()); executeQuery(query.getQueryString(), queryType, query.getNr(), query.getQueryMix());
} }


Expand Down Expand Up @@ -79,7 +80,8 @@ private void executeQuery(String queryString, byte queryType, int queryNr, Query
qe.close(); qe.close();
} }


public void executeQuery(CompiledQuery query, CompiledQueryMix queryMix) { @Override
public void executeQuery(CompiledQuery query, CompiledQueryMix queryMix) {
double timeInSeconds; double timeInSeconds;


String queryString = query.getQueryString(); String queryString = query.getQueryString();
Expand Down Expand Up @@ -211,7 +213,8 @@ public int getCount() {
} }
} }


public void close() { @Override
public void close() {
//nothing to close //nothing to close
} }


Expand All @@ -220,7 +223,8 @@ public void close() {
* @see benchmark.testdriver.ServerConnection#executeValidation(benchmark.testdriver.Query, byte, java.lang.String[]) * @see benchmark.testdriver.ServerConnection#executeValidation(benchmark.testdriver.Query, byte, java.lang.String[])
* Gather information about the result a query returns. * Gather information about the result a query returns.
*/ */
public QueryResult executeValidation(Query query, byte queryType) { @Override
public QueryResult executeValidation(Query query, byte queryType) {
String queryString = query.getQueryString(); String queryString = query.getQueryString();
int queryNr = query.getNr(); int queryNr = query.getNr();
String[] rowNames = query.getRowNames(); String[] rowNames = query.getRowNames();
Expand Down
12 changes: 8 additions & 4 deletions src/benchmark/testdriver/SQLConnection.java 100755 → 100644
Expand Up @@ -38,7 +38,8 @@ public SQLConnection(String serviceURL, int timeout, String driverClassName) {
/* /*
* Execute Query with Query Object * Execute Query with Query Object
*/ */
public void executeQuery(Query query, byte queryType) { @Override
public void executeQuery(Query query, byte queryType) {
executeQuery(query.getQueryString(), queryType, query.getNr(), query.getQueryMix()); executeQuery(query.getQueryString(), queryType, query.getNr(), query.getQueryMix());
} }


Expand Down Expand Up @@ -84,7 +85,8 @@ private void executeQuery(String queryString, byte queryType, int queryNr, Query
* Execute Query with precompiled Query * Execute Query with precompiled Query
* @see benchmark.testdriver.ServerConnection#executeQuery(benchmark.testdriver.CompiledQuery, benchmark.testdriver.CompiledQueryMix) * @see benchmark.testdriver.ServerConnection#executeQuery(benchmark.testdriver.CompiledQuery, benchmark.testdriver.CompiledQueryMix)
*/ */
public void executeQuery(CompiledQuery query, CompiledQueryMix queryMix) { @Override
public void executeQuery(CompiledQuery query, CompiledQueryMix queryMix) {
double timeInSeconds; double timeInSeconds;
String queryString = query.getQueryString(); String queryString = query.getQueryString();
byte queryType = query.getQueryType(); byte queryType = query.getQueryType();
Expand Down Expand Up @@ -144,7 +146,8 @@ private void logResultInfo(int queryNr, int queryMixRun, double timeInSeconds,
logger.log(Level.ALL, sb.toString()); logger.log(Level.ALL, sb.toString());
} }


public void close() { @Override
public void close() {
try { try {
conn.close(); conn.close();
} catch(SQLException e) { } catch(SQLException e) {
Expand All @@ -153,7 +156,8 @@ public void close() {
} }
} }


public QueryResult executeValidation(Query query, byte queryType) { @Override
public QueryResult executeValidation(Query query, byte queryType) {
// TODO Auto-generated method stub // TODO Auto-generated method stub
return null; return null;
} }
Expand Down
6 changes: 4 additions & 2 deletions src/benchmark/tools/ResultTransform.java 100755 → 100644
Expand Up @@ -293,7 +293,8 @@ private static void init() {
} }


class FileFilter implements FilenameFilter { class FileFilter implements FilenameFilter {
public boolean accept(File dir, String name) { @Override
public boolean accept(File dir, String name) {
return name.endsWith(".xml"); return name.endsWith(".xml");
} }
} }
Expand Down Expand Up @@ -391,7 +392,8 @@ public String getQmValue() {
} }


class StringLengthComparator implements Comparator<String> { class StringLengthComparator implements Comparator<String> {
public int compare(String s1, String s2) { @Override
public int compare(String s1, String s2) {
if(s1.length() == s2.length()) if(s1.length() == s2.length())
return 0; return 0;
else if(s1.length()>s2.length()) else if(s1.length()>s2.length())
Expand Down
6 changes: 4 additions & 2 deletions src/benchmark/tools/ResultTransformOriginalStyle.java 100755 → 100644
Expand Up @@ -278,7 +278,8 @@ private static void init() {
} }


private static class FileFilter1 implements FilenameFilter { private static class FileFilter1 implements FilenameFilter {
public boolean accept(File dir, String name) { @Override
public boolean accept(File dir, String name) {
return name.endsWith(".xml"); return name.endsWith(".xml");
} }
} }
Expand Down Expand Up @@ -376,7 +377,8 @@ public String getQmValue() {
} }


private static class StringLengthComparator1 implements Comparator<String> { private static class StringLengthComparator1 implements Comparator<String> {
public int compare(String s1, String s2) { @Override
public int compare(String s1, String s2) {
if(s1.length() == s2.length()) if(s1.length() == s2.length())
return 0; return 0;
else if(s1.length()>s2.length()) else if(s1.length()>s2.length())
Expand Down
4 changes: 2 additions & 2 deletions src/openrdf/test.java 100755 → 100644
Expand Up @@ -18,12 +18,12 @@ public class test
{ {
static { System.setProperty("log4j.configuration", "file:log4j.properties") ; } static { System.setProperty("log4j.configuration", "file:log4j.properties") ; }


public static void main(String... argv) throws IOException public static void main(String... argv)
{ {
query(argv) ; query(argv) ;
} }


public static void query(String... argv) throws IOException public static void query(String... argv)
{ {
if ( argv.length == 0 ) if ( argv.length == 0 )
{ {
Expand Down

0 comments on commit 86ece5a

Please sign in to comment.