可以参考下面的自定义函数,作用是删除当前节点上的所有流计算引擎:
def DropAllEngines(){
if(getStreamEngineStat().rows() > 0){
engineTypes = getStreamEngineStat().keys()
for(engineType in engineTypes){
engineNum = size(getStreamEngineStat()[engineType])
i = 0
do{
print("Drop Stream Engine: " + getStreamEngineStat()[engineType].name[0])
i = i +1
try{
dropStreamEngine(getStreamEngineStat()[engineType].name[0])
}
catch(ex){
print(ex)
}
}
while(i < engineNum)
}
}
print("All engines have been dropped !")
}