У меня есть две таблицы потоков
Таблица
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 в потоковом режиме реализовать это?