You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@jena.apache.org by sa...@apache.org on 2013/01/31 22:49:13 UTC
svn commit: r1441211 -
/jena/branches/streaming-update/jena-sdb/src/main/java/com/hp/hpl/jena/sdb/modify/UpdateEngineSDB.java
Author: sallen
Date: Thu Jan 31 21:49:13 2013
New Revision: 1441211
URL: http://svn.apache.org/viewvc?rev=1441211&view=rev
Log:
Fix the SDB build
Modified:
jena/branches/streaming-update/jena-sdb/src/main/java/com/hp/hpl/jena/sdb/modify/UpdateEngineSDB.java
Modified: jena/branches/streaming-update/jena-sdb/src/main/java/com/hp/hpl/jena/sdb/modify/UpdateEngineSDB.java
URL: http://svn.apache.org/viewvc/jena/branches/streaming-update/jena-sdb/src/main/java/com/hp/hpl/jena/sdb/modify/UpdateEngineSDB.java?rev=1441211&r1=1441210&r2=1441211&view=diff
==============================================================================
--- jena/branches/streaming-update/jena-sdb/src/main/java/com/hp/hpl/jena/sdb/modify/UpdateEngineSDB.java (original)
+++ jena/branches/streaming-update/jena-sdb/src/main/java/com/hp/hpl/jena/sdb/modify/UpdateEngineSDB.java Thu Jan 31 21:49:13 2013
@@ -24,6 +24,8 @@ import com.hp.hpl.jena.sparql.modify.Upd
import com.hp.hpl.jena.sparql.modify.UpdateEngineFactory ;
import com.hp.hpl.jena.sparql.modify.UpdateEngineMain ;
import com.hp.hpl.jena.sparql.modify.UpdateEngineRegistry ;
+import com.hp.hpl.jena.sparql.modify.UpdateEngineStreaming ;
+import com.hp.hpl.jena.sparql.modify.UsingList ;
import com.hp.hpl.jena.sparql.util.Context ;
import com.hp.hpl.jena.update.GraphStore ;
import com.hp.hpl.jena.update.UpdateRequest ;
@@ -35,6 +37,9 @@ public class UpdateEngineSDB extends Upd
public UpdateEngineSDB(DatasetStoreGraph graphStore, UpdateRequest request, Binding inputBinding, Context context)
{ super(graphStore, request, inputBinding, context) ; }
+ public UpdateEngineSDB(DatasetStoreGraph graphStore, UsingList usingList, Binding inputBinding, Context context)
+ { super(graphStore, usingList, inputBinding, context) ; }
+
@Override
public void execute()
{ super.execute() ; }
@@ -54,7 +59,18 @@ public class UpdateEngineSDB extends Upd
{
return new UpdateEngineSDB((DatasetStoreGraph)graphStore, request, inputBinding, context) ;
}
-
+
+ @Override
+ public boolean acceptStreaming(GraphStore graphStore, Context context)
+ {
+ return (graphStore instanceof DatasetStoreGraph) ;
+ }
+
+ @Override
+ public UpdateEngineStreaming createStreaming(UsingList usingList, GraphStore graphStore, Binding initialBinding, Context context)
+ {
+ return new UpdateEngineSDB((DatasetStoreGraph)graphStore, usingList, initialBinding, context);
+ }
} ;
}