[jira] [Created] (FLINK-1274) Make Flink Streaming's FileSourceFunction type generic

[Shang Yuanchun (Jira)]

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)