我想通过下面提到的代码找到flink中的处理时间

JobExecutionResult jobExecutionResult = envrionment.execute("CEP engine ");

   System.out.println("Processing time = " + jobExecutionResult.getNetRuntime(TimeUnit.MILLISECONDS));

但这里的问题是，当生成一定数量的复杂事件时，我不知道如何停止flink程序。我将详细阐述这个场景
场景：flink程序正在接收心率、呼吸频率和其他流数据，并生成心脏病发作警告。传感器数据是使用一些分布生成的。
第一个任务是在连续生成3个警告时停止发动机，并查找发动机的处理时间？
第二个任务是以一定的速率生成数据流？现在，flink程序正在从一个文件中读取各种传感器数据，并从中生成流，然后将蒸汽数据发送给kafka，然后再发送给flink程序。有人能告诉我如何以每秒x个事件的速率生成原始流吗？