You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Péter Szabó (JIRA)" <ji...@apache.org> on 2016/01/12 14:01:39 UTC

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

     [ https://issues.apache.org/jira/browse/FLINK-1274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Péter Szabó resolved FLINK-1274.
--------------------------------
    Resolution: Resolved

No longer an issue, API changed.

> 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)