java - Kafka-Streams 相当于表值函数 join 或 cross apply

Question

我正在使用KStream<key, coordinates>我需要确定每个坐标在哪个周长内并输出 KStream<key, perimeterId> 。

所有周长都在 GlobalKTable<perimeterID, perimeterVertices> 范围内。我有一个多边形点函数来执行此操作，我只是不知道如何在 Kafka-Streams 中使用它，而没有明显的表值函数或在 Kafka-Streams 中交叉应用。

Answer 1

我最终采用了一种极其丑陋的方式，而且可能无法扩展。

我的 GlobalKTable 现在是单行 "1" List<perimeterID,perimeterVertices> 。这允许我使用“1”作为每个事件的 key 来左加入。在 ValueJoiner 中，我运行 Point-in-Polygon 函数并设置周界 ID，然后返回 <key, perimeterId>到我的输出流。