public class DefaultRdfStream extends WrappingStream<com.hp.hpl.jena.graph.Triple> implements RdfStream
Stream.Builder<T>
Modifier and Type | Field and Description |
---|---|
protected com.hp.hpl.jena.graph.Node |
node |
stream
Constructor and Description |
---|
DefaultRdfStream(com.hp.hpl.jena.graph.Node node)
Create an RdfStream
|
DefaultRdfStream(com.hp.hpl.jena.graph.Node node,
Stream<com.hp.hpl.jena.graph.Triple> stream)
Create an RdfStream
|
Modifier and Type | Method and Description |
---|---|
protected void |
concat(Stream<com.hp.hpl.jena.graph.Triple> stream)
Concatenate a Triple stream to the existing stream
|
RdfStream |
distinct() |
RdfStream |
filter(Predicate<? super com.hp.hpl.jena.graph.Triple> predicate) |
static RdfStream |
fromModel(com.hp.hpl.jena.graph.Node node,
com.hp.hpl.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 com.hp.hpl.jena.graph.Triple> action) |
RdfStream |
sequential() |
RdfStream |
skip(long n) |
RdfStream |
sorted() |
RdfStream |
sorted(Comparator<? super com.hp.hpl.jena.graph.Triple> comparator) |
com.hp.hpl.jena.graph.Node |
topic() |
RdfStream |
unordered() |
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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
allMatch, anyMatch, builder, collect, collect, concat, count, empty, findAny, findFirst, flatMap, flatMapToDouble, flatMapToInt, flatMapToLong, forEach, forEachOrdered, generate, iterate, map, mapToDouble, mapToInt, mapToLong, max, min, noneMatch, of, of, reduce, reduce, reduce, toArray, toArray
close, isParallel, iterator, spliterator
protected final com.hp.hpl.jena.graph.Node node
public DefaultRdfStream(com.hp.hpl.jena.graph.Node node)
node
- the topic of the streampublic DefaultRdfStream(com.hp.hpl.jena.graph.Node node, Stream<com.hp.hpl.jena.graph.Triple> stream)
node
- the topic of the streamstream
- the incoming streampublic static RdfStream fromModel(com.hp.hpl.jena.graph.Node node, com.hp.hpl.jena.rdf.model.Model model)
node
- The subject nodemodel
- An input Modelprotected void concat(Stream<com.hp.hpl.jena.graph.Triple> stream)
stream
- additional triplespublic com.hp.hpl.jena.graph.Node topic()
public RdfStream sorted(Comparator<? super com.hp.hpl.jena.graph.Triple> comparator)
public RdfStream onClose(Runnable closeHandler)
onClose
in interface BaseStream<com.hp.hpl.jena.graph.Triple,Stream<com.hp.hpl.jena.graph.Triple>>
public RdfStream parallel()
parallel
in interface BaseStream<com.hp.hpl.jena.graph.Triple,Stream<com.hp.hpl.jena.graph.Triple>>
public RdfStream sequential()
sequential
in interface BaseStream<com.hp.hpl.jena.graph.Triple,Stream<com.hp.hpl.jena.graph.Triple>>
public RdfStream unordered()
unordered
in interface BaseStream<com.hp.hpl.jena.graph.Triple,Stream<com.hp.hpl.jena.graph.Triple>>
Copyright © 2013–2016 DuraSpace, Inc.. All rights reserved.