增加Kafka对地理对象数据类型的支持, 期望可以在Flink中通过类似以下方式直接访问Kafka中的时空数据.

DataStream<Point> dataStream = env.addSource(new CSVPointSource("/path/1.txt"));

具体来说, 所要完成的工作可能包含以下几点:

• Kafka Producer用于从本地文件或其他可能的地方读取数据, 模拟数据生产;
• 实现Kafka Producer的过程中, 可能需要考虑如何进行合理的数据分区(具有空间语义), 以方便Flink可以以更高的吞吐量读取数据;
• Kafka Consumer用于从Kafka消费数据, 考虑从Flink现有的Kafka Connector构建, 屏蔽时空数据解析的细节;
• 总体来说, 完成与Flink与Kafka的交互, 重点是数据的序列化-反序列化, 采用Avro进行, 一个首要的问题可能是为com.github.tm.glink.feature中的Java对象定义Avro Schema.

glink的作者你们好, 我需要用flink做一个地理位置相关的业务工作，很高兴搜到了你们这个库, 但发现还没有使用文档，我想请问一下目前这个库能支持查询某个点是否在一个多边形区域里吗？
我的业务场景为: 读取许多艘船的运动轨迹流, 对它们1分钟后的轨迹进行预测, 对过近的船计算他们的“预警”指标

1. 从数据源读取许多艘船的运动轨迹流(ship1的轨迹，ship2的轨迹...)
2. 把流按船舶编号划分, 并预测生成各个船的流(ship1_1分钟后的轨迹), (ship2_1分钟后的轨迹)...(shipN_1分钟后的轨迹)
3. 查询预测出的未来同一时刻下(比如20s时, 40s时, 在某个多边形(或圆形)范围内的船, 并根据船自身参数计算两艘船的“预警”指标

我目前还是一个学习flink不久的新手, 请问这样的一个功能可以使用你们的库来实现吗?
如果您愿意给我一些思路上的建议, 我将万分感激 ;)