A destination that is composed of different child destinations.
A destination which groups quads by dataset and writes them to different destinations.
A destination which groups quads by dataset and writes them to different destinations.
This class does not use synchronization, but if the target datasets are thread-safe then so is this destination. The write() method may be executed concurrently by multiple threads.
A destination for RDF quads.
Passes quads through to the target destination until a maximum number of quads is reached.
Passes quads through to the target destination until a maximum number of quads is reached. After that, additional quads are ignored.
TODO: Maybe this should be a mixin trait?
Handles a marker file that signals that the extraction is either running ('start mode') or finished ('end mode').
Handles a marker file that signals that the extraction is either running ('start mode') or finished ('end mode').
In 'start mode', the file is created before the extraction starts (it must not already exist) and deleted after the extraction ends.
In 'end mode', the file is deleted before the extraction starts (if it already exists) and re-created after the extraction ends.
Base class for destinations that forward most calls to another destination.
Writes quads to a writer.
Created by Chile on 9/29/2016.
A destination that is composed of different child destinations. Each statement is forwarded to all child destinations.
This class does not use synchronization, but if the target datasets are thread-safe then so is this destination. The write() method may be executed concurrently by multiple threads.