org.dice_research.squirrel.analyzer.commons

Class SquirrelClerezzaSink

java.lang.Object

org.dice_research.squirrel.analyzer.commons.SquirrelClerezzaSink

All Implemented Interfaces:

org.semarglproject.sink.DataSink, org.semarglproject.sink.TripleSink

public class SquirrelClerezzaSink
extends Object
implements org.semarglproject.sink.TripleSink

TripleSink for Clerezza

Author:

Geraldo de Souza Junior

Field Summary

Fields

Modifier and Type	Field and Description
private Map<String,org.apache.clerezza.rdf.core.BNode>	bnodeMap
private UriCollector	collector
private org.dice_research.squirrel.data.uri.CrawleableUri	curi
static String	OUTPUT_GRAPH_PROPERTY
private org.dice_research.squirrel.sink.Sink	sink

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SquirrelClerezzaSink(org.dice_research.squirrel.data.uri.CrawleableUri curi, UriCollector collector, org.dice_research.squirrel.sink.Sink sink)

Method Summary

Modifier and Type	Method and Description
void	addNonLiteral(String subj, String pred, String obj)
void	addPlainLiteral(String subj, String pred, String content, String lang)
protected void	addTriple(String subj, String pred, String obj) Callback method for handling Clerezza triples.
void	addTypedLiteral(String subj, String pred, String content, String type)
static org.semarglproject.sink.TripleSink	connect(org.dice_research.squirrel.data.uri.CrawleableUri curi, UriCollector collector, org.dice_research.squirrel.sink.Sink sink)
private org.apache.clerezza.rdf.core.NonLiteral	convertNonLiteral(String arg)
void	endStream()
private org.apache.clerezza.rdf.core.BNode	getBNode(String bnode)
void	setBaseUri(String baseUri)
boolean	setProperty(String key, Object value)
void	startStream()

Methods inherited from class java.lang.Object

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

Field Detail

OUTPUT_GRAPH_PROPERTY

public static final String OUTPUT_GRAPH_PROPERTY

See Also:

Constant Field Values

curi

private org.dice_research.squirrel.data.uri.CrawleableUri curi

collector

private UriCollector collector

sink

private org.dice_research.squirrel.sink.Sink sink

bnodeMap

private final Map<String,org.apache.clerezza.rdf.core.BNode> bnodeMap

Constructor Detail

SquirrelClerezzaSink

protected SquirrelClerezzaSink(org.dice_research.squirrel.data.uri.CrawleableUri curi,
                               UriCollector collector,
                               org.dice_research.squirrel.sink.Sink sink)

Method Detail

connect

public static org.semarglproject.sink.TripleSink connect(org.dice_research.squirrel.data.uri.CrawleableUri curi,
                                                         UriCollector collector,
                                                         org.dice_research.squirrel.sink.Sink sink)

getBNode

private org.apache.clerezza.rdf.core.BNode getBNode(String bnode)

convertNonLiteral

private org.apache.clerezza.rdf.core.NonLiteral convertNonLiteral(String arg)

addNonLiteral

public final void addNonLiteral(String subj,
                                String pred,
                                String obj)

Specified by:

addNonLiteral in interface org.semarglproject.sink.TripleSink

addPlainLiteral

public final void addPlainLiteral(String subj,
                                  String pred,
                                  String content,
                                  String lang)

Specified by:

addPlainLiteral in interface org.semarglproject.sink.TripleSink

addTypedLiteral

public final void addTypedLiteral(String subj,
                                  String pred,
                                  String content,
                                  String type)

Specified by:

addTypedLiteral in interface org.semarglproject.sink.TripleSink

setProperty

public boolean setProperty(String key,
                           Object value)

Specified by:

setProperty in interface org.semarglproject.sink.DataSink

addTriple

protected void addTriple(String subj,
                         String pred,
                         String obj)

Callback method for handling Clerezza triples.

Parameters:

subj - triple's subject

pred - triple's predicate

obj - triple's object

startStream

public void startStream()
                 throws org.semarglproject.rdf.ParseException

Specified by:

startStream in interface org.semarglproject.sink.DataSink

Throws:

org.semarglproject.rdf.ParseException

endStream

public void endStream()
               throws org.semarglproject.rdf.ParseException

Specified by:

endStream in interface org.semarglproject.sink.DataSink

Throws:

org.semarglproject.rdf.ParseException

setBaseUri

public void setBaseUri(String baseUri)

Specified by:

setBaseUri in interface org.semarglproject.sink.DataSink