flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Yuval Itzchakov <yuva...@gmail.com>
Subject Re: Infer if a Table will create an AppendStream / RetractStream
Date Tue, 19 May 2020 10:53:19 GMT
Hi Timo,
Right now I'm using Flink Planner with 1.9.0 but planning an upgrade to
1.10.1 / 1.11 with Blink.

On Mon, 18 May 2020, 16:43 Timo Walther, <twalthr@apache.org> wrote:

> Hi Yuval,
>
> currently there is no API for getting those insights. I guess you need
> to use internal API for getting this information. Which planner and
> version are you using?
>
> Regards,
> Timo
>
>
> On 18.05.20 14:16, Yuval Itzchakov wrote:
> > Hi,
> >
> > Is there any way to infer if a Table is going to generate an
> > AppendStream or a RetractStream under the hood in order to figure out if
> > I need to call `toAppendStream` vs `toRetractStream` for the DataStream
> > conversion? Note this information is important to me further down the
> > DAG so I want to preserve these semantics.
> >
> > --
> > Best Regards,
> > Yuval Itzchakov.
>
>

Mime
View raw message