Class PipedTuplesStream

  • All Implemented Interfaces:
    StreamRDF

    public class PipedTuplesStream
    extends PipedRDFStream<org.apache.jena.atlas.lib.tuple.Tuple<Node>>
    implements StreamRDF
    Implementation of a producer class that sends @{code Tuple}; must be connected to a PipedRDFIterator<Tuple<Node>.
    • Constructor Detail

      • PipedTuplesStream

        public PipedTuplesStream​(PipedRDFIterator<org.apache.jena.atlas.lib.tuple.Tuple<Node>> sink)
        Creates a piped tuples stream connected to the specified piped RDF iterator. Tuples 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