org.dice_research.squirrel.sink.impl.file

Class FileBasedSink.StreamStatus

java.lang.Object

org.dice_research.squirrel.sink.impl.file.FileBasedSink.StreamStatus

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

FileBasedSink

protected static class FileBasedSink.StreamStatus
extends Object
implements Closeable

Field Summary

Fields

Modifier and Type	Field and Description
protected OutputStream	dataOutputStream
protected File	outputDirectory
protected org.apache.jena.riot.Lang	outputLang
int	tripleCount
protected OutputStream	tripleOutputStream
protected org.apache.jena.riot.system.StreamRDF	tripleStream
protected org.dice_research.squirrel.data.uri.CrawleableUri	uri
protected String	uriString
protected boolean	useCompression

Constructor Summary

Constructors

Constructor and Description
StreamStatus(org.dice_research.squirrel.data.uri.CrawleableUri uri, File outputDirectory, org.apache.jena.riot.Lang outputLang, boolean useCompression)

Method Summary

Modifier and Type	Method and Description
void	close()
protected OutputStream	createStream(String postFix, boolean isRdfFile)
void	flush()
OutputStream	getDataOutputStream()
org.apache.jena.riot.system.StreamRDF	getTripleOutputStream()
void	increaseTripleCount()

Methods inherited from class java.lang.Object

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

Field Detail

tripleCount

public int tripleCount

uri

protected org.dice_research.squirrel.data.uri.CrawleableUri uri

uriString

protected String uriString

outputDirectory

protected File outputDirectory

useCompression

protected boolean useCompression

outputLang

protected org.apache.jena.riot.Lang outputLang

tripleStream

protected org.apache.jena.riot.system.StreamRDF tripleStream

tripleOutputStream

protected OutputStream tripleOutputStream

dataOutputStream

protected OutputStream dataOutputStream

Constructor Detail

StreamStatus

public StreamStatus(org.dice_research.squirrel.data.uri.CrawleableUri uri,
                    File outputDirectory,
                    org.apache.jena.riot.Lang outputLang,
                    boolean useCompression)

Method Detail

getTripleOutputStream

public org.apache.jena.riot.system.StreamRDF getTripleOutputStream()
                                                            throws IOException

Throws:

IOException

getDataOutputStream

public OutputStream getDataOutputStream()
                                 throws IOException

Throws:

IOException

flush

public void flush()
           throws IOException

Throws:

IOException

createStream

protected OutputStream createStream(String postFix,
                                    boolean isRdfFile)
                             throws IOException

Throws:

IOException

increaseTripleCount

public void increaseTripleCount()

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException