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 void
HttpRDF.httpGetToStream
(String url, String acceptHeader, StreamRDF dest) Send the RDF data from the resource at the URL to the StreamRDF.static void
HttpRDF.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 void
HttpRDF.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 StreamRDF
RDFSFactory.streamRDFS
(StreamRDF data, org.apache.jena.graph.Graph vocab) Stream expand data based on a separate vocabularystatic StreamRDF
RDFSFactory.streamRDFS
(StreamRDF data, SetupRDFS setup) Expand a stream of RDF using RDFSMethods in org.apache.jena.rdfs with parameters of type StreamRDFModifier and TypeMethodDescriptionstatic StreamRDF
RDFSFactory.streamRDFS
(StreamRDF data, org.apache.jena.graph.Graph vocab) Stream expand data based on a separate vocabularystatic StreamRDF
RDFSFactory.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 void
Read RDF data.void
Parse the source, sending the results to aStreamRDF
.void
Parse the source, sending the results to aStreamRDF
.void
ReaderRIOT.read
(InputStream in, String baseURI, ContentType ct, StreamRDF output, Context context) Read from an InputStream and output RDF on the StreamRDF.void
Read from an InputStream and output RDF on the StreamRDF.void
ReaderRIOTBase.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 TypeInterfaceDescriptioninterface
Provide counts of triples/quads/tuplesClasses in org.apache.jena.riot.lang that implement StreamRDFModifier and TypeClassDescriptionclass
Base class for StreamRDF implementations which store received<T>
objects in aCollection
.class
Collector stream for quads.class
StreamRDF implementations which stores received triples and quads in aCollection
.class
Collector stream for triples.Methods in org.apache.jena.riot.lang with parameters of type StreamRDFModifier and TypeMethodDescriptionvoid
LangJSONLD11.read
(InputStream input, String baseURI, ContentType ct, StreamRDF output, Context context) void
void
ReaderRDFNULL.read
(InputStream in, String baseURI, ContentType ct, StreamRDF output, Context context) void
ReaderRDFNULL.read
(Reader reader, String baseURI, ContentType ct, StreamRDF output, Context context) void
ReaderTriX.read
(InputStream in, String baseURI, ContentType ct, StreamRDF output, Context context) void
Constructors 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 TypeMethodDescriptionvoid
TurtleJavaccReaderRIOT.read
(InputStream in, String baseURI, ContentType ct, StreamRDF output, Context context) void
TurtleJavaccReaderRIOT.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 TypeMethodDescriptionvoid
ReaderRDFXML_ARP0.read
(InputStream in, String baseURI, ContentType ct, StreamRDF output, Context context) void
ReaderRDFXML_ARP0.read
(Reader reader, String baseURI, ContentType ct, StreamRDF output, Context context) void
ReaderRDFXML_ARP1.read
(InputStream in, String baseURI, ContentType ct, StreamRDF output, Context context) void
ReaderRDFXML_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 TypeMethodDescriptionvoid
ReaderRDFXML_SAX.read
(InputStream in, String baseURI, ContentType ct, StreamRDF output, Context context) void
ReaderRDFXML_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 TypeMethodDescriptionvoid
ReaderRDFXML_StAX_EV.read
(InputStream input, String baseURI, ContentType ct, StreamRDF output, Context context) void
ReaderRDFXML_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 TypeMethodDescriptionvoid
ReaderRDFXML_StAX_SR.read
(InputStream input, String baseURI, ContentType ct, StreamRDF output, Context context) void
ReaderRDFXML_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 TypeClassDescriptionclass
Apply a function to the object of triple/quads.class
Apply 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 TypeClassDescriptionclass
StreamRDF
that converts language tags to lower case or to canonical form (RFC 4646, 5646).class
Canonicalize literal lexical forms (in the object position).Methods in org.apache.jena.riot.process.normalize that return StreamRDFModifier and TypeMethodDescriptionstatic StreamRDF
StreamCanonicalLangTag.toCanonical
(StreamRDF other) Return aStreamRDF
that converts language tags to canonical form (RFC 4646, 5646).static StreamRDF
Return aStreamRDF
that converts language tags to lower caseMethods in org.apache.jena.riot.process.normalize with parameters of type StreamRDFModifier and TypeMethodDescriptionstatic StreamRDF
StreamCanonicalLangTag.toCanonical
(StreamRDF other) Return aStreamRDF
that converts language tags to canonical form (RFC 4646, 5646).static StreamRDF
Return aStreamRDF
that 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 TypeClassDescriptionclass
Encode StreamRDF in RDF_StreamRow and send to a handler.Methods in org.apache.jena.riot.protobuf that return StreamRDFModifier and TypeMethodDescriptionstatic StreamRDF
StreamRDF2Protobuf.createDelimited
(OutputStream outputStream, boolean withValues) static StreamRDF
ProtobufRDF.streamToFile
(String filename) Create anStreamRDF
for output.static StreamRDF
ProtobufRDF.streamToFile
(String filename, boolean withValues) Create anStreamRDF
for output.static StreamRDF
ProtobufRDF.streamToOutputStream
(OutputStream output) AnStreamRDF
that writes to an output stream.static StreamRDF
ProtobufRDF.streamToOutputStream
(OutputStream output, boolean withValues) AnStreamRDF
that writes to an output stream.Methods in org.apache.jena.riot.protobuf with parameters of type StreamRDFModifier and TypeMethodDescriptionstatic void
ProtobufRDF.fileToStream
(String filename, StreamRDF dest) Decode the contents of the file and send to theStreamRDF
.static void
ProtobufRDF_Blk.inputStreamBlkToStreamRDF
(InputStream input, StreamRDF stream) Read an input stream as a single unit (no length delimiters).static void
ProtobufRDF.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 void
ProtobufRDF_Blk.streamToOutputStreamBlk
(OutputStream outputStream, Consumer<StreamRDF> streamDest) Write all of theStreamRDF
to an output stream without length delimiters.static void
StreamRDF2Protobuf.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 TypeClassDescriptionclass
Batch a stream into triples and/or quads.class
class
A StreamRDF which displays the items sent to the stream.class
Send to two streamclass
Apply a function to every triple and quad.class
class
Take one item from a StreamRDF and present as a StreamRowRDFclass
Wrap another StreamRDF and provide counts of itemsclass
class
A wrapper around anotherStreamRDF
class
StreamRDF
that expects triples not quads.Methods in org.apache.jena.riot.system that return StreamRDFModifier and TypeMethodDescriptionstatic StreamRDF
StreamTriplesOnly.addActionIfQuads
(StreamRDF stream, Function<Quad, StreamTriplesOnly.QuadPolicy> action) Add a new policy layer for quadsStreamRDFWriterFactory.create
(OutputStream output, RDFFormat format, Context context) static StreamRDF
StreamRDFLib.dataset
(DatasetGraph dataset) static StreamRDF
StreamTriplesOnly.exceptionOnQuads
(StreamRDF stream) Throw aRiotException
if a non-default graph quad is seen.static StreamRDF
StreamRDFLib.extendTriplesToQuads
(org.apache.jena.graph.Node graphNode, StreamRDF base) Convert any triples seen to a quads, adding the specified graph nodestatic StreamRDF
StreamRDFLib.extendTriplesToQuads
(StreamRDF base) Convert any triples seen to a quads, adding a graph node ofQuad.tripleInQuad
final StreamRDF
StreamRDFWrapper.get()
static StreamRDF
StreamRDFWriter.getWriterStream
(OutputStream output, Lang lang) Get a StreamRDF destination that will output in syntaxLang
and is guaranteed to do so in a scaling, streaming fashion.static StreamRDF
StreamRDFWriter.getWriterStream
(OutputStream output, Lang lang, Context context) Get a StreamRDF destination that will output in syntaxLang
and is guaranteed to do so in a scaling, streaming fashion.static StreamRDF
StreamRDFWriter.getWriterStream
(OutputStream output, RDFFormat format) Get a StreamRDF destination that will output in syntaxRDFFormat
and is guaranteed to do so in a scaling, streaming fashion.static StreamRDF
StreamRDFWriter.getWriterStream
(OutputStream output, RDFFormat format, Context context) Get a StreamRDF destination that will output in syntaxRDFFormat
and is guaranteed to do so in a scaling, streaming fashion.static StreamRDF
StreamRDFLib.graph
(org.apache.jena.graph.Graph graph) static StreamRDF
StreamRDFLib.print
(OutputStream out) Create aStreamRDF
that prints to anOutputStream
.static StreamRDF
StreamRDFLib.print
(org.apache.jena.atlas.io.AWriter out) Create aStreamRDF
that prints to anAWriter
.static StreamRDF
StreamTriplesOnly.setActionIfQuads
(StreamRDF stream, Function<Quad, StreamTriplesOnly.QuadPolicy> action) Replace an existing wrapper with a new policy for quadsstatic StreamRDF
StreamRDFLib.sinkNull()
Send everything to nowhere ... efficientlystatic StreamRDF
Output to a sink; prefix and base handled only within the parser.static StreamRDF
StreamRDFLib.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 StreamRDF
StreamRDFLib.writer
(OutputStream out) Create aStreamRDF
that outputs to anOutputStream
.static StreamRDF
StreamRDFLib.writer
(OutputStream out, org.apache.jena.atlas.lib.CharSpace charSpace) static StreamRDF
static StreamRDF
static StreamRDF
StreamRDFLib.writer
(org.apache.jena.atlas.io.AWriter out) Create aStreamRDF
that outputs to anAWriter
.static StreamRDF
StreamRDFLib.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 StreamRDF
StreamTriplesOnly.addActionIfQuads
(StreamRDF stream, Function<Quad, StreamTriplesOnly.QuadPolicy> action) Add a new policy layer for quadsstatic void
AsyncParser.asyncParse
(InputStream input, Lang lang, String baseURI, StreamRDF output) Function to that parses anInputStream
on a separate thread and sends the output to a StreamRDF on the callers thread.static void
AsyncParser.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 void
AsyncParser.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 void
AsyncParser.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 void
JenaTitanium.convert
(com.apicatalog.rdf.RdfDataset dataset, ParserProfile parserProfile, StreamRDF output) Translate a Titanium JSON-LD dataset to aStreamRDF
static void
Translate a Titanium JSON-LD dataset to aStreamRDF
static StreamRDFCounting
static void
StreamRDFOps.datasetToStream
(DatasetGraph datasetGraph, StreamRDF stream) Send a dataset to a StreamRDF as prefixes, triples and quads, enclosed in stream.start()/stream.finish()static StreamRDF
StreamTriplesOnly.exceptionOnQuads
(StreamRDF stream) Throw aRiotException
if a non-default graph quad is seen.static StreamRDF
StreamRDFLib.extendTriplesToQuads
(org.apache.jena.graph.Node graphNode, StreamRDF base) Convert any triples seen to a quads, adding the specified graph nodestatic StreamRDF
StreamRDFLib.extendTriplesToQuads
(StreamRDF base) Convert any triples seen to a quads, adding a graph node ofQuad.tripleInQuad
static void
StreamRDFOps.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 void
StreamRDFOps.sendDatasetToStream
(DatasetGraph datasetGraph, StreamRDF stream) Send a dataset to a StreamRDF as prefixes, triples and quadsstatic void
StreamRDFOps.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 void
StreamRDFOps.sendGraphToStream
(org.apache.jena.graph.Graph graph, StreamRDF stream) Send the triples of graph and an explicitly given prefix mapping, to a StreamRDF.static void
StreamRDFOps.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 void
StreamRDFOps.sendPrefixesToStream
(PrefixMap prefixMap, StreamRDF stream) Send a PrefixMap to a streamstatic void
StreamRDFOps.sendPrefixesToStream
(org.apache.jena.shared.PrefixMapping prefixMap, StreamRDF stream) static void
StreamRDFOps.sendQuadsToStream
(Iterator<Quad> iter, StreamRDF dest) Set quads to a StreamRDF - does not call .start/.finishstatic void
StreamRDFOps.sendQuadsToStream
(DatasetGraph datasetGraph, StreamRDF stream) Send quads of a dataset (including default graph as quads) to a StreamRDF, without prefixesstatic void
StreamRDFOps.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 void
StreamRDFOps.sendTriplesToStream
(Iterator<org.apache.jena.graph.Triple> iter, StreamRDF dest) Set triples to a StreamRDF - does not call .start/.finishstatic void
StreamRDFOps.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 StreamRDF
StreamTriplesOnly.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 StreamRDF
ThriftRDF.streamToFile
(String filename) Create anStreamRDF
for output.static StreamRDF
ThriftRDF.streamToFile
(String filename, boolean withValues) Create anStreamRDF
for output.static StreamRDF
ThriftRDF.streamToOutputStream
(OutputStream out) Create anStreamRDF
for output.static StreamRDF
ThriftRDF.streamToOutputStream
(OutputStream out, boolean withValues) Create anStreamRDF
for output.static StreamRDF
ThriftRDF.streamToTProtocol
(org.apache.thrift.protocol.TProtocol protocol) Create anStreamRDF
for output.static StreamRDF
ThriftRDF.streamToTProtocol
(org.apache.thrift.protocol.TProtocol protocol, boolean withValues) Create anStreamRDF
for output.Methods in org.apache.jena.riot.thrift with parameters of type StreamRDFModifier and TypeMethodDescriptionstatic void
ThriftRDF.fileToStream
(String filename, StreamRDF dest) Decode the contents of the file and send to theStreamRDF
.static void
ThriftRDF.inputStreamToStream
(InputStream in, StreamRDF dest) Decode the contents of the input stream and send to theStreamRDF
.static void
ThriftRDF.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 TypeClassDescriptionclass
Write TriX by streaming.class
Core engine for output of triples / quads that is streaming.class
An output of triples / quads that print batches of same subject / same graph, same subject.class
An output of triples / quads that is streaming.class
An output of triples / quads that is streaming. -
Uses of StreamRDF in org.apache.jena.system
Methods in org.apache.jena.system with parameters of type StreamRDFModifier and TypeMethodDescriptionstatic void
RDFStar.decodeFromRDF
(org.apache.jena.graph.Graph graph, StreamRDF dest) Copy the argument graph to aStreamRDF
, replacing reifications with for triple terms.static void
RDFStar.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 TypeClassDescriptionclass
Send ticks to aProgressMonitor
as triples and quads are sent along theStreamRDF
.Constructors in org.apache.jena.system.progress with parameters of type StreamRDF