Module org.apache.jena.arq

Package org.apache.jena.riot.thrift

Class StreamRDF2Thrift

java.lang.Object

org.apache.jena.riot.thrift.StreamRDF2Thrift

All Implemented Interfaces:

AutoCloseable, StreamRDF

public class StreamRDF2Thrift
extends Object
implements StreamRDF, AutoCloseable

Encode StreamRDF in Thrift.

See Also:

• (for each RDF_StreamRow) for the reverse process.

Constructor Summary

Constructors

Constructor	Description
StreamRDF2Thrift(OutputStream out)
StreamRDF2Thrift(OutputStream out, boolean encodeValues)
StreamRDF2Thrift(org.apache.thrift.protocol.TProtocol out, boolean encodeValues)

Method Summary

Modifier and Type	Method	Description
void	base(String base)	Base declaration seen
void	close()
void	finish()	Finish processing
void	flush()	Flush the stream
void	prefix(String prefix, String iri)	Prefix declaration seen
void	quad(Quad quad)	Quad emitted
void	start()	Start processing
void	triple(org.apache.jena.graph.Triple triple)	Triple emitted
void	version(String version)	Version declaration seen

Methods inherited from class java.lang.Object

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

Constructor Details

StreamRDF2Thrift

public StreamRDF2Thrift(OutputStream out)

StreamRDF2Thrift

public StreamRDF2Thrift(OutputStream out,
 boolean encodeValues)

StreamRDF2Thrift

public StreamRDF2Thrift(org.apache.thrift.protocol.TProtocol out,
 boolean encodeValues)

Method Details

start

public void start()

Description copied from interface: StreamRDF

Start processing

Specified by:

start in interface StreamRDF

triple

public void triple(org.apache.jena.graph.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

base

public void base(String base)

Description copied from interface: StreamRDF

Base declaration seen

Specified by:

base in interface StreamRDF

prefix

public void prefix(String prefix,
 String iri)

Description copied from interface: StreamRDF

Prefix declaration seen

Specified by:

prefix in interface StreamRDF

version

public void version(String version)

Description copied from interface: StreamRDF

Version declaration seen

Specified by:

version in interface StreamRDF

close

public void close()

Specified by:

close in interface AutoCloseable

flush

public void flush()

Description copied from interface: StreamRDF

Flush the stream

Specified by:

flush in interface StreamRDF

finish

public void finish()

Description copied from interface: StreamRDF

Finish processing

Specified by:

finish in interface StreamRDF