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 wrote:
>
> Hi,
> I am implementing emitting discarded patterns in CEP library through Side
>
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:
void collect(OutputTag outputTag, StreamRecord record);
Why the type of the outputTag is not also X? Or at least T extends X?
Thanks in advance