大佬们, assignTimestampsAndWatermarks() 支持将eventTime设置为未来的时间吗

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

大佬们, assignTimestampsAndWatermarks() 支持将eventTime设置为未来的时间吗

Hongyuan Ma
我想预测某个轨迹点后续5秒的轨迹, 并设置eventTime为未来的时间
我使用AscendingTimestampExtractor 但是报了 WARN Timestamp monotony violated xxxxxxx < yyyyyyy


// 对于每个轨迹点, 预测输出其后续10秒的点, 比如A车10秒时来了一条, B车15秒时来了一条
stream.flatmap()  // 预测出A车11~20秒的轨迹, B车16~25秒时的轨迹
.assignTimestamps(new AscendingTimestampExtractor()) // 设置eventTime为预测计算出的未来的时间
.window(1s) // 收集预测出的第16, 第17秒...第20秒时的A, B两个轨迹点
.process() // 对某一秒时的轨迹点进行两两距离计算, 距离过近就发送一条警报消息