You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/09 07:57:41 UTC
[jira] [Commented] (FLINK-2186) Rework CSV import to support very
wide files
[ https://issues.apache.org/jira/browse/FLINK-2186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15859174#comment-15859174 ]
ASF GitHub Bot commented on FLINK-2186:
---------------------------------------
Github user ex00 commented on the issue:
https://github.com/apache/flink/pull/3012
Thanks for work @tonycox.
The PR looks good to me. I left a few minor comments about PR.
What do you mean about test negative case? If typeMap does not match with fields type in file for example
> Rework CSV import to support very wide files
> --------------------------------------------
>
> Key: FLINK-2186
> URL: https://issues.apache.org/jira/browse/FLINK-2186
> Project: Flink
> Issue Type: Improvement
> Components: Machine Learning Library, Scala API
> Reporter: Theodore Vasiloudis
> Assignee: Anton Solovev
>
> In the current readVcsFile implementation, importing CSV files with many columns can become from cumbersome to impossible.
> For example to import an 11 column file we need to write:
> {code}
> val cancer = env.readCsvFile[(String, String, String, String, String, String, String, String, String, String, String)]("/path/to/breast-cancer-wisconsin.data")
> {code}
> For many use cases in Machine Learning we might have CSV files with thousands or millions of columns that we want to import as vectors.
> In that case using the current readCsvFile method becomes impossible.
> We therefore need to rework the current function, or create a new one that will allow us to import CSV files with an arbitrary number of columns.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)