You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by Dawid Wysakowicz <wy...@gmail.com> on 2017/04/03 08:22:22 UTC

Side Outputs - type bounds.

Hi,
I am implementing emitting discarded patterns in CEP library through Side
Outputs and I have a question about the Output::collect method which is:

<X> void collect(OutputTag<?> outputTag, StreamRecord<X> record);

Why the type of the outputTag is not also X? Or at least T extends X?

Thanks in advance for some info on it.

Regards
Dawid Wysakowicz

Re: Side Outputs - type bounds.

Posted by Aljoscha Krettek <al...@apache.org>.

Hi,
You’re absolutely right. I created an Issue for this: https://issues.apache.org/jira/browse/FLINK-6246

Best,
Aljoscha
> On 3. Apr 2017, at 10:22, Dawid Wysakowicz <wy...@gmail.com> wrote:
> 
> Hi,
> I am implementing emitting discarded patterns in CEP library through Side
> Outputs and I have a question about the Output::collect method which is:
> 
> <X> void collect(OutputTag<?> outputTag, StreamRecord<X> record);
> 
> Why the type of the outputTag is not also X? Or at least T extends X?
> 
> Thanks in advance for some info on it.
> 
> Regards
> Dawid Wysakowicz