stopTimerEngine
语法
stopTimerEngine(engine)
详情
该函数只能通过 useOrcaStreamEngine 调用，暂停由
DStream::timerEngine 提交的任务。
参数
engine 表示引擎名称。字符串标量，可以传入完整的全限定名（如 "catalog_name.orca_engine.engine_name"）；或引擎名（如 "engine_name"），系统会根据当前的 catalog 设置自动补全为对应的全限定名。
例子
提交任务
if (!existsCatalog("test")) {
createCatalog("test")
}
go
use catalog test
// 定义任务
def myFunc(x,y,z){
writeLog(x,y,z)
}
// 定义参数
a = "aaa"
b = "bbb"
c = "ccc"
// 提交流图
g = createStreamGraph("timerEngineDemo")
g.source("trade", `id`price, [INT, DOUBLE])
.timerEngine(3, myFunc, a, b, c)
.setEngineName("myJob")
.sink("result")
g.submit()暂停任务执行
useOrcaStreamEngine("myJob", stopTimerEngine)继续执行任务
useOrcaStreamEngine("myJob", resumeTimerEngine)