我有一个物体坐标流（时间，x，y），我想把它转换成一个距离流，然后再转换成一个速度流。要做到这一点，我需要处理两个连续的消息每次。你能给我一个关于如何创建点之间欧几里德距离流的想法吗？
nnt7mjpx1#
DataStream<Distance> distances = yourCoordinateSource .windowAll(GlobalWindows.create()) .trigger(PurgingTrigger.of(CountTrigger.of(2))) .process(new DistanceFunction()); DataStream<Speed> speeds = distances.map(new SpeedFunction())...
你可以链的过程 DataStream s。要访问两条消息，可以创建两条消息的固定大小窗口，然后对窗口应用处理函数。假设您的流没有键控使用 windowAll() .你必须实现这两个目标 DistanceFunction （延伸） ProcessWindowFunction )以及 SpeedFunction （延伸） MapFunction ).
DataStream
windowAll()
DistanceFunction
ProcessWindowFunction
SpeedFunction
MapFunction
1条答案
按热度按时间nnt7mjpx1#
你可以链的过程
DataStreams。要访问两条消息，可以创建两条消息的固定大小窗口，然后对窗口应用处理函数。
假设您的流没有键控使用
windowAll().你必须实现这两个目标
DistanceFunction（延伸）ProcessWindowFunction)以及SpeedFunction（延伸）MapFunction).