Re: Fw: Metrics based on data filtered from DataStreamSource

2019-12-19 Thread Robert Metzger
Developer >> M: +972.528197720 */* Skype: sidney.feiner.startapp >> >> [image: emailsignature] >> >> -- >> *From:* vino yang >> *Sent:* Monday, December 16, 2019 7:56 AM >> *To:* Sidney Feiner >> *Cc:* user@flink.apa

Re: Fw: Metrics based on data filtered from DataStreamSource

2019-12-16 Thread vino yang
r* */* Data Platform Developer > M: +972.528197720 */* Skype: sidney.feiner.startapp > > [image: emailsignature] > > -- > *From:* vino yang > *Sent:* Monday, December 16, 2019 7:56 AM > *To:* Sidney Feiner > *Cc:* user@flink.apache.org > *

Re: Fw: Metrics based on data filtered from DataStreamSource

2019-12-16 Thread Sidney Feiner
[emailsignature] From: vino yang Sent: Monday, December 16, 2019 7:56 AM To: Sidney Feiner Cc: user@flink.apache.org Subject: Re: Fw: Metrics based on data filtered from DataStreamSource Hi Sidney, Firstly, the `open` method of UDF's instance is always invoked when the task thread star

Re: Fw: Metrics based on data filtered from DataStreamSource

2019-12-15 Thread vino yang
Hi Sidney, Firstly, the `open` method of UDF's instance is always invoked when the task thread starts to run. >From the second code snippet image that you provided, I guess you are trying to get a dynamic handler with reflection technology, is that correct? I also guess that you want to get a dyn