FLINK SQL: полное объединение двух таблиц на основе временного окна - PullRequest
0 голосов
/ 15 октября 2018

У меня есть две таблицы потоков

Таблица

id     | data1  |  ts
------------------------
1      | xxxx   | 1234

Таблица B

id     | data2  |  ts
------------------------
2      | yyyy   | 1234

И я хочу объединить эти две таблицы на основе временного окна。ДляНапример, на каждые 20 секунд переворачивающегося окна он будет генерировать один из следующих результатов

1), если у пакета A и B есть записи с одинаковым идентификатором в этом временном окне

A.id | A.data1 | A.ts | B.id | B.data2 | B.ts

2) если B не имеет записей совпадений идентификаторов в A в этом временном окне

A.id | A.data1 | A.ts | null | null | null

3) если A не имеет записей совпадений идентификаторов в b в этом временном окне

null | null | null | B.id | B.data2 | B.ts

Может ли Flink Sql в потоковом режиме реализовать это?

...