Package com.snowflake.connectors.taskreactor.worker

Class Worker<T>

java.lang.Object

com.snowflake.connectors.taskreactor.worker.Worker<T>

Type Parameters:

T - param defining type of response during running worker jobs.

Direct Known Subclasses:

IngestionWorker, SimpleTaskWorker

public abstract class Worker<T>
extends Object

A set of methods performed by the Worker implementation.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Worker(WorkerId workerId, Identifier instanceName, WorkerStatusRepository workerStatusRepository, ObjectName workerTask, WorkerQueue workerQueue, TaskRepository taskRepository)

Method Summary

Modifier and Type	Method	Description
protected abstract T	performWork(WorkItem workItem)
T	run()	Generic body of the worker execution job.
protected boolean	shouldCancel()

Methods inherited from class java.lang.Object

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

Constructor Detail

Worker

protected Worker(WorkerId workerId,
                 Identifier instanceName,
                 WorkerStatusRepository workerStatusRepository,
                 ObjectName workerTask,
                 WorkerQueue workerQueue,
                 TaskRepository taskRepository)

Method Detail

run

public T run()
      throws WorkerException,
             WorkerJobCancelledException

Generic body of the worker execution job.

Returns:

result of the performWork(com.snowflake.connectors.taskreactor.worker.queue.WorkItem) method implementation.

Throws:

WorkerException - when generic worker fail occurs.

WorkerJobCancelledException - if running task is performed by worker scheduled for cancellation.

performWork

protected abstract T performWork(WorkItem workItem)

Parameters:

workItem - work item provided by the dispatcher

Returns:

custom object defined by the user.

shouldCancel

protected boolean shouldCancel()