Hi,
Thanks Fabian and Chesnay for providing those information.
Pawan
On Wed, Jan 18, 2017 at 2:11 PM, Chesnay Schepler
wrote:
> Hello,
>
> The dependencies are fine.
>
> The short answer is i would recommend you to read op on java generics.
>
> The long answer is that OT and T are just placeho
Hello,
The dependencies are fine.
The short answer is i would recommend you to read op on java generics.
The long answer is that OT and T are just placeholders for types that
are supposed to be replaced.
You can either provide the type in your implementation:
(in this example, the ReadFromFi
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 if the input format produce a tuple with two fields
of String and
Hi,
Yeah I also wrote in the way you have written..
public class ReadFromFile implements InputFormat{
}
Is that a problem with that declaration or dependencies ?
Thanks,
Pawan
On Tue, Jan 17, 2017 at 7:56 PM, Chesnay Schepler
wrote:
> Hello,
>
> Did you write something like this?
>
>p
Hello,
Did you write something like this?
public class MyInputFormat implements InputFormat {
}
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 rea
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.
org.apache.flink
flink-core
1.1.4
