Class UpdateEngineMain

All Implemented Interfaces:
Direct Known Subclasses:

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 Details

    • UpdateEngineMain

      public UpdateEngineMain(DatasetGraph datasetGraph, Binding inputBinding, Context context)
      Creates a new Update Engine
      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()