Class UpdateVisitorSink

All Implemented Interfaces:
org.apache.jena.atlas.lib.Closeable, org.apache.jena.atlas.lib.Sink<Update>, UpdateSink

public class UpdateVisitorSink extends Object implements UpdateSink
UpdateSink that sends every Update to a worker except for the quads of INSERT DATA, DELETE DATA which do to special sinks.
  • Constructor Details

    • UpdateVisitorSink

      public UpdateVisitorSink(UpdateVisitor worker, org.apache.jena.atlas.lib.Sink<Quad> addSink, org.apache.jena.atlas.lib.Sink<Quad> delSink)
  • Method Details

    • send

      public void send(Update update)
      Specified by:
      send in interface org.apache.jena.atlas.lib.Sink<Update>
    • createInsertDataSink

      public QuadDataAccSink createInsertDataSink()
      Specified by:
      createInsertDataSink in interface UpdateSink
    • createDeleteDataSink

      public QuadDataAccSink createDeleteDataSink()
      Specified by:
      createDeleteDataSink in interface UpdateSink
    • flush

      public void flush()
      Specified by:
      flush in interface org.apache.jena.atlas.lib.Sink<Update>
    • close

      public void close()
      Specified by:
      close in interface org.apache.jena.atlas.lib.Closeable