Class RecordReaderRdfTrigDataset

  • All Implemented Interfaces:
    Closeable, AutoCloseable

    public class RecordReaderRdfTrigDataset
    extends RecordReaderGenericRdfAccumulatingBase<org.apache.jena.sparql.core.Quad,​org.apache.jena.graph.Node,​org.aksw.jenax.arq.dataset.api.DatasetOneNg,​org.aksw.jenax.arq.dataset.api.DatasetOneNg>
    RecordReader for the Trig RDF format that groups consecutive quads having the same IRI for the graph component into Datasets.
    • Constructor Detail

      • RecordReaderRdfTrigDataset

        public RecordReaderRdfTrigDataset()
    • Method Detail

      • parse

        protected io.reactivex.rxjava3.core.Flowable<org.apache.jena.sparql.core.Quad> parse​(Callable<InputStream> inputStreamSupplier)
        Description copied from class: RecordReaderGenericBase
        Create a flowable from the input stream. The input stream may be incorrectly positioned in which case the Flowable is expected to indicate this by raising an error event.
        Specified by:
        parse in class RecordReaderGenericBase<org.apache.jena.sparql.core.Quad,​org.apache.jena.graph.Node,​org.aksw.jenax.arq.dataset.api.DatasetOneNg,​org.aksw.jenax.arq.dataset.api.DatasetOneNg>
        Parameters:
        inputStreamSupplier - A supplier of input streams. May supply the same underlying stream on each call hence only at most a single stream should be taken from the supplier. Supplied streams are safe to use in try-with-resources blocks (possibly using CloseShieldInputStream). Taken streams should be closed by the client code.
        Returns: