public class UpdateProcessorStreamingBase extends Object implements UpdateProcessorStreaming
Constructor and Description |
---|
UpdateProcessorStreamingBase(GraphStore graphStore,
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, Context context, UpdateEngineFactory factory)
public void startRequest()
UpdateProcessorStreaming
startRequest
in interface UpdateProcessorStreaming
public void finishRequest()
UpdateProcessorStreaming
finishRequest
in interface UpdateProcessorStreaming
public UpdateSink getUpdateSink()
UpdateProcessorStreaming
getUpdateSink
in interface UpdateProcessorStreaming
public GraphStore getGraphStore()
UpdateProcessorStreaming
getGraphStore
in interface UpdateProcessorStreaming
public Context getContext()
UpdateProcessorStreaming
getContext
in interface UpdateProcessorStreaming
Licenced under the Apache License, Version 2.0