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

UpdateEngineNonStreaming(GraphStore graphStore, Binding inputBinding, Context context)
Creates a new Update Engine

Method Summary

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,
                                Binding inputBinding,
                                Context context)

Creates a new Update Engine

Parameters:

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