Как открыть tcp-сокет и обработать непрерывную информацию, полученную через него в Hazelcast Jet

Question

Я пытаюсь проанализировать данные датчика с помощью Hazelcast Jet. Для этого мне нужно открыть Tcp-сокет и обработать информацию, полученную через него.

Answer 1

Вы можете читать из сокетов в Jet используя Socket Streamer. Ознакомьтесь с документацией: http://docs.hazelcast.org/docs/jet/0.4/manual/Vertices_in_the_Library/Sources.html.