Class WorkerTaskManager
- java.lang.Object
-
- com.snowflake.connectors.taskreactor.worker.WorkerTaskManager
-
public class WorkerTaskManager extends Object
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
alterWarehouse(WorkerId workerId, String warehouseName)
Alters a worker task warehousevoid
createWorkerTask(WorkerId workerId)
Creates a new worker task.void
dropWorkerTask(WorkerId workerId)
Drops a worker task.static WorkerTaskManager
from(Session session, Identifier instanceSchema)
Creates a newWorkerTaskManager
.void
resumeWorkerTask(WorkerId workerId)
Resumes a worker task if it exists.void
suspendWorkerTaskIfExists(WorkerId workerId)
Suspends a worker task if it exists.
-
-
-
Method Detail
-
from
public static WorkerTaskManager from(Session session, Identifier instanceSchema)
Creates a newWorkerTaskManager
.- Parameters:
session
- Snowpark session objectinstanceSchema
- task reactor instance schema name- Returns:
- new manager instance
-
createWorkerTask
public void createWorkerTask(WorkerId workerId)
Creates a new worker task.- Parameters:
workerId
- worker id
-
dropWorkerTask
public void dropWorkerTask(WorkerId workerId)
Drops a worker task.Throws
SnowflakeSQLException
if the queue does not exist.- Parameters:
workerId
- worker id
-
alterWarehouse
public void alterWarehouse(WorkerId workerId, String warehouseName)
Alters a worker task warehouseThrows
SnowflakeSQLException
if the queue does not exist.- Parameters:
workerId
- worker idwarehouseName
- new warehouse name
-
suspendWorkerTaskIfExists
public void suspendWorkerTaskIfExists(WorkerId workerId)
Suspends a worker task if it exists.- Parameters:
workerId
- worker id
-
resumeWorkerTask
public void resumeWorkerTask(WorkerId workerId)
Resumes a worker task if it exists.- Parameters:
workerId
- worker id
-
-