如何在Hazelcast Jet中打开一个tcp套接字并处理通过它获取的连续信息

How to open a tcp socket and process the continuous information obtained through it in Hazelcast Jet

我正在尝试使用 Hazelcast 分析传感器数据 jet.For 我需要打开一个 Tcp 套接字并处理通过它获得的信息。

您可以使用 Socket streamer 从 Jet 中的套接字读取数据。查看文档:http://docs.hazelcast.org/docs/jet/0.4/manual/Vertices_in_the_Library/Sources.html#page_Socket+Streamer