Re: Flink's Either type information

[Yun Gao]

      Hi Jacopo,

          Could you also provide how the KeyedBroadcastProcessFunction is 
created when constructing datastream API ? For example, are you using something 
like 

          new KeyedBroadcastProcessFunction<Integer, Integer, Integer, 
Either<MyLeft, MyRight>() { 
                       // Function implementation
             }

             or something else?

     Best, 
      Yun



------------------------------------------------------------------
From:jacopo.gobbi <jacopo.go...@ubs.com>
Send Time:2020 Feb. 17 (Mon.) 18:31
To:user <user@flink.apache.org>
Subject:Flink's Either type information

Hi all,
How can an Either value be returned by a KeyedBroadcastProcessFunction?
We keep getting "InvalidTypesException: Type extraction is not possible on 
Either type as it does not contain information about the 'left' type." when 
doing: out.collect(Either.<MyLeftType, MyRightType>Right(myObject));

Thanks,

Jacopo Gobbi