Re: Case Class TypeInformation

2017-10-25 Thread Fabian Hueske
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 classes: > https://issues.apa

Re: Case Class TypeInformation

2017-10-25 Thread 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 classes: https://issues.apache.org/jira/browse/FLINK-7859 Joshua On Oct 17, 2017, at 3:01 AM, Fabian Hueske mailto:fhue...@gmail.com>> wrote: Hi Joshua, that's

Re: Case Class TypeInformation

2017-10-17 Thread Fabian Hueske
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 Tup

Re: Case Class TypeInformation

2017-10-16 Thread Joshua Griffith
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 mailto:jgriff...@campuslabs.com>> wrote: Hello, I have a case class that wraps a Flink Row and I’d like to use fields from that Row