Package com.snowflake.connectors.taskreactor.dispatcher

Class InMemoryDispatcherTaskProvider

java.lang.Object

com.snowflake.connectors.taskreactor.dispatcher.InMemoryDispatcherTaskProvider

public class InMemoryDispatcherTaskProvider
extends Object

In memory provider of DispatcherTaskManager instances.

Constructor Summary

Constructors

Constructor	Description
InMemoryDispatcherTaskProvider()

Method Summary

Modifier and Type	Method	Description
static com.snowflake.connectors.taskreactor.dispatcher.DispatcherTaskManager	getInstance(com.snowflake.connectors.common.object.Identifier instanceSchema, com.snowflake.connectors.common.task.TaskRepository taskRepository)	Creates a new DispatcherTaskManager.

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryDispatcherTaskProvider

public InMemoryDispatcherTaskProvider()

Method Detail

getInstance

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

Creates a new DispatcherTaskManager.

Parameters:

instanceSchema - Task Reactor instance name

taskRepository - task repository

Returns:

a new dispatcher task manager instance