You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Kurt Young (Jira)" <ji...@apache.org> on 2019/12/06 08:13:00 UTC

[jira] [Commented] (FLINK-13943) Provide api to convert flink table to java List (e.g. Table#collect)

    [ https://issues.apache.org/jira/browse/FLINK-13943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989499#comment-16989499 ] 

Kurt Young commented on FLINK-13943:
------------------------------------

Eventually we added a util to blink planner only, due to some type & capability mismatch between blink and flink planner.

> Provide api to convert flink table to java List (e.g. Table#collect)
> --------------------------------------------------------------------
>
>                 Key: FLINK-13943
>                 URL: https://issues.apache.org/jira/browse/FLINK-13943
>             Project: Flink
>          Issue Type: Improvement
>          Components: Table SQL / Planner
>            Reporter: Jeff Zhang
>            Assignee: Caizhi Weng
>            Priority: Major
>              Labels: pull-request-available
>          Time Spent: 20m
>  Remaining Estimate: 0h
>
> It would be nice to convert flink table to java List so that I can do other data manipulation in client side after execution flink job. For flink planner, I can convert flink table to DataSet and use DataSet#collect, but for blink planner, there's no such api.
> EDIT from FLINK-14807:
> Currently, it is very unconvinient for user to fetch data of flink job unless specify sink expclitly and then fetch data from this sink via its api (e.g. write to hdfs sink, then read data from hdfs). However, most of time user just want to get the data and do whatever processing he want. So it is very necessary for flink to provide api Table#collect for this purpose. 
> Other apis such as Table#head, Table#print is also helpful.  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)