org.eclipse.smila.importing.worker

Class DeltaCheckerWorker

java.lang.Object

org.eclipse.smila.importing.worker.WorkerUsingDeltaService

org.eclipse.smila.importing.worker.DeltaCheckerWorker

All Implemented Interfaces:

Worker

public class DeltaCheckerWorker
extends WorkerUsingDeltaService

Worker implementation that performs delta checks.

Author:

stuc07

Constructor Summary

Constructors

Constructor and Description
DeltaCheckerWorker()

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.

Methods inherited from class org.eclipse.smila.importing.worker.WorkerUsingDeltaService

checkDeltaStateTimed, deleteDeltaEntryTimed, getCompoundId, getDeltaImportStrategy, getDeltaImportStrategy, getJobRunId, getRequiredParameter, getUnvisitedEntriesTimed, isCompound, markAsUpdatedTimed, markCompoundElementsVisitedTimed, setDeltaService, unsetDeltaService

Methods inherited from class java.lang.Object

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

Constructor Detail

DeltaCheckerWorker

public DeltaCheckerWorker()

Method Detail

getName

public java.lang.String getName()

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!

Parameters:

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

Throws:

java.lang.Exception