org.apache.jena.hadoop.rdf.io.input.util

Class TrackedPipedQuadsStream

java.lang.Object

org.apache.jena.riot.lang.PipedRDFStream<T>

org.apache.jena.hadoop.rdf.io.input.util.TrackedPipedRDFStream<Quad>

org.apache.jena.hadoop.rdf.io.input.util.TrackedPipedQuadsStream

All Implemented Interfaces:

StreamRDF

public class TrackedPipedQuadsStream
extends TrackedPipedRDFStream<Quad>

A tracked piped quads stream

Constructor Summary

Constructors

Constructor and Description
TrackedPipedQuadsStream(PipedRDFIterator<Quad> sink, TrackableInputStream input) Creates a new stream

Method Summary

Modifier and Type	Method and Description
void	quad(Quad quad)
void	triple(org.apache.jena.graph.Triple triple)

Methods inherited from class org.apache.jena.hadoop.rdf.io.input.util.TrackedPipedRDFStream

getPosition

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

Constructor Detail

TrackedPipedQuadsStream

public TrackedPipedQuadsStream(PipedRDFIterator<Quad> sink,
                               TrackableInputStream input)

Creates a new stream

Parameters:

sink - Sink

input - Input stream

Method Detail

triple

public void triple(org.apache.jena.graph.Triple triple)

quad

public void quad(Quad quad)