Hi Pawan,
If you want to read a file, you might want to extend the FileInputFormat
class. It has already a lot of file-related functionality implemented.
OT is the type of the records produced by the InputFormat. For example
Tuple2<String, Integer> if the input format produce a tuple with two fields
of String and Integer types.
Best, Fabian
2017-01-18 4:52 GMT+01:00 Pawan Manishka Gunarathna <
pawan.manis...@gmail.com>:
> Hi,
> Yeah I also wrote in the way you have written......
>
> public class ReadFromFile implements InputFormat<OT,T extends InputSplit>{
> }
>
> Is that a problem with that declaration or dependencies ?
>
> Thanks,
> Pawan
>
> On Tue, Jan 17, 2017 at 7:56 PM, Chesnay Schepler <ches...@apache.org>
> wrote:
>
> > Hello,
> >
> > Did you write something like this?
> >
> > public class MyInputFormat implements InputFormat<OT, T extends
> > InputSplit> {
> > ....
> > }
> >
> > Regards,
> > Chesnay
> >
> > On 17.01.2017 04:18, Pawan Manishka Gunarathna wrote:
> >
> >> Hi,
> >>
> >> I'm currently working on Flink InputFormat Interface implementation. I'm
> >> writing a java program to read data from a file using InputputFormat
> >> Interface. I used maven project and I have added following dependencies
> to
> >> the pom.xml.
> >>
> >> <dependencies>
> >> <dependency>
> >> <groupId>org.apache.flink</groupId>
> >> <artifactId>flink-core</artifactId>
> >> <version>1.1.4</version>
> >> </dependency>
> >>
> >> <dependency>
> >> <groupId>org.apache.flink</groupId>
> >> <artifactId>flink-clients_2.11</artifactId>
> >> <version>1.1.4</version>
> >> </dependency>
> >>
> >> <dependency>
> >> <groupId>org.apache.flink</groupId>
> >> <artifactId>flink-java</artifactId>
> >> <version>1.1.4</version>
> >> </dependency>
> >>
> >> </dependencies>
> >>
> >>
> >> I have a java class that implements InputFormat. It works with
> >> *InputFormat.
> >> *But it didn't allow to used *InputFormat<OT, T extends InputSplit>.
> *That
> >> OT field didn't recognized.
> >>
> >> I need a any kind of help to solve this problem.
> >>
> >> Thanks,
> >> Pawan
> >>
> >>
> >
>
>
> --
>
> *Pawan Gunaratne*
> *Mob: +94 770373556*
>
