Hi Salva,

The examples for temporal table joins can be found at
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sql/queries/joins/#temporal-joins.
Your example is definitely possible with just using SQL.

Best regards,

Martijn

On Tue, Oct 4, 2022 at 12:20 PM Salva Alcántara <salcantara...@gmail.com>
wrote:

> Based on this:
>
>
> https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/concepts/temporal_table_function/
>
> It seems that the only way of registering temporal table functions is via
> the Table API.
>
> If that is the case, is there a way to make this example work
>
> ```
> SELECT
>   SUM(amount * rate) AS amount
> FROM
>   orders,
>   LATERAL TABLE (rates(order_time))
> WHERE
>   rates.currency = orders.currency
> ```
>
> without the Table API, just using SQL? E.g., is it possible to deploy the
> temporal table function to the cluster (by packaging it in a jar file) and
> then run the above query from the Flink SQL CLI?
>
> Thanks in advance,
>
> Salva
>
>

Reply via email to