Соединение двух потоков и управление состоянием во Flink - PullRequest
Новая
       16

Соединение двух потоков и управление состоянием во Flink

0 голосов
/ 29 мая 2018

У меня есть два потоковых источника nifi в Flink, мне нужно выполнить соединения на этих двух источниках.Какое решение будет лучшим для этого?Является ли это объединением API, предоставляемым DataStreams или таблицей API (https://ci.apache.org/projects/flink/flink-docs-release-1.5/dev/table/streaming.html#streaming-concepts).?

Кроме того, как поддерживать состояние потоков и объединений? Существует ли какое-либо решение для сборки, предоставляемое flink.

Спасибо, Рилван

1 Ответ

0 голосов
/ 29 мая 2018

Это очень сильно зависит от того, какие вычисления вы хотите применить к присоединенным данным.Если вы можете выразить свои вычисления с помощью StreamSQL (или таблицы API).Я бы посоветовал использовать его, поскольку он абстрагирует всю тяжесть низкоуровневых деталей реализации, таких как, например, поддержание состояния.

Если API таблицы недостаточно, переключитесь на API DataStream.

...