Module org.apache.jena.arq

Package org.apache.jena.sparql.modify

Class UpdateEngineNonStreaming

java.lang.Object

org.apache.jena.sparql.modify.UpdateEngineBase

org.apache.jena.sparql.modify.UpdateEngineMain

org.apache.jena.sparql.modify.UpdateEngineNonStreaming

All Implemented Interfaces:

UpdateEngine

public class UpdateEngineNonStreaming
extends UpdateEngineMain

Example implementation of an update engine that does not stream data, instead it will build it up into an in-memory UpdateRequest, and then traverse it after all update operations have finished.

Constructor Summary

Constructors

Constructor	Description
UpdateEngineNonStreaming(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 adds all update operations into an internal UpdateRequest object.
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

UpdateEngineNonStreaming

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

Creates a new Update Engine

Parameters:

datasetGraph - Store 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

Specified by:

startRequest in interface UpdateEngine

Overrides:

startRequest in class UpdateEngineMain

finishRequest

public void finishRequest()

Description copied from interface: UpdateEngine

Signal end of a request being executed

Specified by:

finishRequest in interface UpdateEngine

Overrides:

finishRequest in class UpdateEngineMain

getUpdateSink

public UpdateSink getUpdateSink()

Returns an UpdateSink that adds all update operations into an internal UpdateRequest object. After the last update operation has been added, the execute() method is called.

Specified by:

getUpdateSink in interface UpdateEngine

Overrides:

getUpdateSink in class UpdateEngineMain

getFactory

public static UpdateEngineFactory getFactory()