Péter Szabó created FLINK-1274:
----------------------------------
Summary: Make Flink Streaming's FileSourceFunction type generic
Key: FLINK-1274
URL: https://issues.apache.org/jira/browse/FLINK-1274
Project: Flink
Issue Type: Improvement
Components: Streaming
Reporter: Péter Szabó
Assignee: Péter Szabó
We experimented with reading files with Flink Streaming from non-local file
systems that are supported by the Flink api (e.g. HDFS). Our FileSourceFunction
works only with String types. It would be important to parametrize that class
in order to be able to read data from a file into a specified type. When we
tried to do so, we got a type erasure problem.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
