org.apache.jena.riot.lang
Class PipedTriplesStream

java.lang.Object
  org.apache.jena.riot.lang.PipedRDFStream<Triple>
      org.apache.jena.riot.lang.PipedTriplesStream

All Implemented Interfaces:

StreamRDF

public class PipedTriplesStream
extends PipedRDFStream<Triple>
implements StreamRDF

Implementation of a producer class that sends Triples; must be connected to a PipedRDFIterator<Triple>.

Constructor Summary

PipedTriplesStream(PipedRDFIterator<Triple> sink)
Creates a piped triples stream connected to the specified piped RDF iterator.

Method Summary

void	quad(Quad quad) Quad emitted
void	triple(Triple triple) Triple emitted
void	tuple(Tuple<Node> tuple) Generalized emitted

Methods inherited from class org.apache.jena.riot.lang.PipedRDFStream

base, finish, prefix, start

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.jena.riot.system.StreamRDF

base, finish, prefix, start

Constructor Detail

PipedTriplesStream

public PipedTriplesStream(PipedRDFIterator<Triple> sink)

Creates a piped triples stream connected to the specified piped RDF iterator. Triples written to this stream will then be available as input from sink.

Parameters:

sink - The piped RDF iterator to connect to.

Method Detail

triple

public void triple(Triple triple)

Description copied from interface: StreamRDF

Triple emitted

Specified by:

triple in interface StreamRDF

quad

public void quad(Quad quad)

Description copied from interface: StreamRDF

Quad emitted

Specified by:

quad in interface StreamRDF

tuple

public void tuple(Tuple<Node> tuple)

Description copied from interface: StreamRDF

Generalized emitted

Specified by:

tuple in interface StreamRDF