Package com.snowflake.connectors.taskreactor

Class InMemoryTaskManagement

java.lang.Object

com.snowflake.connectors.taskreactor.InMemoryTaskManagement

All Implemented Interfaces:

com.snowflake.connectors.common.task.TaskLister, com.snowflake.connectors.common.task.TaskRepository, com.snowflake.connectors.taskreactor.TaskReactorExistenceVerifier

public class InMemoryTaskManagement
extends Object
implements com.snowflake.connectors.common.task.TaskRepository, com.snowflake.connectors.common.task.TaskLister, com.snowflake.connectors.taskreactor.TaskReactorExistenceVerifier

In memory implementation of TaskRepository and TaskLister.

Constructor Summary

Constructors

Constructor	Description
InMemoryTaskManagement()

Method Summary

Modifier and Type	Method	Description
void	clear()	Clears the task storage of this object.
com.snowflake.connectors.common.task.TaskRef	create(com.snowflake.connectors.common.task.TaskDefinition definition, boolean replace, boolean ifNotExists)
com.snowflake.connectors.common.task.TaskRef	fetch(com.snowflake.connectors.common.object.ObjectName objectName)
Map<com.snowflake.connectors.common.object.ObjectName,com.snowflake.connectors.common.task.TaskProperties>	fetchAll()	Returns all tasks stored in this object.
boolean	isTaskReactorConfigured()
Optional<com.snowflake.connectors.common.task.TaskProperties>	showTask(com.snowflake.connectors.common.object.ObjectName taskName)
List<com.snowflake.connectors.common.task.TaskProperties>	showTasks(String schema)
List<com.snowflake.connectors.common.task.TaskProperties>	showTasks(String schema, String like)

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryTaskManagement

public InMemoryTaskManagement()

Method Detail

create

public com.snowflake.connectors.common.task.TaskRef create(com.snowflake.connectors.common.task.TaskDefinition definition,
                                                           boolean replace,
                                                           boolean ifNotExists)

Specified by:

create in interface com.snowflake.connectors.common.task.TaskRepository

fetch

public com.snowflake.connectors.common.task.TaskRef fetch(com.snowflake.connectors.common.object.ObjectName objectName)

Specified by:

fetch in interface com.snowflake.connectors.common.task.TaskRepository

clear

public void clear()

Clears the task storage of this object.

showTask

public Optional<com.snowflake.connectors.common.task.TaskProperties> showTask(com.snowflake.connectors.common.object.ObjectName taskName)

Specified by:

showTask in interface com.snowflake.connectors.common.task.TaskLister

showTasks

public List<com.snowflake.connectors.common.task.TaskProperties> showTasks(String schema)

Specified by:

showTasks in interface com.snowflake.connectors.common.task.TaskLister

showTasks

public List<com.snowflake.connectors.common.task.TaskProperties> showTasks(String schema,
                                                                           String like)

Specified by:

showTasks in interface com.snowflake.connectors.common.task.TaskLister

fetchAll

public Map<com.snowflake.connectors.common.object.ObjectName,com.snowflake.connectors.common.task.TaskProperties> fetchAll()

Returns all tasks stored in this object.

Returns:

all tasks stored in this object

isTaskReactorConfigured

public boolean isTaskReactorConfigured()

Specified by:

isTaskReactorConfigured in interface com.snowflake.connectors.taskreactor.TaskReactorExistenceVerifier