Hi, I'm currently working on Flink InputFormat related implementation. So I have written class as follows.
public class MyInputFormat extends RichInputFormat<Row, InputSplit>
implements ResultTypeQueryable {
But here I'm getting error with *Row *parameter. I can't import that
*org.apache.flink.types.Row.*
I have added the needed dependencies to the maven pom.xml as well. So how
can I solve this issue...
Thanks,
Pawan
--
*Pawan Gunaratne*
*Mob: +94 770373556*
