__ __
> >
> > Would you please give related code? I think it might due to
> > insufficient hint to type information.
> >
> > __ __
> >
> > Best
> >
> > Yun Tang
> >
> > __ __
>
lto:laolang...@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
shou
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 PM
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
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 some
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
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
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
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
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 t
10 matches
Mail list logo
