Есть ли в потоке Apache Flink опция сравнения? - PullRequest
Новая
       36

Есть ли в потоке Apache Flink опция сравнения?

0 голосов
/ 12 декабря 2018

В нашем случае мы хотели бы иметь возможность сравнивать потоковые данные при подписке с сервера AMPS [CRANK UP THE AMPS].Есть ли встроенная функция или какие-либо опции для сравнения предыдущего значения результата выполнения потоковой передачи?

1 Ответ

0 голосов
/ 15 декабря 2018

Функция Flink Потоковая передача с отслеживанием состояния и предлагает несколько решений для определения закономерностей и трендов:

  • Вы можете использовать состояние в операторе, например RichFlatMap или ProcessFunction чтобы запомнить информацию о предыдущих событиях и использовать ее при обработке последующих событий.
  • CEP - это библиотека, которая реализует DSL (выполняемый конечным автоматом) для выполнения сложной обработки событий.
  • MATCH_RECOGNIZE - это функция потока Flink SQL, которая используется для обнаружения шаблонов.
...