15:11 GMT+02:00 nragon :
> Hi,
>
> I have two streams coming from kafka which I want to map into table
> environment. Because they are not pojo or tuple I will have to map them
> using, for instance, Types.ROW_NAMED. Can i use StreamTableSource and call
> registerTableSource o
Hi,
I have two streams coming from kafka which I want to map into table
environment. Because they are not pojo or tuple I will have to map them
using, for instance, Types.ROW_NAMED. Can i use StreamTableSource and call
registerTableSource or should I use the same code inside getDataStream but