[TASK] Reduce amount of windows.

This commit is contained in:
Jan Philipp Timme 2016-10-09 18:08:32 +02:00
parent 471fbdb8a6
commit 00f063bff8
1 changed files with 9 additions and 5 deletions

View File

@ -183,13 +183,17 @@ public class SimulationContext {
RDFStreamFormatter rdfStreamFormatter = new RDFStreamFormatter(streamUri);
engine.registerStream(rdfStreamFormatter);
resultProxy.addObserver(rdfStreamFormatter);
if(queryContainer.useObserverWindow) {
Observer resultObserver = this.createResultObserverWindow(queryContainer.name);
resultProxy.addObserver(resultObserver);
}
} else {
// If it is a regular query, just attach a fitting observer
// If it is a regular query, just attach a fitting observer, if enabled
if(queryContainer.useObserverWindow) {
Observer resultObserver = this.createResultObserverWindow(queryContainer.name);
resultProxy.addObserver(resultObserver);
}
}
// Attach custom observers to resultProxy if available
// These are used for SPARQL UPDATE queries on local domain knowledge
if(queryContainer.customObserver != null) {