0

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

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

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

但是这里的问题是，当产生一定数量的复杂事件时，我不知道如何停止 Flink 程序。我将详细阐述场景

场景： Flink 程序正在接收心率、呼吸率和其他流数据，并正在生成心脏病发作警告。传感器数据是使用一些分布生成的。

  1. 第一个任务是在连续产生 3 个警告时停止引擎并查找引擎的处理时间？

  2. 第二个任务是以一定的速率生成数据流？目前，Flink 程序正在从文件中读取各种传感器数据并从中生成流，并将 Steam 数据发送到 Kafka，然后再发送到 Flink 程序。有人能告诉我如何以x 事件/秒的速率生成原始流吗？

4

0 回答 0