Package com.snowflake.connectors.taskreactor.worker.ingestion

Class IngestionWorker<T>

java.lang.Object

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

com.snowflake.connectors.taskreactor.worker.ingestion.IngestionWorker<T>

public class IngestionWorker<T>
extends Worker<T>

A worker executing an Ingestion.

Method Summary

Modifier and Type	Method	Description
static <T> IngestionWorker<T>	from(Session session, Ingestion<T> ingestion, WorkerId workerId, Identifier instanceSchema)	Creates a new IngestionWorker.
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> IngestionWorker<T> from(Session session,
                                          Ingestion<T> ingestion,
                                          WorkerId workerId,
                                          Identifier instanceSchema)

Creates a new IngestionWorker.

Type Parameters:

T - ingestion state type

Parameters:

session - Snowpark session object

ingestion - ingestion

workerId - worker id

instanceSchema - Task Reactor instance name

Returns:

a new ingestion 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.