[TASK] Move CarStreamGenerator into own package
This commit is contained in:
parent
0d6f4d2530
commit
c06d4e1828
|
@ -10,6 +10,7 @@ import eu.larkc.csparql.core.engine.ConsoleFormatter;
|
||||||
import eu.larkc.csparql.core.engine.CsparqlEngine;
|
import eu.larkc.csparql.core.engine.CsparqlEngine;
|
||||||
import eu.larkc.csparql.core.engine.CsparqlEngineImpl;
|
import eu.larkc.csparql.core.engine.CsparqlEngineImpl;
|
||||||
import eu.larkc.csparql.core.engine.CsparqlQueryResultProxy;
|
import eu.larkc.csparql.core.engine.CsparqlQueryResultProxy;
|
||||||
|
import lu.jpt.csparqltest.carexample.CarStreamGenerator;
|
||||||
|
|
||||||
public class Main {
|
public class Main {
|
||||||
|
|
||||||
|
@ -49,9 +50,9 @@ public class Main {
|
||||||
// Add ConsoleFormatter as observer so it gets notified of every query result
|
// Add ConsoleFormatter as observer so it gets notified of every query result
|
||||||
resultProxy.addObserver(new ConsoleFormatter());
|
resultProxy.addObserver(new ConsoleFormatter());
|
||||||
|
|
||||||
// Let it all run for a couple of seconds
|
// Let it all run for a couple of seconds (3 min, 20 seconds)
|
||||||
try {
|
try {
|
||||||
Thread.sleep(200000);
|
Thread.sleep(10000);
|
||||||
} catch (InterruptedException e) {
|
} catch (InterruptedException e) {
|
||||||
logger.error(e.getMessage(), e);
|
logger.error(e.getMessage(), e);
|
||||||
}
|
}
|
||||||
|
|
|
@ -1,4 +1,4 @@
|
||||||
package lu.jpt.csparqltest;
|
package lu.jpt.csparqltest.carexample;
|
||||||
|
|
||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
Loading…
Reference in New Issue