Package org.fcrepo.kernel.api.rdf
Class DefaultRdfStream
- java.lang.Object
-
- org.fcrepo.kernel.api.utils.WrappingStream<org.apache.jena.graph.Triple>
-
- org.fcrepo.kernel.api.rdf.DefaultRdfStream
-
- All Implemented Interfaces:
AutoCloseable
,BaseStream<org.apache.jena.graph.Triple,Stream<org.apache.jena.graph.Triple>>
,Stream<org.apache.jena.graph.Triple>
,RdfStream
public class DefaultRdfStream extends WrappingStream<org.apache.jena.graph.Triple> implements RdfStream
Implementation of a context-bearing RDF stream- Since:
- Dec 6, 2015
- Author:
- acoburn
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface java.util.stream.Stream
Stream.Builder<T extends Object>
-
-
Field Summary
-
Fields inherited from class org.fcrepo.kernel.api.utils.WrappingStream
stream
-
-
Constructor Summary
Constructors Constructor Description DefaultRdfStream(org.apache.jena.graph.Node node)
Create an RdfStreamDefaultRdfStream(org.apache.jena.graph.Node node, Stream<org.apache.jena.graph.Triple> stream)
Create an RdfStream
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
concat(Stream<org.apache.jena.graph.Triple> stream)
Concatenate a Triple stream to the existing streamRdfStream
distinct()
RdfStream
filter(Predicate<? super org.apache.jena.graph.Triple> predicate)
static RdfStream
fromModel(org.apache.jena.graph.Node node, org.apache.jena.rdf.model.Model model)
Create an RdfStream from an existing Model.RdfStream
limit(long maxSize)
RdfStream
onClose(Runnable closeHandler)
RdfStream
parallel()
RdfStream
peek(Consumer<? super org.apache.jena.graph.Triple> action)
RdfStream
sequential()
RdfStream
skip(long n)
RdfStream
sorted()
RdfStream
sorted(Comparator<? super org.apache.jena.graph.Triple> comparator)
org.apache.jena.graph.Node
topic()
RdfStream
unordered()
-
Methods inherited from class org.fcrepo.kernel.api.utils.WrappingStream
allMatch, anyMatch, close, collect, collect, count, findAny, findFirst, flatMap, flatMapToDouble, flatMapToInt, flatMapToLong, forEach, forEachOrdered, isParallel, iterator, map, mapToDouble, mapToInt, mapToLong, max, min, noneMatch, reduce, reduce, reduce, spliterator, toArray, toArray
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface java.util.stream.BaseStream
close, isParallel, iterator, spliterator
-
Methods inherited from interface java.util.stream.Stream
allMatch, anyMatch, collect, collect, count, dropWhile, findAny, findFirst, flatMap, flatMapToDouble, flatMapToInt, flatMapToLong, forEach, forEachOrdered, map, mapToDouble, mapToInt, mapToLong, max, min, noneMatch, reduce, reduce, reduce, takeWhile, toArray, toArray
-
-
-
-
Constructor Detail
-
DefaultRdfStream
public DefaultRdfStream(org.apache.jena.graph.Node node)
Create an RdfStream- Parameters:
node
- the topic of the stream
-
DefaultRdfStream
public DefaultRdfStream(org.apache.jena.graph.Node node, Stream<org.apache.jena.graph.Triple> stream)
Create an RdfStream- Parameters:
node
- the topic of the streamstream
- the incoming stream
-
-
Method Detail
-
fromModel
public static RdfStream fromModel(org.apache.jena.graph.Node node, org.apache.jena.rdf.model.Model model)
Create an RdfStream from an existing Model.- Parameters:
node
- The subject nodemodel
- An input Model- Returns:
- a new RdfStream object
-
concat
protected void concat(Stream<org.apache.jena.graph.Triple> stream)
Concatenate a Triple stream to the existing stream- Parameters:
stream
- additional triples
-
topic
public org.apache.jena.graph.Node topic()
-
sorted
public RdfStream sorted(Comparator<? super org.apache.jena.graph.Triple> comparator)
-
onClose
public RdfStream onClose(Runnable closeHandler)
- Specified by:
onClose
in interfaceBaseStream<org.apache.jena.graph.Triple,Stream<org.apache.jena.graph.Triple>>
-
parallel
public RdfStream parallel()
- Specified by:
parallel
in interfaceBaseStream<org.apache.jena.graph.Triple,Stream<org.apache.jena.graph.Triple>>
-
sequential
public RdfStream sequential()
- Specified by:
sequential
in interfaceBaseStream<org.apache.jena.graph.Triple,Stream<org.apache.jena.graph.Triple>>
-
unordered
public RdfStream unordered()
- Specified by:
unordered
in interfaceBaseStream<org.apache.jena.graph.Triple,Stream<org.apache.jena.graph.Triple>>
-
-