[
https://issues.apache.org/jira/browse/FLINK-13943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-13943:
-------------------------------------
Description:
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.
was: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.
> 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 / API
> Reporter: Jeff Zhang
> Priority: Major
>
> 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)
