Package com.snowflake.connectors.common.task

Class InMemoryTaskRef

java.lang.Object

com.snowflake.connectors.common.task.InMemoryTaskRef

All Implemented Interfaces:

com.snowflake.connectors.common.task.TaskRef

public class InMemoryTaskRef
extends Object
implements com.snowflake.connectors.common.task.TaskRef

In memory implementation of TaskRef.

Constructor Summary

Constructors

Constructor	Description
InMemoryTaskRef(com.snowflake.connectors.common.object.ObjectName taskName, Map<com.snowflake.connectors.common.object.ObjectName,com.snowflake.connectors.common.task.TaskProperties> store)	Creates a new InMemoryTaskRef.

Method Summary

Modifier and Type	Method	Description
void	alterSchedule(String schedule)
void	alterScheduleIfExists(String schedule)
void	alterWarehouse(String warehouse)
void	alterWarehouseIfExists(String warehouse)
boolean	checkIfExists()
void	drop()
void	dropIfExists()
void	execute()
com.snowflake.connectors.common.task.TaskProperties	fetch()
void	grantMonitorPrivilegeToRole(String role)
com.snowflake.connectors.common.object.ObjectName	name()
void	resume()
void	resumeIfExists()
void	suspend()
void	suspendIfExists()

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryTaskRef

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

Creates a new InMemoryTaskRef.

Parameters:

taskName - name of the task object

store - map used for task storage

Method Detail

name

public com.snowflake.connectors.common.object.ObjectName name()

Specified by:

name in interface com.snowflake.connectors.common.task.TaskRef

execute

public void execute()

Specified by:

execute in interface com.snowflake.connectors.common.task.TaskRef

checkIfExists

public boolean checkIfExists()

Specified by:

checkIfExists in interface com.snowflake.connectors.common.task.TaskRef

resume

public void resume()

Specified by:

resume in interface com.snowflake.connectors.common.task.TaskRef

resumeIfExists

public void resumeIfExists()

Specified by:

resumeIfExists in interface com.snowflake.connectors.common.task.TaskRef

suspend

public void suspend()

Specified by:

suspend in interface com.snowflake.connectors.common.task.TaskRef

suspendIfExists

public void suspendIfExists()

Specified by:

suspendIfExists in interface com.snowflake.connectors.common.task.TaskRef

drop

public void drop()

Specified by:

drop in interface com.snowflake.connectors.common.task.TaskRef

dropIfExists

public void dropIfExists()

Specified by:

dropIfExists in interface com.snowflake.connectors.common.task.TaskRef

alterSchedule

public void alterSchedule(String schedule)

Specified by:

alterSchedule in interface com.snowflake.connectors.common.task.TaskRef

alterScheduleIfExists

public void alterScheduleIfExists(String schedule)

Specified by:

alterScheduleIfExists in interface com.snowflake.connectors.common.task.TaskRef

alterWarehouse

public void alterWarehouse(String warehouse)

Specified by:

alterWarehouse in interface com.snowflake.connectors.common.task.TaskRef

alterWarehouseIfExists

public void alterWarehouseIfExists(String warehouse)

Specified by:

alterWarehouseIfExists in interface com.snowflake.connectors.common.task.TaskRef

grantMonitorPrivilegeToRole

public void grantMonitorPrivilegeToRole(String role)

Specified by:

grantMonitorPrivilegeToRole in interface com.snowflake.connectors.common.task.TaskRef

fetch

public com.snowflake.connectors.common.task.TaskProperties fetch()

Specified by:

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