ar 2020 16:00
> *To:* Robert Metzger; Gobbi, Jacopo-XT
> *Cc:* user
> *Subject:* [External] Re: Flink's Either type information
>
>
>
> Hi Jacopo, Robert,
>
>
>
> Very sorry for missing the previous email and not response in
> time. I think exact
: Yun Gao [mailto:yungao...@aliyun.com]
Sent: Freitag, 21. Februar 2020 16:00
To: Robert Metzger; Gobbi, Jacopo-XT
Cc: user
Subject: [External] Re: Flink's Either type information
Hi Jacopo, Robert,
Very sorry for missing the previous email and not response in time. I
think exactly
ntext ctx,
Collector> out) throws Exception { }
});
result.print();
On Wed, Feb 19, 2020 at 6:07 PM wrote:
Yes, I create it the way you mentioned.
From: Yun Gao [mailto:yungao...@aliyun.com]
Sent: Dienstag, 18. Februar 2020 10:12
To: Gobbi, Jacopo-XT; user
Subject: [External] Re: Flink
ed, Feb 19, 2020 at 6:07 PM wrote:
> Yes, I create it the way you mentioned.
>
>
>
> *From:* Yun Gao [mailto:yungao...@aliyun.com]
> *Sent:* Dienstag, 18. Februar 2020 10:12
> *To:* Gobbi, Jacopo-XT; user
> *Subject:* [External] Re: Flink's Either type information
>
>
&
Hi Jacopo,
Could you also provide how the KeyedBroadcastProcessFunction is
created when constructing datastream API ? For example, are you using something
like
new KeyedBroadcastProcessFunction() {
// Function implementation
}
