Class RecordReaderRdfTrigQuad

    • Constructor Detail

      • RecordReaderRdfTrigQuad

        public RecordReaderRdfTrigQuad()
    • 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.sparql.core.Quad,​org.apache.jena.sparql.core.Quad,​org.apache.jena.sparql.core.Quad>
        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: