Module org.apache.jena.arq

Package org.apache.jena.sparql.modify

Class UpdateVisitorSink

java.lang.Object

org.apache.jena.sparql.modify.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 Summary

Constructors

Constructor	Description
UpdateVisitorSink(UpdateVisitor worker, org.apache.jena.atlas.lib.Sink<Quad> addSink, org.apache.jena.atlas.lib.Sink<Quad> delSink)

Method Summary

Modifier and Type	Method	Description
void	close()
QuadDataAccSink	createDeleteDataSink()
QuadDataAccSink	createInsertDataSink()
void	flush()
void	send(Update update)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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