Re: DataStream to Table API

Perfect, that worked. Thanks a lot, JING! On Sun, Aug 22, 2021 at 1:25 AM JING ZHANG wrote: > Hi Matthias, > Before the bug is fixed, you could specify the return type explicitly in > the second parameter of the map function. > > DataStream rows = integers.map(i -> Row.of("Name"+i, i)); -> >

Re: DataStream to Table API

Hi Matthias, Before the bug is fixed, you could specify the return type explicitly in the second parameter of the map function. DataStream rows = integers.map(i -> Row.of("Name"+i, i)); -> DataStream rows = integers.map(i -> Row.of("Name"+i, i), new RowTypeInfo(Types.STRING, Types.INT)); Best,

Re: DataStream to Table API

Thank you, Caizhi, for looking into this and identifying the source of the bug. Is there a way to work around this at the API level until this bug is resolved? Can I somehow "inject" the type? Thanks a lot for your help, Matthias On Thu, Aug 19, 2021 at 10:15 PM Caizhi Weng wrote: > Hi! > > I'v

Re: DataStream to Table API

Hi! I've created a JIRA ticket[1] for this issue. Please check it out and track the progress there. [1] https://issues.apache.org/jira/browse/FLINK-23885 Caizhi Weng 于2021年8月20日周五 上午10:47写道： > Hi! > > This is because TypeExtractor#getMapReturnTypes are not dealing with row > types (see that me

Re: DataStream to Table API

Hi! This is because TypeExtractor#getMapReturnTypes are not dealing with row types (see that method and also TypeExtractor#privateGetForClass). You might want to open a JIRA ticket for this. Matthias Broecheler 于2021年8月20日周五 上午7:01写道： > Hey Flinkers, > > I am trying to follow the docs >

DataStream to Table API

Hey Flinkers, I am trying to follow the docs to convert a DataStream to a Table. Specifically, I have a DataStream of Row and want the columns of the row to become the columns of the resulting table. Tha

Re: DataStream to Table Api idioms

Not a problem, thanks for the quick feedback. https://issues.apache.org/jira/browse/FLINK-7999 Seth Wiesman From: Fabian Hueske Date: Monday, November 6, 2017 at 9:14 AM To: Seth Wiesman Cc: user Subject: Re: DataStream to Table Api idioms Hi Seth, I think the Table API is not there yet to

Re: DataStream to Table Api idioms

Hi Seth, I think the Table API is not there yet to address you use case. 1. Allowed lateness cannot be configured but it is on the list of features that we plan to add in the future. 2. Custom triggers are not supported. We are planning to add an option to support your use case (early firing and

DataStream to Table Api idioms

Hi, I am experimenting with rewriting some of my datastream projects with the table api and I had some questions on how to express certain idioms. I am using 1.4-SNAPSHOT. 1) Can I express allowed lateness? 2) Can I use a custom trigger? More specifically, I have a 24hr window bu