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
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
> *
[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
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
Hey,
I have a question about using metrics based on filtered data.
Basically, I have handlers for many types of events I get from my data source
(in my case, Kafka), and every handler has it's own filter function.
That given handler also has a Counter, incrementing every time it filters out
an ev
