Package com.snowflake.connectors.taskreactor.worker.simpletask

Class SimpleTaskWorker<T>

java.lang.Object

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

com.snowflake.connectors.taskreactor.worker.simpletask.SimpleTaskWorker<T>

public class SimpleTaskWorker<T>
extends Worker<T>

A worker executing a SimpleTask.

Method Summary

Modifier and Type	Method	Description
static <T> SimpleTaskWorker<T>	from(Session session, SimpleTask<T> task, WorkerId workerId, Identifier instanceSchema)	Creates a new SimpleTaskWorker.
protected T	performWork(WorkItem workItem)

Methods inherited from class com.snowflake.connectors.taskreactor.worker.Worker

run, shouldCancel

Methods inherited from class java.lang.Object

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

Method Detail

from

public static <T> SimpleTaskWorker<T> from(Session session,
                                           SimpleTask<T> task,
                                           WorkerId workerId,
                                           Identifier instanceSchema)

Creates a new SimpleTaskWorker.

Type Parameters:

T - task response type

Parameters:

session - Snowpark session object

task - task

workerId - worker id

instanceSchema - Task Reactor instance name

Returns:

a new simple task worker

performWork

protected T performWork(WorkItem workItem)

Specified by:

performWork in class Worker<T>

Parameters:

workItem - work item provided by the dispatcher

Returns:

custom object defined by the user.