Modifier and Type | Method and Description |
---|---|
static LangRIOT |
RiotReader.createParser(InputStream input,
Lang lang,
String baseIRI,
StreamRDF dest)
Deprecated.
|
static LangRIOT |
RiotReader.createParser(Reader input,
Lang lang,
String baseIRI,
StreamRDF dest)
Deprecated.
|
static LangRIOT |
RiotReader.createParser(Tokenizer tokenizer,
Lang lang,
String baseIRI,
StreamRDF dest)
Deprecated.
|
static LangNQuads |
RiotReader.createParserNQuads(InputStream input,
CharSpace charSpace,
StreamRDF dest)
Deprecated.
use an RDFDataMgr operation with argument Lang.NQUADS)
|
static LangNQuads |
RiotReader.createParserNQuads(InputStream input,
StreamRDF dest)
Deprecated.
use an RDFDataMgr operation with argument Lang.NQUADS)
|
static LangNQuads |
RiotReader.createParserNQuads(Tokenizer tokenizer,
StreamRDF dest)
Create a parser for NQuads
|
static LangNTriples |
RiotReader.createParserNTriples(InputStream input,
CharSpace charSpace,
StreamRDF dest)
Deprecated.
use an RDFDataMgr operation with argument Lang.NTRIPLES
|
static LangNTriples |
RiotReader.createParserNTriples(InputStream input,
StreamRDF dest)
Deprecated.
use an RDFDataMgr operation with argument Lang.NTRIPLES
|
static LangNTriples |
RiotReader.createParserNTriples(Tokenizer tokenizer,
StreamRDF dest)
Create a parser for N-Triples
|
static LangRDFJSON |
RiotReader.createParserRdfJson(InputStream input,
StreamRDF dest)
Deprecated.
use RDFDataMgr and Lang.RDFJSON
|
static LangRDFJSON |
RiotReader.createParserRdfJson(Tokenizer tokenizer,
StreamRDF dest)
Create parsers for RDF/JSON
|
static LangRDFXML |
RiotReader.createParserRDFXML(InputStream input,
String baseIRI,
StreamRDF dest)
Deprecated.
use an RDFDataMgr operation with argument Lang.RDFXML
|
static LangTriG |
RiotReader.createParserTriG(InputStream input,
String baseIRI,
StreamRDF dest)
Deprecated.
use an RDFDataMgr operation with argument Lang.TRIG
|
static LangTriG |
RiotReader.createParserTriG(Tokenizer tokenizer,
String baseIRI,
StreamRDF dest)
Create a parser for TriG
|
static LangTurtle |
RiotReader.createParserTurtle(InputStream input,
String baseIRI,
StreamRDF dest)
Deprecated.
use an RDFDataMgr operation with argument Lang.Turtle
|
static LangTurtle |
RiotReader.createParserTurtle(Tokenizer tokenizer,
String baseIRI,
StreamRDF dest)
Create a parser for Turtle
|
static void |
RiotReader.parse(InputStream in,
Lang lang,
StreamRDF dest)
Parse an InputStream, using RDFParserOutput as the destination for the parser output.
|
static void |
RiotReader.parse(InputStream in,
Lang lang,
String baseIRI,
StreamRDF dest)
Parse an InputStream, using RDFParserOutput as the destination for the parser output.
|
static void |
RDFDataMgr.parse(StreamRDF sink,
InputStream in,
Lang lang)
Read RDF data.
|
static void |
RDFDataMgr.parse(StreamRDF sink,
InputStream in,
String base,
Lang hintLang)
Read RDF data.
|
static void |
RDFDataMgr.parse(StreamRDF sink,
InputStream in,
String base,
Lang hintLang,
Context context)
Read RDF data.
|
static void |
RDFDataMgr.parse(StreamRDF sink,
Reader in,
Lang lang)
Deprecated.
Use an InputStream or a StringReader.
|
static void |
RDFDataMgr.parse(StreamRDF sink,
Reader in,
String base,
Lang hintLang)
Deprecated.
Use an InputStream or a StringReader.
|
static void |
RDFDataMgr.parse(StreamRDF sink,
Reader in,
String base,
Lang hintLang,
Context context)
Deprecated.
Use an InputStream or a StringReader.
|
static void |
RDFDataMgr.parse(StreamRDF sink,
String uri)
Read RDF data.
|
static void |
RDFDataMgr.parse(StreamRDF sink,
String uri,
Lang lang)
Read RDF data.
|
static void |
RDFDataMgr.parse(StreamRDF sink,
String uri,
Lang hintLang,
Context context)
Read RDF data.
|
static void |
RDFDataMgr.parse(StreamRDF sink,
StringReader in,
Lang lang)
Read RDF data.
|
static void |
RDFDataMgr.parse(StreamRDF sink,
StringReader in,
String base,
Lang hintLang)
Read RDF data.
|
static void |
RDFDataMgr.parse(StreamRDF sink,
StringReader in,
String base,
Lang hintLang,
Context context)
Read RDF data.
|
static void |
RDFDataMgr.parse(StreamRDF sink,
String uri,
String base,
Lang hintLang,
Context context)
Read RDF data.
|
static void |
RDFDataMgr.parse(StreamRDF sink,
TypedInputStream in)
Read RDF data.
|
static void |
RDFDataMgr.parse(StreamRDF sink,
TypedInputStream in,
String base)
Read RDF data.
|
static void |
RDFDataMgr.parse(StreamRDF sink,
TypedInputStream in,
String base,
Context context)
Read RDF data.
|
static void |
RiotReader.parse(String filename,
Lang lang,
StreamRDF dest)
Parse a file, sending output to a StreamRDF sink.
|
static void |
RiotReader.parse(String filename,
Lang lang,
String baseIRI,
StreamRDF dest)
Parse a file, sending output to a StreamRDF sink.
|
static void |
RiotReader.parse(String filename,
StreamRDF dest)
Parse a file, sending output to a StreamRDF sink.
|
void |
ReaderRIOTBase.read(InputStream in,
String baseURI,
ContentType ct,
StreamRDF output,
Context context) |
void |
ReaderRIOT.read(InputStream in,
String baseURI,
ContentType ct,
StreamRDF output,
Context context)
Read from an InputStream and output RDF on the StreamRDF.
|
abstract void |
ReaderRIOTBase.read(InputStream in,
String baseURI,
Lang lang,
StreamRDF output,
Context context) |
void |
ReaderRIOT.read(Reader reader,
String baseURI,
ContentType ct,
StreamRDF output,
Context context)
Read from an InputStream and output RDF on the StreamRDF.
|
Modifier and Type | Interface and Description |
---|---|
interface |
StreamRDFCounting
Provide counts of triples/quads/tuples
|
Modifier and Type | Class and Description |
---|---|
class |
CollectorStreamBase<T>
Base class for StreamRDF implementations which store received
Collection . |
class |
CollectorStreamQuads
Collector stream for quads.
|
class |
CollectorStreamRDF
StreamRDF implementations which store received triples and quads
in a
Collection . |
class |
CollectorStreamTriples
Collector stream for triples.
|
class |
PipedQuadsStream
Implementation of a producer class that sends Quads; must be connected to a
PipedRDFIterator<Quad> . |
class |
PipedRDFStream<T>
Abstract implementation of a producer class that implements
StreamRDF ;
use one of the concrete implementations that match the RDF primitive you are using. |
class |
PipedTriplesStream
Implementation of a producer class that sends Triples; must be connected to a
PipedRDFIterator<Triple> . |
class |
PipedTuplesStream
Implementation of a producer class that sends @{code Tuple
PipedRDFIterator<Tuple<Node> . |
Modifier and Type | Method and Description |
---|---|
static LangRDFXML |
LangRDFXML.create(InputStream in,
String xmlBase,
String filename,
ErrorHandler errorHandler,
StreamRDF sink) |
static LangRDFXML |
LangRDFXML.create(Reader reader,
String xmlBase,
String filename,
ErrorHandler errorHandler,
StreamRDF sink) |
static LangRDFXML |
LangRDFXML.create(String xmlBase,
String filename,
ErrorHandler errorHandler,
StreamRDF sink) |
void |
ReaderTriX.read(InputStream in,
String baseURI,
ContentType ct,
StreamRDF output,
Context context) |
void |
JsonLDReader.read(InputStream in,
String baseURI,
ContentType ct,
StreamRDF output,
Context context) |
void |
ReaderTriX.read(Reader reader,
String baseURI,
ContentType ct,
StreamRDF output,
Context context) |
void |
JsonLDReader.read(Reader reader,
String baseURI,
ContentType ct,
StreamRDF output,
Context context) |
Constructor and Description |
---|
LangCSV(InputStream in,
String base,
String filename,
ErrorHandler errorHandler,
StreamRDF sink) |
LangCSV(Reader reader,
String base,
String filename,
ErrorHandler errorHandler,
StreamRDF sink) |
LangNQuads(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) |
Modifier and Type | Class and Description |
---|---|
class |
BatchedStreamRDF
Batch a stream into triples and/or quads.
|
Modifier and Type | Class and Description |
---|---|
class |
InferenceProcessorStreamRDF
Receive triples and quads (incoming because this is a StreamRDF);
allow RDFS; output to place provided.
|
Modifier and Type | Method and Description |
---|---|
static StreamRDF |
InfFactory.inf(StreamRDF data,
InferenceSetupRDFS setup) |
static StreamRDF |
InfFactory.inf(StreamRDF data,
Model vocab) |
Modifier and Type | Method and Description |
---|---|
static StreamRDF |
InfFactory.inf(StreamRDF data,
InferenceSetupRDFS setup) |
static StreamRDF |
InfFactory.inf(StreamRDF data,
Model vocab) |
Constructor and Description |
---|
InferenceProcessorStreamRDF(StreamRDF output,
InferenceSetupRDFS rdfsSetup) |
Modifier and Type | Class and Description |
---|---|
class |
LoggingStreamRDF |
class |
PrintingStreamRDF
Primarily for debugging
|
class |
StreamRDF2
Send to two stream
|
class |
StreamRDFBase |
class |
StreamRDFCollectOne
Take one item from a StreamRDF and present as a StreamRowRDF
|
class |
StreamRDFCountingBase
Wrap another StreamRDF and provide counts of items
|
class |
StreamRDFWrapper
A wrapper around another
StreamRDF |
Modifier and Type | Method and Description |
---|---|
StreamRDF |
StreamRDFWriterFactory.create(OutputStream output,
RDFFormat format) |
static StreamRDF |
StreamRDFLib.dataset(DatasetGraph dataset) |
static StreamRDF |
StreamRDFLib.extendTriplesToQuads(Node graphNode,
StreamRDF base)
Convert any triples seen to a quads, adding the specified graph node
|
static StreamRDF |
StreamRDFLib.extendTriplesToQuads(StreamRDF base)
Convert any triples seen to a quads, adding a graph node of
Quad.tripleInQuad |
static StreamRDF |
StreamRDFWriter.getWriterStream(OutputStream output,
Lang lang)
Get a StreamRDF destination that will output in syntax Lang
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 syntax RDFFormat
and is guaranteed to do so in a scaling, streaming fashion.
|
static StreamRDF |
StreamRDFLib.graph(Graph graph) |
static StreamRDF |
StreamRDFLib.sinkNull()
Send everything to nowhere ...
|
static StreamRDF |
StreamRDFLib.sinkQuads(Sink<Quad> sink)
Output to a sink; prefix and base handled only within the parser.
|
static StreamRDF |
StreamRDFLib.sinkTriples(Sink<Triple> sink)
Output to a sink; prefix and base handled only within the parser.
|
static StreamRDF |
StreamRDFLib.writer(AWriter out) |
static StreamRDF |
StreamRDFLib.writer(AWriter out,
CharSpace charSpace) |
static StreamRDF |
StreamRDFLib.writer(OutputStream out) |
static StreamRDF |
StreamRDFLib.writer(OutputStream out,
CharSpace charSpace) |
static StreamRDF |
StreamRDFLib.writer(Writer out) |
static StreamRDF |
StreamRDFLib.writer(Writer out,
CharSpace charSpace) |
Modifier and Type | Method and Description |
---|---|
static StreamRDFCounting |
StreamRDFLib.count(StreamRDF other) |
static void |
StreamOps.datasetToStream(DatasetGraph datasetGraph,
StreamRDF stream)
Send a dataset to a StreamRDF as prefixes, triples and quads, enclosed in stream.start()/steram.finish()
|
static StreamRDF |
StreamRDFLib.extendTriplesToQuads(Node graphNode,
StreamRDF base)
Convert any triples seen to a quads, adding the specified graph node
|
static StreamRDF |
StreamRDFLib.extendTriplesToQuads(StreamRDF base)
Convert any triples seen to a quads, adding a graph node of
Quad.tripleInQuad |
static void |
StreamOps.graphToStream(Graph graph,
StreamRDF stream)
Send the triples of graph and it's prefix mapping to a StreamRDF, enclosed in stream.start()/steram.finish()
|
static void |
StreamOps.sendDatasetToStream(DatasetGraph datasetGraph,
StreamRDF stream)
Send a dataset to a StreamRDF as prefixes, triples and quads
|
static void |
StreamOps.sendDatasetToStream(DatasetGraph datasetGraph,
StreamRDF stream,
PrefixMap prefixMap)
Send a dataset to a StreamRDF as triples and quads, using the explicitly given prefix map
|
static void |
StreamOps.sendGraphToStream(Graph graph,
StreamRDF stream)
Send the triples of graph and an explicitly given prefix mapping, to a StreamRDF
|
static void |
StreamOps.sendGraphToStream(Graph graph,
StreamRDF stream,
PrefixMap prefixMap)
Send the triples of graph and an explicitly given prefix mapping, to a StreamRDF
|
static void |
StreamOps.sendPrefixesToStream(PrefixMapping prefixMap,
StreamRDF stream) |
static void |
StreamOps.sendPrefixesToStream(PrefixMap prefixMap,
StreamRDF stream)
Send a PrefixMap to a stream
|
static void |
StreamOps.sendQuadsToStream(DatasetGraph datasetGraph,
StreamRDF stream)
Send quads of a dataset (including default graph as quads) to a StreamRDF, without prefixes
|
static void |
StreamOps.sendQuadsToStream(Iterator<Quad> iter,
StreamRDF dest)
Set quads to a StreamRDF - does not call .start/.finish
|
static void |
StreamOps.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 prefixes
|
static void |
StreamOps.sendTriplesToStream(Graph graph,
StreamRDF stream)
Send the triples of graph to a StreamRDF (no prefix mapping)
|
static void |
StreamOps.sendTriplesToStream(Iterator<Triple> iter,
StreamRDF dest)
Set triples to a StreamRDF - does not call .start/.finish
|
Constructor and Description |
---|
StreamRDF2(StreamRDF sink1,
StreamRDF sink2) |
StreamRDFCountingBase(StreamRDF other) |
StreamRDFWrapper(StreamRDF sink)
Create a new wrapper
|
Modifier and Type | Class and Description |
---|---|
class |
StreamRDF2Thrift
Encode StreamRDF in Thrift.
|
Modifier and Type | Method and Description |
---|---|
static StreamRDF |
BinRDF.streamToFile(String filename)
Create an
StreamRDF for output. |
static StreamRDF |
BinRDF.streamToFile(String filename,
boolean withValues)
Create an
StreamRDF for output. |
static StreamRDF |
BinRDF.streamToOutputStream(OutputStream out)
Create an
StreamRDF for output. |
static StreamRDF |
BinRDF.streamToOutputStream(OutputStream out,
boolean withValues)
Create an
StreamRDF for output. |
static StreamRDF |
BinRDF.streamToTProtocol(org.apache.thrift.protocol.TProtocol protocol)
Create an
StreamRDF for output. |
static StreamRDF |
BinRDF.streamToTProtocol(org.apache.thrift.protocol.TProtocol protocol,
boolean withValues)
Create an
StreamRDF for output. |
Modifier and Type | Method and Description |
---|---|
static void |
BinRDF.fileToStream(String filename,
StreamRDF dest)
Decode the contents of the file and send to the
StreamRDF . |
static void |
BinRDF.inputStreamToStream(InputStream in,
StreamRDF dest)
Decode the contents of the input stream and send to the
StreamRDF . |
static void |
BinRDF.protocolToStream(org.apache.thrift.protocol.TProtocol protocol,
StreamRDF dest)
Decode the contents of the TProtocol and send to the
StreamRDF . |
Constructor and Description |
---|
Thrift2StreamRDF(PrefixMap pmap,
StreamRDF stream) |
Modifier and Type | Class and Description |
---|---|
class |
StreamWriterTriX
Write TriX by streaming.
|
class |
WriterStreamRDFBase
Core engine for output of triples / quads that is streaming.
|
class |
WriterStreamRDFBlocks
An output of triples / quads that print batches of same subject / same graph, same subject.
|
class |
WriterStreamRDFFlat
An output of triples / quads that is streaming.
|
class |
WriterStreamRDFPlain
An output of triples / quads that is streaming.
|
Licenced under the Apache License, Version 2.0