Можем ли мы изменить поле rowtime в FLINK SQL? - PullRequest
Новая
       74

Можем ли мы изменить поле rowtime в FLINK SQL?

0 голосов
/ 31 марта 2020

У меня есть таблица event и три (может быть, больше) других feature таблицы. Когда я запрашиваю объекты, я использую таблицы объектов левого соединения последовательно к таблице событий.

Так же, как псевдокод ниже: 

resultTable0 = eventTable left join featureTable0
resultTable1 = resultTable0 left join featureTable1
resultTable2 = resultTable1 left join featureTable2

Затем я оцениваю обогащенные события с моделью.

Но я обнаружил, что это медленнее, чем я хочу, потому что я использую интервальное соединение, у каждого соединения есть окно. Таким образом, события должны go через несколько windows, и я обнаружил, что windows больше задержек при выводе событий.

Поэтому я переключился на использование небольшого окна для левых соединений. Но для этого нужно изменить значение поля таблицы времени таблицы событий. 

 e.timestamp between f.timestamp - interval '1' day and f.timestamp

                        ||
                        ||
                        vv
 ft(e.timestamp) between f.timestamp - interval '1' second and f.timestamp

Мне нужно указать ft(e.timestamp) в качестве нового поля ROWTIME для таблицы событий (результатов). Является ли это возможным?

Заранее спасибо.

...