Uses of Interface
org.apache.jena.riot.system.StreamRDF
Package
Description
RRX (RIOT RDF/XML) is a set of three RDF/XML parsers.
-
Uses of StreamRDF in org.apache.jena.http
Modifier 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
Modifier 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 RDFSModifier 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 RDFSModifierConstructorDescriptionInfStreamRDFS
(StreamRDF output, ConfigRDFS<org.apache.jena.graph.Node> rdfsSetup) -
Uses of StreamRDF in org.apache.jena.riot
Modifier 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
Modifier and TypeInterfaceDescriptioninterface
Provide counts of triples/quads/tuplesModifier 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.Modifier 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
ModifierConstructorDescriptionLangNQuads
(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
Modifier 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
Modifier 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
Modifier 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
Modifier 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
Modifier 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
Modifier and TypeClassDescriptionclass
Apply a function to the object of triple/quads.class
Apply a function to the object of triple/quads.ModifierConstructorDescriptionStreamRDFApply
(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
Modifier 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).Modifier 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 case -
Uses of StreamRDF in org.apache.jena.riot.protobuf
Modifier and TypeClassDescriptionclass
Encode StreamRDF in RDF_StreamRow and send to a handler.Modifier 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.Modifier 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
.Modifier 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) -
Uses of StreamRDF in org.apache.jena.riot.system
Modifier 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.Modifier 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) Modifier 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 quadsModifierConstructorDescriptionStreamRDF2
(StreamRDF sink1, StreamRDF sink2) StreamRDFCountingBase
(StreamRDF other) StreamRDFWrapper
(StreamRDF other) -
Uses of StreamRDF in org.apache.jena.riot.thrift
Modifier 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.Modifier 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
. -
Uses of StreamRDF in org.apache.jena.riot.writer
Modifier 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
Modifier 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
Modifier and TypeClassDescriptionclass
Send ticks to aProgressMonitor
as triples and quads are sent along theStreamRDF
.