我有一个Flink应用程序的AWS动态分析服务。我需要根据阈值过滤数据流上的一些值。另外,我使用AWS系统管理器参数存储服务传递阈值参数。现在,我要说的是:val threshold: Int = ssmParameter.getParameterRequest(ssmClient, "/kinesis/threshold").toInt
val kinesis_deserial
我有带unix纪元时间戳的事件,我正在使用一个带Kinesis连接器的表作为源表。我需要使用与水印相同的时间戳字段。我如何在python中做到这一点?我使用的是Flink-1.11版本,因为这是最新的AWS支持。event_time AS event_time - INTERVAL '5' SECOND WITH (