Class UpdateVisitorSink

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

    public class UpdateVisitorSink
    extends java.lang.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 Detail

      • UpdateVisitorSink

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

      • send

        public void send​(Update update)
        Specified by:
        send in interface org.apache.jena.atlas.lib.Sink<Update>
      • 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