Re: StreamTableSource

2017-07-16 Thread Fabian Hueske
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

StreamTableSource

2017-07-12 Thread 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 or should I use the same code inside getDataStream but