You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Dong Lin (Jira)" <ji...@apache.org> on 2023/05/11 01:11:00 UTC
[jira] [Updated] (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:all-tabpanel ]
Dong Lin updated FLINK-2186:
----------------------------
Component/s: (was: Library / Machine Learning)
> 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: API / Scala
> Reporter: Theodore Vasiloudis
> Priority: Not a Priority
> Labels: auto-deprioritized-major, auto-deprioritized-minor, auto-unassigned, pull-request-available
> Time Spent: 10m
> Remaining Estimate: 0h
>
> 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
(v8.20.10#820010)