|
|
|
@ -81,7 +81,7 @@ public class IotMachineEventGeneratorJob { |
|
|
|
private ValueState<JSON> deviceState; |
|
|
|
|
|
|
|
@Override |
|
|
|
public void open(Configuration parameters) throws SQLException, IOException { |
|
|
|
public void open(Configuration parameters) throws SQLException { |
|
|
|
// 必须在 open 生命周期初始化 |
|
|
|
// 获取所有设备的最新状态 |
|
|
|
List<DeviceState> deviceStateList = Db.use().query(sql, DeviceState.class); |
|
|
|
|