resumeTimerEngine
Syntax
resumeTimerEngine(engine)
Arguments
engine A STRING scalar representing the engine name. You can provide either the fully qualified name (e.g., "catalog_name.orca_engine.engine_name"), or just the engine name (e.g., "engine_name") when the system will automatically complete it to the corresponding fully qualified name based on the current catalog setting.
Details
This function can only be called via useOrcaStreamEngine and resumes
execution of jobs submitted by DStream::timerEngine.
Examples
Submit the job:
if (!existsCatalog("test")) {
createCatalog("test")
}
go
use catalog test
// Define the job
def myFunc(x,y,z){
writeLog(x,y,z)
}
// Define the parameter
a = "aaa"
b = "bbb"
c = "ccc"
// Submit the steam graph
g = createStreamGraph("timerEngineDemo")
g.source("trade", `id`price, [INT, DOUBLE])
.timerEngine(3, myFunc, a, b, c)
.setEngineName("myJob")
.sink("result")
g.submit()Stop job execution:
useOrcaStreamEngine("myJob", stopTimerEngine)Resume job execution:
useOrcaStreamEngine("myJob", resumeTimerEngine)