[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14327776#comment-14327776
]
ASF GitHub Bot commented on FLINK-1512:
---------------------------------------
GitHub user chiwanpark opened a pull request:
https://github.com/apache/flink/pull/426
[FLINK-1512] Add CsvReader for reading into POJOs.
This PR contains following changes.
* `CsvInputFormat` and `ScalaCsvInputFormat` can receive POJO type as
generic parameter
* Add `pojoType(Class<T> targetType)` into `CsvReader` (Java API)
* Modify `readCsvFile` method in `ExecutionEnvironment` (Scala API)
* Add unit tests for `CsvInputFormat` and `ScalaCsvInputFormat`
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/chiwanpark/flink FLINK-1512
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/426.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #426
----
commit 2463d6b7d244528e1625288e1b780335769f14ee
Author: Chiwan Park <[email protected]>
Date: 2015-02-18T18:27:59Z
[FLINK-1512] [java api] Add CsvReader for reading into POJOs
commit 8fe5f8d1bd402382e6fa93014c5b2fec8e22cbd0
Author: Chiwan Park <[email protected]>
Date: 2015-02-19T17:23:56Z
[FLINK-1512] [scala api] Add CsvReader for reading into POJOs
----
> Add CsvReader for reading into POJOs.
> -------------------------------------
>
> Key: FLINK-1512
> URL: https://issues.apache.org/jira/browse/FLINK-1512
> Project: Flink
> Issue Type: New Feature
> Components: Java API, Scala API
> Reporter: Robert Metzger
> Assignee: Chiwan Park
> Priority: Minor
> Labels: starter
>
> Currently, the {{CsvReader}} supports only TupleXX types.
> It would be nice if users were also able to read into POJOs.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
