Package com.snowflake.connectors.common.task

Class DefaultTaskRepository

java.lang.Object

com.snowflake.connectors.common.task.DefaultTaskRepository

All Implemented Interfaces:

TaskRepository

public class DefaultTaskRepository
extends Object
implements TaskRepository

Default implementation of TaskRepository.

Constructor Summary

Constructors

Constructor	Description
DefaultTaskRepository(Session session)	Creates a new DefaultTaskRepository.

Method Summary

Modifier and Type	Method	Description
TaskRef	create(TaskDefinition definition, boolean replace, boolean ifNotExists)	Creates or replaces task with given definition in the database.
TaskRef	fetch(ObjectName objectName)	Provides database reference to task without executing database call.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultTaskRepository

public DefaultTaskRepository(Session session)

Creates a new DefaultTaskRepository.

Parameters:

session - Snowpark session object

Method Detail

create

public TaskRef create(TaskDefinition definition,
                      boolean replace,
                      boolean ifNotExists)

Description copied from interface: TaskRepository

Creates or replaces task with given definition in the database.

Specified by:

create in interface TaskRepository

Parameters:

definition - set of properties defining task to be created

replace - flag to replace task if it existed

ifNotExists - flag to create task only when it did not exist

Returns:

Reference to the created task.

fetch

public TaskRef fetch(ObjectName objectName)

Description copied from interface: TaskRepository

Provides database reference to task without executing database call.

Specified by:

fetch in interface TaskRepository

Parameters:

objectName - name of the referenced task

Returns:

Reference task object.