org.eclipse.smila.importing.crawler.jdbc

Class JdbcFetcherWorker

java.lang.Object

org.eclipse.smila.importing.crawler.jdbc.JdbcFetcherWorker

All Implemented Interfaces:

Worker

public class JdbcFetcherWorker
extends java.lang.Object
implements Worker

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	NAME Name of the worker, used in worker description and workflows.
static java.lang.String	TASK_PARAM_FETCH_PARAM_ATTRIBUTES attribute containing the values to use as parameters in the fetch sql (Prepared)statement.
static java.lang.String	TASK_PARAM_FETCH_SQL sql statement used for fetching.

Constructor Summary

Constructors

Constructor and Description
JdbcFetcherWorker()

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	getName()
void	perform(TaskContext taskContext) Performs a computation on the data available in the TaskContext, such as a task for this worker, input and (if configured) output slots.
void	setJdbcAccessService(JdbcAccessService jdbcAccess) DS service reference bind method.
void	unsetJdbcAccessService(JdbcAccessService jdbcAccess) DS service reference unbind method.

Methods inherited from class java.lang.Object

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

Field Detail

NAME

public static final java.lang.String NAME

Name of the worker, used in worker description and workflows.

See Also:

Constant Field Values

TASK_PARAM_FETCH_SQL

public static final java.lang.String TASK_PARAM_FETCH_SQL

sql statement used for fetching.

See Also:

Constant Field Values

TASK_PARAM_FETCH_PARAM_ATTRIBUTES

public static final java.lang.String TASK_PARAM_FETCH_PARAM_ATTRIBUTES

attribute containing the values to use as parameters in the fetch sql (Prepared)statement.

See Also:

Constant Field Values

Constructor Detail

JdbcFetcherWorker

public JdbcFetcherWorker()

Method Detail

getName

public java.lang.String getName()

Specified by:

getName in interface Worker

Returns:

the name of the worker. The worker function will be executed for tasks tied to this worker name.

perform

public void perform(TaskContext taskContext)
             throws java.lang.Exception

Description copied from interface: Worker

Performs a computation on the data available in the TaskContext, such as a task for this worker, input and (if configured) output slots. An implementor must make sure, calls to this method must be thread-safe!

Specified by:

perform in interface Worker

Parameters:

taskContext - the TaskContext information with which this operation can be performed.

Throws:

java.lang.Exception

setJdbcAccessService

public void setJdbcAccessService(JdbcAccessService jdbcAccess)

DS service reference bind method.

unsetJdbcAccessService

public void unsetJdbcAccessService(JdbcAccessService jdbcAccess)

DS service reference unbind method.