Modifier and Type | Class and Description |
---|---|
class |
BindingOutputStream
Parser for the RDF Tuples language
|
Modifier and Type | Class and Description |
---|---|
class |
UpdateDataWriter |
Modifier and Type | Interface and Description |
---|---|
interface |
DataBag<T>
A collection of Tuples.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractDataBag<E>
Abstract implementation of DataBag.
|
class |
DefaultDataBag<E>
This data bag will gather items in memory until a size threshold is passed, at which point it will write
out all of the items to disk using the supplied serializer.
|
class |
DistinctDataBag<E>
This data bag will gather distinct items in memory until a size threshold is passed, at which point it will write
out all of the items to disk using the supplied serializer.
|
class |
DistinctDataNet<E>
This class is like
DistinctDataBag except that you are informed if the item you just
added was known to be distinct. |
class |
SortedDataBag<E>
This data bag will gather items in memory until a size threshold is passed, at which point it will write
out all of the items to disk using the supplied serializer.
|
Modifier and Type | Method and Description |
---|---|
Sink<E> |
SerializationFactory.createSerializer(OutputStream out) |
Modifier and Type | Class and Description |
---|---|
static class |
BufferingWriter.SinkBuffer |
static class |
BufferingWriter.SinkChannel |
static class |
BufferingWriter.SinkOutputStream |
Constructor and Description |
---|
BufferingWriter(Sink<ByteBuffer> sink)
Create a buffering output stream of charcaters to a
Sink |
Modifier and Type | Method and Description |
---|---|
static <T> void |
Iter.sendToSink(Iterable<T> stream,
Sink<T> sink)
Send the elements of the iterator to a sink - consumes the iterator
|
static <T> void |
Iter.sendToSink(Iterator<T> iter,
Sink<T> sink)
Send the elements of the iterator to a sink - consumes the iterator
|
void |
Iter.sendToSink(Sink<T> sink) |
Modifier and Type | Class and Description |
---|---|
class |
SinkCounting<T> |
class |
SinkLogging<T> |
class |
SinkNull<T> |
class |
SinkPrint<T> |
class |
SinkSplit<T>
Split a sink stream and duplicate the operations onto two sinks
See also:
SinkWrapper |
class |
SinkToQueue<T>
Send items to a blocking queue
|
class |
SinkWrapper<T>
Wrap one sink in another - to pass on behaviour, the derived Sink must call super.operation
See also:
SinkSplit |
Constructor and Description |
---|
SinkCounting(Sink<T> output) |
SinkSplit(Sink<T> sink1,
Sink<T> sink2) |
SinkSplit(Sink<T> sink1,
Sink<T> sink2) |
SinkWrapper(Sink<T> sink) |
Modifier and Type | Method and Description |
---|---|
static Sink<Quad> |
RiotLoader.datasetSink(DatasetGraph dataset) |
static Sink<Triple> |
RiotLoader.graphSink(Graph graph) |
Modifier and Type | Method and Description |
---|---|
static LangNQuads |
RiotReader.createParserNQuads(InputStream input,
Sink<Quad> sink)
Create a parser for NQuads, with default behaviour
|
static LangNQuads |
RiotReader.createParserNQuads(Tokenizer tokenizer,
Sink<Quad> sink)
Create a parser for NQuads, with default behaviour
|
static LangNTriples |
RiotReader.createParserNTriples(InputStream input,
Sink<Triple> sink)
Create a parser for N-Triples, with default behaviour
|
static LangNTriples |
RiotReader.createParserNTriples(Tokenizer tokenizer,
Sink<Triple> sink)
Create a parser for N-Triples, with default behaviour
|
static LangRIOT |
RiotReader.createParserQuads(InputStream input,
Lang lang,
String baseIRI,
Sink<Quad> sink)
Create a parser for a quads (or triples) language
|
static LangRIOT |
RiotReader.createParserQuads(Tokenizer tokenizer,
Lang lang,
String baseIRI,
Sink<Quad> sink)
Create a parser for a quads language
|
static LangRDFJSON |
RiotReader.createParserRdfJson(InputStream input,
Sink<Triple> sink) |
static LangRDFJSON |
RiotReader.createParserRdfJson(Tokenizer tokenizer,
Sink<Triple> sink)
Create parsers for RDF/JSON
|
static LangRDFXML |
RiotReader.createParserRDFXML(InputStream input,
String baseIRI,
Sink<Triple> sink)
Create a parser for RDF/XML
|
static LangTriG |
RiotReader.createParserTriG(InputStream input,
String baseIRI,
Sink<Quad> sink)
Create a parser for TriG, with default behaviour
|
static LangTriG |
RiotReader.createParserTriG(Tokenizer tokenizer,
String baseIRI,
Sink<Quad> sink)
Create a parser for TriG, with default behaviour
|
static LangRIOT |
RiotReader.createParserTriples(InputStream input,
Lang lang,
String baseIRI,
Sink<Triple> sink)
Create a parser for a triples language
|
static LangRIOT |
RiotReader.createParserTriples(Tokenizer tokenizer,
Lang lang,
String baseIRI,
Sink<Triple> sink)
Create a parser for a triples language
|
static LangTurtle |
RiotReader.createParserTurtle(InputStream input,
String baseIRI,
Sink<Triple> sink)
Create a parser for Turtle, with default behaviour
|
static LangTurtle |
RiotReader.createParserTurtle(Tokenizer tokenizer,
String baseIRI,
Sink<Triple> sink)
Create a parser for Turtle, with default behaviour
|
static void |
RiotReader.parseQuads(InputStream in,
Lang lang,
String baseIRI,
Sink<Quad> sink)
Parse an InputStream, sending quads to a sink.
|
static void |
RiotReader.parseQuads(String filename,
Lang lang,
String baseIRI,
Sink<Quad> sink)
Parse a file, sending quads to a sink.
|
static void |
RiotReader.parseQuads(String filename,
Sink<Quad> sink)
Parse a file, sending quads to a sink.
|
static void |
RiotReader.parseTriples(InputStream in,
Lang lang,
String baseIRI,
Sink<Triple> sink)
Parse an InputStream, sending triples to a sink.
|
static void |
RiotReader.parseTriples(String filename,
Lang lang,
String baseIRI,
Sink<Triple> sink)
Parse a file, sending triples to a sink.
|
static void |
RiotReader.parseTriples(String filename,
Sink<Triple> sink)
Parse a file, sending triples to a sink.
|
static void |
RiotLoader.readQuads(InputStream input,
Lang language,
String baseURI,
Sink<Quad> sink)
Parse an input stream and send the quads to the sink
|
static void |
RiotLoader.readTriples(InputStream input,
Lang language,
String baseURI,
Sink<Triple> sink)
Parse an input stream and send the triples to the sink
|
Modifier and Type | Class and Description |
---|---|
class |
PrintingSink |
class |
SinkQuadsToDataset
Send quads to a dataset.
|
class |
SinkTriplesToGraph
Send triples to a graph.
|
Modifier and Type | Method and Description |
---|---|
static LangRDFXML |
LangRDFXML.create(InputStream in,
String xmlBase,
String filename,
ErrorHandler errorHandler,
Sink<Triple> sink) |
static LangRDFXML |
LangRDFXML.create(Reader reader,
String xmlBase,
String filename,
ErrorHandler errorHandler,
Sink<Triple> sink)
Deprecated.
|
static LangRDFXML |
LangRDFXML.create(String xmlBase,
String filename,
ErrorHandler errorHandler,
Sink<Triple> sink) |
Constructor and Description |
---|
LangNQuads(Tokenizer tokens,
ParserProfile profile,
Sink<Quad> sink) |
LangNTriples(Tokenizer tokens,
ParserProfile profile,
Sink<Triple> sink) |
LangRDFJSON(Tokenizer tokenizer,
ParserProfile profile,
Sink<Triple> sink) |
LangTriG(Tokenizer tokens,
ParserProfile profile,
Sink<Quad> sink) |
LangTurtle(Tokenizer tokens,
ParserProfile profile,
Sink<Triple> sink) |
Modifier and Type | Class and Description |
---|---|
class |
SinkEntityOutput |
class |
SinkQuadBracedOutput
A class that print quads, SPARQL style (maybe good for Trig too?)
|
class |
SinkQuadOutput
A class that print quads, N-Quads style
|
class |
SinkTripleOutput
A class that print triples, N-triples style
|
Modifier and Type | Interface and Description |
---|---|
interface |
PipelineStage<T> |
Modifier and Type | Class and Description |
---|---|
class |
SinkQuadNodeTransform
Apply a node transform to each node in a quad
|
class |
SinkTripleNodeTransform
Apply a node transform to each node in a triple
|
Modifier and Type | Method and Description |
---|---|
void |
PipelineStage.addOutput(Sink<T> sink) |
Constructor and Description |
---|
SinkQuadNodeTransform(Sink<Quad> sink,
NodeTransform nodeTransform)
Apply the nodeTransform to each of G, S, P and O
|
SinkQuadNodeTransform(Sink<Quad> sink,
NodeTransform graphNodeTransform,
NodeTransform subjTransform,
NodeTransform predTransform,
NodeTransform objTransform)
Apply the respective nodeTransform to the slot in the triple
|
SinkTripleNodeTransform(Sink<Triple> sink,
NodeTransform nodeTransform)
Apply the nodeTransform to each of S, P and O
|
SinkTripleNodeTransform(Sink<Triple> sink,
NodeTransform subjTransform,
NodeTransform predTransform,
NodeTransform objTransform)
Apply the respective nodeTransform to the slot in the triple
|
Modifier and Type | Method and Description |
---|---|
static Sink<Quad> |
InfFactory.infQuads(Sink<Quad> sink,
InferenceSetupRDFS setup) |
static Sink<Quad> |
InfFactory.infQuads(Sink<Quad> sink,
Model vocab) |
static Sink<Triple> |
InfFactory.infTriples(Sink<Triple> sink,
InferenceSetupRDFS setup) |
static Sink<Triple> |
InfFactory.infTriples(Sink<Triple> sink,
Model vocab) |
Modifier and Type | Method and Description |
---|---|
static Sink<Quad> |
InfFactory.infQuads(Sink<Quad> sink,
InferenceSetupRDFS setup) |
static Sink<Quad> |
InfFactory.infQuads(Sink<Quad> sink,
Model vocab) |
static Sink<Triple> |
InfFactory.infTriples(Sink<Triple> sink,
InferenceSetupRDFS setup) |
static Sink<Triple> |
InfFactory.infTriples(Sink<Triple> sink,
Model vocab) |
Modifier and Type | Class and Description |
---|---|
class |
SinkNormalize
Apply a node transform to each node in a triple
|
Constructor and Description |
---|
SinkNormalize(Sink<Triple> sink)
Apply the nodeTransform to each of S, P and O
|
Modifier and Type | Class and Description |
---|---|
class |
SinkExtendTriplesToQuads
Take a stream of triples and send down a Sink<Quad>
The quad will have
Quad.tripleInQuad in the G field or a specified node.. |
Constructor and Description |
---|
SinkExtendTriplesToQuads(Node gn,
Sink<Quad> quadSink) |
SinkExtendTriplesToQuads(Sink<Quad> quadSink) |
Licenced under the Apache License, Version 2.0