[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: [TABLE][SQL] Enirchment/Time versioned joins support in Flink

Huge +1!!!

On Mon, Jul 2, 2018 at 6:07 AM Piotr Nowojski <piotr@xxxxxxxxxxxxxxxxx>

> Hi,
> Together with Fabian, Timo and Stephan we were working on a proposal to
> add a support for time versioned joins in Flink SQL/Table API. The idea
> here is to support use cases, when user would like to join a stream of data
> with a table, that changes over time and where future updates to the table
> do not affect past/previously emitted results.
> I have prepared a document describing such feature, with proposed
> nomenclature and syntax, as well with explained semantic of such join:
> <
> >
> The document briefly covers also a case of enrichment join with
> static/bounded table.
> If anyone has any comments/questions, please feel free to mark them in the
> document or in this thread.
> Thanks, Piotrek