Module org.apache.jena.arq

Package org.apache.jena.sparql.modify

Class UpdateProcessorStreamingBase

java.lang.Object

org.apache.jena.sparql.modify.UpdateProcessorStreamingBase

All Implemented Interfaces:

UpdateProcessorStreaming

public class UpdateProcessorStreamingBase
extends Object
implements UpdateProcessorStreaming

Class to hold the general state of a update request execution. See query ExecutionContext

Constructor Summary

Constructors

Constructor	Description
UpdateProcessorStreamingBase(DatasetGraph datasetGraph, Binding inputBinding, Prologue prologue, Context context, UpdateEngineFactory factory)

Method Summary

Modifier and Type	Method	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).
DatasetGraph	getDatasetGraph()	The dataset against which the query will execute.
Prologue	getPrologue()	Prologue for the UpdateRequest
UpdateSink	getUpdateSink()	The UpdateSink into which Updates are added and executed
void	startRequest()	Start the request, call before putting updates into the Sink

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

UpdateProcessorStreamingBase

public UpdateProcessorStreamingBase(DatasetGraph datasetGraph,
 Binding inputBinding,
 Prologue prologue,
 Context context,
 UpdateEngineFactory factory)

Method Details

startRequest

public void startRequest()

Description copied from interface: UpdateProcessorStreaming

Start the request, call before putting updates into the Sink

Specified by:

startRequest in interface UpdateProcessorStreaming

finishRequest

public void finishRequest()

Description copied from interface: UpdateProcessorStreaming

Finish the request, call after putting updates into the Sink

Specified by:

finishRequest in interface UpdateProcessorStreaming

getUpdateSink

public UpdateSink getUpdateSink()

Description copied from interface: UpdateProcessorStreaming

The UpdateSink into which Updates are added and executed

Specified by:

getUpdateSink in interface UpdateProcessorStreaming

getDatasetGraph

public DatasetGraph getDatasetGraph()

Description copied from interface: UpdateProcessorStreaming

The dataset against which the query will execute. May be null, implying the there isn't a local GraphStore target for this UpdateProcessor.

Specified by:

getDatasetGraph in interface UpdateProcessorStreaming

getContext

public Context getContext()

Description copied from interface: UpdateProcessorStreaming

The properties associated with a query execution - implementation specific parameters This includes Java objects (so it is not an RDF graph). Keys should be URIs as strings. May be null (this implementation does not provide any configuration).

Specified by:

getContext in interface UpdateProcessorStreaming

getPrologue

public Prologue getPrologue()

Description copied from interface: UpdateProcessorStreaming

Prologue for the UpdateRequest

Specified by:

getPrologue in interface UpdateProcessorStreaming