Re: Scala case class TypeInformation and Serializer

aolang...@gmail.com>> *Date: *Wednesday, December 11, 2019 at 7:20 PM *To: *user mailto:user@flink.apache.org>> *Subject: *Scala case class TypeInformation and Serializer __ __ Hi, I'm working on write a flink stream job with scala api , how should I fi

Re: Scala case class TypeInformation and Serializer

12日周四 上午12:45写道： > Hi > > > > Would you please give related code? I think it might due to insufficient > hint to type information. > > > > Best > > Yun Tang > > > > > > > > *From: *杨光 > *Date: *Wednesday, December 11, 2019 at 7:20

Re: Scala case class TypeInformation and Serializer

Hi Would you please give related code? I think it might due to insufficient hint to type information. Best Yun Tang From: 杨光 Date: Wednesday, December 11, 2019 at 7:20 PM To: user Subject: Scala case class TypeInformation and Serializer Hi, I'm working on write a flink stream job

Scala case class TypeInformation and Serializer

Hi, I'm working on write a flink stream job with scala api , how should I find out which class is serialied by flink type serializer and which is falled back to generic Kryo serializer. And if one class falls back to Kryo serializer, how can I make some extend the TypeInfo classes of Flink or

Re: Case Class TypeInformation

Yes, that JIRA was actually motivated by your question. Thanks for the feedback :-) 2017-10-25 17:14 GMT+02:00 Joshua Griffith : > Hello Fabian, > > Thank you for the suggestion. I see that an issue has been created to > support adding custom type information to case

Re: Case Class TypeInformation

Hello Fabian, Thank you for the suggestion. I see that an issue has been created to support adding custom type information to case classes: https://issues.apache.org/jira/browse/FLINK-7859 Joshua On Oct 17, 2017, at 3:01 AM, Fabian Hueske > wrote:

Re: Case Class TypeInformation

Hi Joshua, that's a limitation of the Scala API. Row requires to explicitly specify a TypeInformation[Row] but it is not possible to inject custom types into a CaseClassTypeInfo, which are automatically generated by a Scala compiler plugin. The probably easiest solution is to use Flink's Java

Re: Case Class TypeInformation

Correction: I have the row’s RowTypeInfo at runtime before the job starts. I don’t have RowTypeInfo at compile time. On Oct 16, 2017, at 4:15 PM, Joshua Griffith > wrote: Hello, I have a case class that wraps a Flink Row and I’d like

Case Class TypeInformation

Hello, I have a case class that wraps a Flink Row and I’d like to use fields from that Row in a delta iteration join condition. I only have the row’s fields after the job starts. I can construct RowTypeInfo for the Row but I’m not sure how to add that to Flink’s generated type information for