flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Péter Szabó (JIRA) <j...@apache.org>
Subject [jira] [Created] (FLINK-1274) Make Flink Streaming's FileSourceFunction type generic
Date Sat, 22 Nov 2014 22:29:12 GMT
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

View raw message