Modifier and Type | Class and Description |
---|---|
class |
BindingOutputStream
Parser for the RDF Tuples language
|
Modifier and Type | Interface and Description |
---|---|
interface |
UpdateSink
An UpdateSink is an object usually created by a container (such as a storage engine
or an
UpdateRequest ) that can process or store a single SPARQL Update
request which consists of one or more SPARQL Update operations. |
Modifier and Type | Class and Description |
---|---|
class |
UpdateRequestSink |
class |
UpdateVisitorSink |
class |
UsingUpdateSink
Adds using clauses from the UsingList to UpdateWithUsing operations; will throw an UpdateException if the modify operation already contains a using clause.
|
Modifier and Type | Method and Description |
---|---|
Sink<Quad> |
UpdateEngineWorker.createDeleteDataSink() |
Sink<Quad> |
UpdateEngineWorker.createInsertDataSink() |
Modifier and Type | Class and Description |
---|---|
class |
UpdateDataWriter |
Modifier and Type | Method and Description |
---|---|
Sink<Quad> |
UpdateVisitor.createDeleteDataSink() |
Sink<Quad> |
UpdateVisitor.createInsertDataSink() |
Constructor and Description |
---|
QuadAccSink(Sink<Quad> sink) |
QuadDataAccSink(Sink<Quad> sink) |
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 |
SinkToCollection<T>
Send items to a collection
|
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 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.
|
Modifier and Type | Class and Description |
---|---|
class |
SinkQuadsToDataset
Send quads to a dataset.
|
class |
SinkTriplesToGraph
Send triples to a graph.
|
Modifier and Type | Class and Description |
---|---|
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 | Method and Description |
---|---|
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.
|
Modifier and Type | Class and Description |
---|---|
class |
SinkEntityOutput |
Modifier and Type | Method and Description |
---|---|
static void |
RiotReader.parseQuads(InputStream in,
Lang lang,
String baseIRI,
Sink<Quad> sink)
Deprecated.
Parse an InputStream, sending quads to a sink.
|
static void |
RiotReader.parseQuads(String filename,
Lang lang,
String baseIRI,
Sink<Quad> sink)
Deprecated.
Parse a file, sending quads to a sink.
|
static void |
RiotReader.parseQuads(String filename,
Sink<Quad> sink)
Deprecated.
Parse a file, sending quads to a sink.
|
static void |
RiotReader.parseTriples(InputStream in,
Lang lang,
String baseIRI,
Sink<Triple> sink)
Deprecated.
Parse an InputStream, sending triples to a sink.
|
static void |
RiotReader.parseTriples(String filename,
Lang lang,
String baseIRI,
Sink<Triple> sink)
Deprecated.
Parse a file, sending triples to a sink.
|
static void |
RiotReader.parseTriples(String filename,
Sink<Triple> sink)
Deprecated.
Parse a file, sending triples to a sink.
|
Licenced under the Apache License, Version 2.0