public class UpdateProcessorStreamingBase extends Object implements UpdateProcessorStreaming
| Constructor and Description |
|---|
UpdateProcessorStreamingBase(GraphStore graphStore,
Binding inputBinding,
Context context,
UpdateEngineFactory factory) |
| Modifier and Type | Method and Description |
|---|---|
void |
finishRequest()
Finish the request, call after putting updates into the Sink
|
Context |
getContext()
The properties associated with a query execution -
implementation specific parameters This includes
Java objects (so it is not an RDF graph).
|
GraphStore |
getGraphStore()
The dataset against which the query will execute.
|
UpdateSink |
getUpdateSink()
The UpdateSink into which Updates are added and executed
|
void |
startRequest()
Start the request, call before putting updates into the Sink
|
public UpdateProcessorStreamingBase(GraphStore graphStore, Binding inputBinding, Context context, UpdateEngineFactory factory)
public void startRequest()
UpdateProcessorStreamingstartRequest in interface UpdateProcessorStreamingpublic void finishRequest()
UpdateProcessorStreamingfinishRequest in interface UpdateProcessorStreamingpublic UpdateSink getUpdateSink()
UpdateProcessorStreaminggetUpdateSink in interface UpdateProcessorStreamingpublic GraphStore getGraphStore()
UpdateProcessorStreaminggetGraphStore in interface UpdateProcessorStreamingpublic Context getContext()
UpdateProcessorStreaminggetContext in interface UpdateProcessorStreamingLicenced under the Apache License, Version 2.0