apache-kafka - 地理位置点上的 Kafka 流窗口

Question

我想利用 Kafka Stream 库通过会话窗口执行流式分析，但我希望“会话窗口”不是按时评估，而是按地理距离度量。

我试图在互联网上寻找它，但找不到任何资源，有人知道吗？以防我在开始换班之前错过了什么。

编辑

我想要一些东西：

在 T0 到达消息时：

{
tm: T0
lat: x
lon: y
}

在 T1 > T0 时：

{
tm: T1
lat: x + Delta_x
lon: y + Delta_y
}

我想在坐标和时间上定义一个“会话窗口”，如果新消息在适当的时间窗口中到达并且在适当的“坐标距离”中会话继续，如果其中一个策略丢失你关闭会话窗口

编辑结束

谢谢马特奥

标签： apache-kafkaapache-kafka-streams