Package com.snowflake.connectors.taskreactor.worker

Class InMemoryWorkerTaskManagerProvider

java.lang.Object

com.snowflake.connectors.taskreactor.worker.InMemoryWorkerTaskManagerProvider

public class InMemoryWorkerTaskManagerProvider
extends Object

In memory provider of WorkerTaskManager instances.

Constructor Summary

Constructors

Constructor	Description
InMemoryWorkerTaskManagerProvider()

Method Summary

Modifier and Type	Method	Description
static com.snowflake.connectors.taskreactor.worker.WorkerTaskManager	getInstance(com.snowflake.connectors.common.object.Identifier instanceSchema, com.snowflake.connectors.common.task.TaskRepository taskRepository)	Creates a new in memory instance of WorkerTaskManager.

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryWorkerTaskManagerProvider

public InMemoryWorkerTaskManagerProvider()

Method Detail

getInstance

public static com.snowflake.connectors.taskreactor.worker.WorkerTaskManager getInstance(com.snowflake.connectors.common.object.Identifier instanceSchema,
                                                                                        com.snowflake.connectors.common.task.TaskRepository taskRepository)

Creates a new in memory instance of WorkerTaskManager.

Parameters:

instanceSchema - Task Reactor instance name

taskRepository - task repository

Returns:

a new worker task manager instance