Module org.apache.jena.arq

Package org.apache.jena.sparql.modify

Class UpdateEngineMain

java.lang.Object

org.apache.jena.sparql.modify.UpdateEngineBase

org.apache.jena.sparql.modify.UpdateEngineMain

All Implemented Interfaces:

UpdateEngine

Direct Known Subclasses:

UpdateEngineNonStreaming

public class UpdateEngineMain
extends UpdateEngineBase

Default implementation of an update engine based on stream updates to a worker function. In addition, it applies INSERT DATA and DELETE DATA driven off the updates, which may be directly from the parser.

Developers who only want to change/extend the processing of individual updates can easily

See UpdateEngineNonStreaming for a subclass that accumulates updates, including during parsing then executes the operation.

Constructor Summary

Constructors

Constructor	Description
UpdateEngineMain(DatasetGraph datasetGraph, Binding inputBinding, Context context)	Creates a new Update Engine

Method Summary

Modifier and Type	Method	Description
void	finishRequest()	Signal end of a request being executed
static UpdateEngineFactory	getFactory()
UpdateSink	getUpdateSink()	Returns an UpdateSink that accepts Update operations
void	startRequest()	Signal start of a request being executed

Methods inherited from class java.lang.Object

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

Constructor Details

UpdateEngineMain

public UpdateEngineMain(DatasetGraph datasetGraph,
 Binding inputBinding,
 Context context)

Creates a new Update Engine

Parameters:

datasetGraph - DatasetGraph the updates operate over

inputBinding - Initial binding to be applied to Update operations that can apply an initial binding (i.e. UpdateDeleteWhere, UpdateModify)

context - Execution Context

Method Details

startRequest

public void startRequest()

Description copied from interface: UpdateEngine

Signal start of a request being executed

finishRequest

public void finishRequest()

Description copied from interface: UpdateEngine

Signal end of a request being executed

getUpdateSink

public UpdateSink getUpdateSink()

Description copied from interface: UpdateEngine

Returns an UpdateSink that accepts Update operations

getFactory

public static UpdateEngineFactory getFactory()