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

Class TrackedPipedTriplesStream

java.lang.Object

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

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

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

All Implemented Interfaces:

StreamRDF

public class TrackedPipedTriplesStream
extends TrackedPipedRDFStream<org.apache.jena.graph.Triple>

A tracked piped triples stream

Constructor Summary

Constructors

Constructor and Description
TrackedPipedTriplesStream(PipedRDFIterator<org.apache.jena.graph.Triple> sink, TrackableInputStream input) Creates a tracked triples 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

TrackedPipedTriplesStream

public TrackedPipedTriplesStream(PipedRDFIterator<org.apache.jena.graph.Triple> sink,
                                 TrackableInputStream input)

Creates a tracked triples 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)