Uses of Interface
org.apache.jena.riot.system.StreamRDF
Packages that use StreamRDF
Package
Description
RRX (RIOT RDF/XML) is a set of three RDF/XML parsers.
-
Uses of StreamRDF in org.apache.jena.http
Methods in org.apache.jena.http with parameters of type StreamRDFModifier and TypeMethodDescriptionstatic CompletableFuture<Void>AsyncHttpRDF.asyncGetToStream(HttpClient httpClient, String url, String acceptHeader, StreamRDF dest, Transactional transactional) Execute an asynchronous GET and parse the result to a StreamRDF.static voidHttpRDF.httpGetToStream(String url, String acceptHeader, StreamRDF dest) Send the RDF data from the resource at the URL to the StreamRDF.static voidHttpRDF.httpGetToStream(HttpClient client, String url, String acceptHeader, StreamRDF dest) Read the RDF data from the resource at the URL and send to the StreamRDF.static voidHttpRDF.httpGetToStream(HttpClient client, String url, Map<String, String> headers, StreamRDF dest) Read the RDF data from the resource at the URL and send to the StreamRDF. -
Uses of StreamRDF in org.apache.jena.rdfs
Classes in org.apache.jena.rdfs that implement StreamRDFMethods in org.apache.jena.rdfs that return StreamRDFModifier and TypeMethodDescriptionstatic StreamRDFRDFSFactory.removeGeneralizedRDF(StreamRDF data) RDFS can generate "symmetric RDF", "generalized RDF" - e.g. triples with literals as subjects.static StreamRDFRDFSFactory.streamRDFS(StreamRDF data, org.apache.jena.graph.Graph vocab) Stream expand data based on a separate vocabularystatic StreamRDFRDFSFactory.streamRDFS(StreamRDF data, SetupRDFS setup) Expand a stream of RDF using RDFSMethods in org.apache.jena.rdfs with parameters of type StreamRDFModifier and TypeMethodDescriptionstatic StreamRDFRDFSFactory.removeGeneralizedRDF(StreamRDF data) RDFS can generate "symmetric RDF", "generalized RDF" - e.g. triples with literals as subjects.static StreamRDFRDFSFactory.streamRDFS(StreamRDF data, org.apache.jena.graph.Graph vocab) Stream expand data based on a separate vocabularystatic StreamRDFRDFSFactory.streamRDFS(StreamRDF data, SetupRDFS setup) Expand a stream of RDF using RDFSConstructors in org.apache.jena.rdfs with parameters of type StreamRDFModifierConstructorDescriptionInfStreamRDFS(StreamRDF output, ConfigRDFS<org.apache.jena.graph.Node> rdfsSetup) -
Uses of StreamRDF in org.apache.jena.riot
Methods in org.apache.jena.riot with parameters of type StreamRDFModifier and TypeMethodDescriptionstatic voidRead RDF data.voidParse the source, sending the results to aStreamRDF.voidParse the source, sending the results to aStreamRDF.voidReaderRIOT.read(InputStream in, String baseURI, ContentType ct, StreamRDF output, Context context) Read from an InputStream and output RDF on the StreamRDF.voidRead from an InputStream and output RDF on the StreamRDF.voidReaderRIOTBase.read(InputStream in, String baseURI, ContentType ct, StreamRDF output, Context context) abstract void -
Uses of StreamRDF in org.apache.jena.riot.lang
Subinterfaces of StreamRDF in org.apache.jena.riot.langModifier and TypeInterfaceDescriptioninterfaceProvide counts of triples/quads/tuplesClasses in org.apache.jena.riot.lang that implement StreamRDFModifier and TypeClassDescriptionclassDeprecated.classDeprecated, for removal: This API element is subject to removal in a future version.classStreamRDF implementations which stores received triples and quads in aCollection.classDeprecated, for removal: This API element is subject to removal in a future version.Methods in org.apache.jena.riot.lang with parameters of type StreamRDFModifier and TypeMethodDescriptionvoidLangJSONLD11.read(InputStream input, String baseURI, ContentType ct, StreamRDF output, Context context) voidvoidReaderRDFNULL.read(InputStream in, String baseURI, ContentType ct, StreamRDF output, Context context) voidReaderRDFNULL.read(Reader reader, String baseURI, ContentType ct, StreamRDF output, Context context) voidReaderTriX.read(InputStream in, String baseURI, ContentType ct, StreamRDF output, Context context) voidConstructors in org.apache.jena.riot.lang with parameters of type StreamRDFModifierConstructorDescriptionLangNQuads(Tokenizer tokens, ParserProfile profile, StreamRDF dest) LangNTriples(Tokenizer tokens, ParserProfile profile, StreamRDF dest) LangRDFJSON(Tokenizer tokenizer, ParserProfile profile, StreamRDF dest) LangTriG(Tokenizer tokens, ParserProfile profile, StreamRDF dest) LangTurtle(Tokenizer tokens, ParserProfile profile, StreamRDF dest) -
Uses of StreamRDF in org.apache.jena.riot.lang.extra
Methods in org.apache.jena.riot.lang.extra with parameters of type StreamRDFModifier and TypeMethodDescriptionvoidTurtleJavaccReaderRIOT.read(InputStream in, String baseURI, ContentType ct, StreamRDF output, Context context) voidTurtleJavaccReaderRIOT.read(Reader reader, String baseURI, ContentType ct, StreamRDF output, Context context) void -
Uses of StreamRDF in org.apache.jena.riot.lang.rdfxml
Methods in org.apache.jena.riot.lang.rdfxml with parameters of type StreamRDFModifier and TypeMethodDescriptionvoidReaderRDFXML_ARP1.read(InputStream in, String baseURI, ContentType ct, StreamRDF output, Context context) voidReaderRDFXML_ARP1.read(Reader reader, String baseURI, ContentType ct, StreamRDF output, Context context) -
Uses of StreamRDF in org.apache.jena.riot.lang.rdfxml.rrx
Methods in org.apache.jena.riot.lang.rdfxml.rrx with parameters of type StreamRDFModifier and TypeMethodDescriptionvoidReaderRDFXML_SAX.read(InputStream in, String baseURI, ContentType ct, StreamRDF output, Context context) voidReaderRDFXML_SAX.read(Reader reader, String baseURI, ContentType ct, StreamRDF output, Context context) -
Uses of StreamRDF in org.apache.jena.riot.lang.rdfxml.rrx_stax_ev
Methods in org.apache.jena.riot.lang.rdfxml.rrx_stax_ev with parameters of type StreamRDFModifier and TypeMethodDescriptionvoidReaderRDFXML_StAX_EV.read(InputStream input, String baseURI, ContentType ct, StreamRDF output, Context context) voidReaderRDFXML_StAX_EV.read(Reader reader, String baseURI, ContentType ct, StreamRDF output, Context context) -
Uses of StreamRDF in org.apache.jena.riot.lang.rdfxml.rrx_stax_sr
Methods in org.apache.jena.riot.lang.rdfxml.rrx_stax_sr with parameters of type StreamRDFModifier and TypeMethodDescriptionvoidReaderRDFXML_StAX_SR.read(InputStream input, String baseURI, ContentType ct, StreamRDF output, Context context) voidReaderRDFXML_StAX_SR.read(Reader reader, String baseURI, ContentType ct, StreamRDF output, Context context) -
Uses of StreamRDF in org.apache.jena.riot.process
Classes in org.apache.jena.riot.process that implement StreamRDFModifier and TypeClassDescriptionclassApply a function to the object of triple/quads.classApply a function to the object of triple/quads.Constructors in org.apache.jena.riot.process with parameters of type StreamRDFModifierConstructorDescriptionStreamRDFApply(StreamRDF other, Function<org.apache.jena.graph.Node, org.apache.jena.graph.Node> sFunction, Function<org.apache.jena.graph.Node, org.apache.jena.graph.Node> pFunction, Function<org.apache.jena.graph.Node, org.apache.jena.graph.Node> oFunction) StreamRDFApply(StreamRDF other, Function<org.apache.jena.graph.Node, org.apache.jena.graph.Node> gFunction, Function<org.apache.jena.graph.Node, org.apache.jena.graph.Node> sFunction, Function<org.apache.jena.graph.Node, org.apache.jena.graph.Node> pFunction, Function<org.apache.jena.graph.Node, org.apache.jena.graph.Node> oFunction) StreamRDFApplyObject(StreamRDF other, Function<org.apache.jena.graph.Node, org.apache.jena.graph.Node> function) -
Uses of StreamRDF in org.apache.jena.riot.process.normalize
Classes in org.apache.jena.riot.process.normalize that implement StreamRDFModifier and TypeClassDescriptionclassStreamRDFthat converts language tags to lower case or to canonical form (RFC 4646, 5646).classCanonicalize literal lexical forms (in the object position).Methods in org.apache.jena.riot.process.normalize that return StreamRDFModifier and TypeMethodDescriptionstatic StreamRDFStreamCanonicalLangTag.toCanonical(StreamRDF other) Return aStreamRDFthat converts language tags to canonical form (RFC 4646, 5646).static StreamRDFReturn aStreamRDFthat converts language tags to lower caseMethods in org.apache.jena.riot.process.normalize with parameters of type StreamRDFModifier and TypeMethodDescriptionstatic StreamRDFStreamCanonicalLangTag.toCanonical(StreamRDF other) Return aStreamRDFthat converts language tags to canonical form (RFC 4646, 5646).static StreamRDFReturn aStreamRDFthat converts language tags to lower caseConstructors in org.apache.jena.riot.process.normalize with parameters of type StreamRDF -
Uses of StreamRDF in org.apache.jena.riot.protobuf
Classes in org.apache.jena.riot.protobuf that implement StreamRDFModifier and TypeClassDescriptionclassEncode StreamRDF in RDF_StreamRow and send to a handler.Methods in org.apache.jena.riot.protobuf that return StreamRDFModifier and TypeMethodDescriptionstatic StreamRDFStreamRDF2Protobuf.createDelimited(OutputStream outputStream, boolean withValues) static StreamRDFProtobufRDF.streamToFile(String filename) Create anStreamRDFfor output.static StreamRDFProtobufRDF.streamToFile(String filename, boolean withValues) Create anStreamRDFfor output.static StreamRDFProtobufRDF.streamToOutputStream(OutputStream output) AnStreamRDFthat writes to an output stream.static StreamRDFProtobufRDF.streamToOutputStream(OutputStream output, boolean withValues) AnStreamRDFthat writes to an output stream.Methods in org.apache.jena.riot.protobuf with parameters of type StreamRDFModifier and TypeMethodDescriptionstatic voidProtobufRDF.fileToStream(String filename, StreamRDF dest) Decode the contents of the file and send to theStreamRDF.static voidProtobufRDF_Blk.inputStreamBlkToStreamRDF(InputStream input, StreamRDF stream) Read an input stream as a single unit (no length delimiters).static voidProtobufRDF.inputStreamToStreamRDF(InputStream input, StreamRDF stream) Read an input stream and send item to theStreamRDF.Method parameters in org.apache.jena.riot.protobuf with type arguments of type StreamRDFModifier and TypeMethodDescriptionstatic voidProtobufRDF_Blk.streamToOutputStreamBlk(OutputStream outputStream, Consumer<StreamRDF> streamDest) Write all of theStreamRDFto an output stream without length delimiters.static voidStreamRDF2Protobuf.writeBlk(OutputStream outputStream, Consumer<StreamRDF> stream, boolean withValues) Constructors in org.apache.jena.riot.protobuf with parameters of type StreamRDF -
Uses of StreamRDF in org.apache.jena.riot.system
Classes in org.apache.jena.riot.system that implement StreamRDFModifier and TypeClassDescriptionclassBatch a stream into triples and/or quads.classclassA StreamRDF which displays the items sent to the stream.classSend to two streamsclassApply a function to every triple and quad.classclassTake one item from a StreamRDF and present as a StreamRowRDFclassWrap another StreamRDF and provide counts of itemsclassclassA wrapper around anotherStreamRDFclassStreamRDFthat expects triples not quads.Methods in org.apache.jena.riot.system that return StreamRDFModifier and TypeMethodDescriptionstatic StreamRDFStreamTriplesOnly.addActionIfQuads(StreamRDF stream, Function<Quad, StreamTriplesOnly.QuadPolicy> action) Add a new policy layer for quadsStreamRDFWriterFactory.create(OutputStream output, RDFFormat format, Context context) static StreamRDFStreamRDFLib.dataset(DatasetGraph dataset) static StreamRDFStreamTriplesOnly.exceptionOnQuads(StreamRDF stream) Throw aRiotExceptionif a non-default graph quad is seen.static StreamRDFStreamRDFLib.extendTriplesToQuads(org.apache.jena.graph.Node graphNode, StreamRDF base) Convert any triples seen to a quads, adding the specified graph nodestatic StreamRDFStreamRDFLib.extendTriplesToQuads(StreamRDF base) Convert any triples seen to a quads, adding a graph node ofQuad.tripleInQuadfinal StreamRDFStreamRDFWrapper.get()static StreamRDFStreamRDFWriter.getWriterStream(OutputStream output, Lang lang) Get a StreamRDF destination that will output in syntaxLangand is guaranteed to do so in a scaling, streaming fashion.static StreamRDFStreamRDFWriter.getWriterStream(OutputStream output, Lang lang, Context context) Get a StreamRDF destination that will output in syntaxLangand is guaranteed to do so in a scaling, streaming fashion.static StreamRDFStreamRDFWriter.getWriterStream(OutputStream output, RDFFormat format) Get a StreamRDF destination that will output in syntaxRDFFormatand is guaranteed to do so in a scaling, streaming fashion.static StreamRDFStreamRDFWriter.getWriterStream(OutputStream output, RDFFormat format, Context context) Get a StreamRDF destination that will output in syntaxRDFFormatand is guaranteed to do so in a scaling, streaming fashion.static StreamRDFStreamRDFLib.graph(org.apache.jena.graph.Graph graph) static StreamRDFStreamRDFLib.print(OutputStream out) Create aStreamRDFthat prints to anOutputStream.static StreamRDFStreamRDFLib.print(org.apache.jena.atlas.io.AWriter out) Create aStreamRDFthat prints to anAWriter.static StreamRDFStreamTriplesOnly.setActionIfQuads(StreamRDF stream, Function<Quad, StreamTriplesOnly.QuadPolicy> action) Replace an existing wrapper with a new policy for quadsstatic StreamRDFStreamRDFLib.sinkNull()Send everything to nowhere ... efficientlystatic StreamRDFOutput to a sink; prefix and base handled only within the parser.static StreamRDFStreamRDFLib.sinkTriples(org.apache.jena.atlas.lib.Sink<org.apache.jena.graph.Triple> sink) Output to a sink; prefix and base handled only within the parser.static StreamRDFStreamRDFLib.writer(OutputStream out) Create aStreamRDFthat outputs to anOutputStream.static StreamRDFStreamRDFLib.writer(OutputStream out, org.apache.jena.atlas.lib.CharSpace charSpace) static StreamRDFstatic StreamRDFstatic StreamRDFStreamRDFLib.writer(org.apache.jena.atlas.io.AWriter out) Create aStreamRDFthat outputs to anAWriter.static StreamRDFStreamRDFLib.writer(org.apache.jena.atlas.io.AWriter out, org.apache.jena.atlas.lib.CharSpace charSpace) Methods in org.apache.jena.riot.system with parameters of type StreamRDFModifier and TypeMethodDescriptionstatic StreamRDFStreamTriplesOnly.addActionIfQuads(StreamRDF stream, Function<Quad, StreamTriplesOnly.QuadPolicy> action) Add a new policy layer for quadsstatic voidAsyncParser.asyncParse(InputStream input, Lang lang, String baseURI, StreamRDF output) Function to that parses anInputStreamon a separate thread and sends the output to a StreamRDF on the callers thread.static voidAsyncParser.asyncParse(String fileOrURL, StreamRDF output) Function that reads a file or GETs a URL, parses the content on a separate thread and sends the output to a StreamRDF on the callers thread.static voidAsyncParser.asyncParse(List<String> filesOrURLs, StreamRDF output) Function that parses content from a list of files or URLs on a separate thread and sends the output to a StreamRDF on the callers thread.static voidAsyncParser.asyncParseSources(List<RDFParserBuilder> sources, StreamRDF output) Parse a number of sources (RDFParserBuilders) on a separate thread and send the output to a StreamRDF on the callers thread.AsyncParserBuilder.asyncParseSources(StreamRDF output) Calling the returned runnable stops parsing.static voidJenaTitanium.convert(com.apicatalog.rdf.RdfDataset dataset, ParserProfile parserProfile, StreamRDF output) Deprecated, for removal: This API element is subject to removal in a future version.No longer used by the LangJSONLD_11static voidDeprecated, for removal: This API element is subject to removal in a future version.No longer used by the LangJSONLD_11static StreamRDFCountingstatic voidStreamRDFOps.datasetToStream(DatasetGraph datasetGraph, StreamRDF stream) Send a dataset to a StreamRDF as prefixes, triples and quads, enclosed in stream.start()/stream.finish()static StreamRDFStreamTriplesOnly.exceptionOnQuads(StreamRDF stream) Throw aRiotExceptionif a non-default graph quad is seen.static StreamRDFStreamRDFLib.extendTriplesToQuads(org.apache.jena.graph.Node graphNode, StreamRDF base) Convert any triples seen to a quads, adding the specified graph nodestatic StreamRDFStreamRDFLib.extendTriplesToQuads(StreamRDF base) Convert any triples seen to a quads, adding a graph node ofQuad.tripleInQuadstatic voidStreamRDFOps.graphToStream(org.apache.jena.graph.Graph graph, StreamRDF stream) Send the triples of graph and it's prefix mapping to a StreamRDF, enclosed in stream.start()/stream.finish()static voidStreamRDFOps.sendDatasetToStream(DatasetGraph datasetGraph, StreamRDF stream) Send a dataset to a StreamRDF as prefixes, triples and quadsstatic voidStreamRDFOps.sendDatasetToStream(DatasetGraph datasetGraph, StreamRDF stream, String baseURI, PrefixMap prefixMap) Send a dataset to a StreamRDF as triples and quads, using the explicitly given prefix mapstatic voidStreamRDFOps.sendGraphToStream(org.apache.jena.graph.Graph graph, StreamRDF stream) Send the triples of graph and an explicitly given prefix mapping, to a StreamRDF.static voidStreamRDFOps.sendGraphToStream(org.apache.jena.graph.Graph graph, StreamRDF stream, String baseURI, PrefixMap prefixMap) Send the triples of graph, and an explicitly given prefix mapping, to a StreamRDFstatic voidStreamRDFOps.sendPrefixesToStream(PrefixMap prefixMap, StreamRDF stream) Send a PrefixMap to a streamstatic voidStreamRDFOps.sendPrefixesToStream(org.apache.jena.shared.PrefixMapping prefixMap, StreamRDF stream) static voidStreamRDFOps.sendQuadsToStream(Iterator<Quad> iter, StreamRDF dest) Set quads to a StreamRDF - does not call .start/.finishstatic voidStreamRDFOps.sendQuadsToStream(DatasetGraph datasetGraph, StreamRDF stream) Send quads of a dataset (including default graph as quads) to a StreamRDF, without prefixesstatic voidStreamRDFOps.sendTriplesQuadsToStream(DatasetGraph datasetGraph, StreamRDF stream) Send a dataset graph to a stream with triples for the default graph and quads for the named graphs without prefixesstatic voidStreamRDFOps.sendTriplesToStream(Iterator<org.apache.jena.graph.Triple> iter, StreamRDF dest) Set triples to a StreamRDF - does not call .start/.finishstatic voidStreamRDFOps.sendTriplesToStream(org.apache.jena.graph.Graph graph, StreamRDF stream) Send the triples of graph to a StreamRDF (no prefix mapping) See alsoStreamRDFOps.sendGraphToStream(org.apache.jena.graph.Graph, org.apache.jena.riot.system.StreamRDF)which does send the prefix mapping.static StreamRDFStreamTriplesOnly.setActionIfQuads(StreamRDF stream, Function<Quad, StreamTriplesOnly.QuadPolicy> action) Replace an existing wrapper with a new policy for quadsConstructors in org.apache.jena.riot.system with parameters of type StreamRDFModifierConstructorDescriptionStreamRDF2(StreamRDF sink1, StreamRDF sink2) StreamRDFCountingBase(StreamRDF other) StreamRDFWrapper(StreamRDF other) -
Uses of StreamRDF in org.apache.jena.riot.thrift
Classes in org.apache.jena.riot.thrift that implement StreamRDFMethods in org.apache.jena.riot.thrift that return StreamRDFModifier and TypeMethodDescriptionstatic StreamRDFThriftRDF.streamToFile(String filename) Create anStreamRDFfor output.static StreamRDFThriftRDF.streamToFile(String filename, boolean withValues) Create anStreamRDFfor output.static StreamRDFThriftRDF.streamToOutputStream(OutputStream out) Create anStreamRDFfor output.static StreamRDFThriftRDF.streamToOutputStream(OutputStream out, boolean withValues) Create anStreamRDFfor output.static StreamRDFThriftRDF.streamToTProtocol(org.apache.thrift.protocol.TProtocol protocol) Create anStreamRDFfor output.static StreamRDFThriftRDF.streamToTProtocol(org.apache.thrift.protocol.TProtocol protocol, boolean withValues) Create anStreamRDFfor output.Methods in org.apache.jena.riot.thrift with parameters of type StreamRDFModifier and TypeMethodDescriptionstatic voidThriftRDF.fileToStream(String filename, StreamRDF dest) Decode the contents of the file and send to theStreamRDF.static voidThriftRDF.inputStreamToStream(InputStream in, StreamRDF dest) Decode the contents of the input stream and send to theStreamRDF.static voidThriftRDF.protocolToStream(org.apache.thrift.protocol.TProtocol protocol, StreamRDF dest) Decode the contents of the TProtocol and send to theStreamRDF.Constructors in org.apache.jena.riot.thrift with parameters of type StreamRDF -
Uses of StreamRDF in org.apache.jena.riot.writer
Classes in org.apache.jena.riot.writer that implement StreamRDFModifier and TypeClassDescriptionclassWrite TriX by streaming.classCore engine for output of triples / quads that is streaming.classAn output of triples / quads that print batches of same subject / same graph, same subject.classAn output of triples / quads that is streaming.classAn output of triples / quads that is streaming. -
Uses of StreamRDF in org.apache.jena.sparql.util
Methods in org.apache.jena.sparql.util that return StreamRDFModifier and TypeMethodDescriptionstatic StreamRDFNodeUtils.removeGeneralizedRDF(StreamRDF data) Filter out triples and quads that are "generalized" RDFMethods in org.apache.jena.sparql.util with parameters of type StreamRDFModifier and TypeMethodDescriptionstatic StreamRDFNodeUtils.removeGeneralizedRDF(StreamRDF data) Filter out triples and quads that are "generalized" RDF -
Uses of StreamRDF in org.apache.jena.system
Methods in org.apache.jena.system with parameters of type StreamRDFModifier and TypeMethodDescriptionstatic voidRDFStar.decodeFromRDF(org.apache.jena.graph.Graph graph, StreamRDF dest) Copy the argument graph to aStreamRDF, replacing reifications with for triple terms.static voidRDFStar.encodeAsRDF(org.apache.jena.graph.Graph graph, StreamRDF dest) Copy to aStreamRDF, encoding RDF-star Triple terms by replacing them with RDF Reification. -
Uses of StreamRDF in org.apache.jena.system.progress
Classes in org.apache.jena.system.progress that implement StreamRDFModifier and TypeClassDescriptionclassSend ticks to aProgressMonitoras triples and quads are sent along theStreamRDF.Constructors in org.apache.jena.system.progress with parameters of type StreamRDF
CollectorStreamRDF