flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chesnay Schepler <ches...@apache.org>
Subject Re: [Dev] Dependencies issue related to implementing InputFormat Interface
Date Tue, 17 Jan 2017 14:26:23 GMT
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
>


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message