org.eclipse.smila.ontology.pipelets
Class ASesameRecordPipelet

java.lang.Object
  org.eclipse.smila.ontology.pipelets.ASesameRecordPipelet

All Implemented Interfaces:

Pipelet

Direct Known Subclasses:

CreateRelationPipelet, CreateResourcePipelet, SesameRecordReaderPipelet, SesameRecordWriterPipelet

public abstract class ASesameRecordPipelet
extends java.lang.Object
implements Pipelet

abstract base class of Sesame-Record-IO-pipelets.

Author:

jschumacher

Field Summary

protected AnyMap	_configuration my config.
protected SesameValueHelper	_valueHelper value creation helper.
static java.lang.String	PARAM_RECORDFILTER parameter/config property to specify a record filter.
static java.lang.String	PARAM_REPOSITORY parameter/config property to specify a non-default repository to use for IO.

Constructor Summary

ASesameRecordPipelet()

Method Summary

void	configure(AnyMap configuration) set configuration of pipelet. called once after instantiation before the pipelet is actually used in a workflow.
protected URI	createUri(RepositoryConnection connection, java.lang.String uriString) resolve namespace prefixes in URI string.
protected ParameterAccessor	getParameters(Blackboard blackboard) create parameter accessor to use.
protected RepositoryConnection	getRepositoryConnection(ParameterAccessor parameters) get repository connection as described by parameters, pipelet config or default.
protected SesameOntologyManager	getSesameOntologyManager()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.smila.processing.Pipelet

process

Field Detail

PARAM_RECORDFILTER

public static final java.lang.String PARAM_RECORDFILTER

parameter/config property to specify a record filter. It is used to:

• write only attributes in filter to Sesame
• read only attributes in filter from Sesame

If no filter is specified, all attributes are written to the ontology, and all statements are used for attribute values. The referenced filters must be configured in the blackboard configuration package.

See Also:

Constant Field Values

PARAM_REPOSITORY

public static final java.lang.String PARAM_REPOSITORY

parameter/config property to specify a non-default repository to use for IO.

See Also:

Constant Field Values

_configuration

protected AnyMap _configuration

my config.

_valueHelper

protected SesameValueHelper _valueHelper

value creation helper.

Constructor Detail

ASesameRecordPipelet

public ASesameRecordPipelet()

Method Detail

configure

public void configure(AnyMap configuration)
               throws ProcessingException

set configuration of pipelet. called once after instantiation before the pipelet is actually used in a workflow.

Specified by:

configure in interface Pipelet

Parameters:

configuration - configuration of pipelet.

Throws:

ProcessingException - configuration is not applicable for pipelet (missing properties, wrong datatypes)

See Also:

#configure(org.eclipse.smila.processing.configuration.PipeletConfiguration)

getSesameOntologyManager

protected SesameOntologyManager getSesameOntologyManager()
                                                  throws ProcessingException

Returns:

active instance of SesameOntologyManager service.

Throws:

ProcessingException - no instance could be found.

getParameters

protected ParameterAccessor getParameters(Blackboard blackboard)

create parameter accessor to use.

Parameters:

blackboard - request blackboard.

Returns:

parameter accessor.

getRepositoryConnection

protected RepositoryConnection getRepositoryConnection(ParameterAccessor parameters)
                                                throws ProcessingException

get repository connection as described by parameters, pipelet config or default.

Parameters:

parameters - parameter accessor

Returns:

repository connection

Throws:

ProcessingException - error accessing SesameOntologyManager service or the named repository.

createUri

protected URI createUri(RepositoryConnection connection,
                        java.lang.String uriString)

resolve namespace prefixes in URI string.

Parameters:

connection - connection to ask for namespace resolving and use as value factory.

uriString - an uri string that possibly contains a namespace prefix.

Returns:

Sesame URI