У меня есть конечная точка http, где клиент отправляет запрос со своими данными, на который возвращается вычисленный ответ. Вычисление имеет несколько этапов - data lookup, calculations и несколько transformations. Окончательный результат записывается как ответ на запрос.
Могу ли я написать задание Hazelcast Jet, которое принимает данные, полученные в http, все ли вычисления, указанные выше, отвечают на запрос?
Я не вижу прямого пути к этому, однако один подход, который я вижу, состоит в том, чтобы иметь реактивный http-сервер, прочитать запрос реактивным способом, записать запрос в Ringbuffer или IQueue и дождаться результата (с с помощью обратного вызова) в другом Ringbuffer.
Задание Hazelcast может читать из источника Ringbuffer, вычислять и преобразовывать, наконец записывая результат в другой Ringbuffer (приемник).
Использует ли Hazelcast Jet такой способ? Ваши мысли могут помочь лучше понять Джет.