com.hp.hpl.jena.sparql.modify

Class UpdateEngineNonStreaming

java.lang.Object

com.hp.hpl.jena.sparql.modify.UpdateEngineBase

com.hp.hpl.jena.sparql.modify.UpdateEngineMain

com.hp.hpl.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 and Description
UpdateEngineNonStreaming(GraphStore graphStore, Context context) Creates a new Update Engine

Method Summary

Methods

Modifier and Type	Method and 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 Detail

UpdateEngineNonStreaming

public UpdateEngineNonStreaming(GraphStore graphStore,
                        Context context)

Creates a new Update Engine

Parameters:

graphStore - Graph Store the updates operate over

context - Execution Context

Method Detail

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()