Changed
- Major upgrade of Apache Flink version
- No updates to existing datasets needed, but the verifiability of some datasets may be broken (since we don't yet implement engine versioning as per ODF spec)
Added
- Flink now supports a much nicer temporal table join syntax:
sql
SELECT
t.event_time,
t.symbol,
p.volume as volume,
t.price as current_price,
p.volume * t.price as current_value
FROM tickers as t
JOIN portfolio FOR SYSTEM_TIME AS OF t.event_time AS p
WHERE t.symbol = p.symbol
- We recommend using `FOR SYSTEM_TIME AS OF` join syntax as replacement for old `LATERAL TABLE` joins
- Determinism of Flink computation should be improved