You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/01/23 15:46:00 UTC
[jira] [Comment Edited] (FLINK-14807) Add Table#collect api for
fetching data to client
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17022084#comment-17022084 ]
Kostas Kloudas edited comment on FLINK-14807 at 1/23/20 3:45 PM:
-----------------------------------------------------------------
I have to think about the whole issue more, but definitely an interface like the one [~aljoscha] described (like the old and now deleted {{Program}}) could at least make easier a lot of things. Currently, the only "entrypoint" of the framework to the user code is the {{execute()}} method and this often limits our alternatives for implementing things.
was (Author: kkl0u):
I have to think about the whole issue more, but definitely an interface like the one [~aljoscha] described (like the old and now deleted {{Program}}) could at least make easier a lot of things. Currently, the only "entrypoint" of framework to the user code is the {{execute()}} method and this often limits our alternatives for implementing things.
> Add Table#collect api for fetching data to client
> -------------------------------------------------
>
> Key: FLINK-14807
> URL: https://issues.apache.org/jira/browse/FLINK-14807
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / API
> Affects Versions: 1.9.1
> Reporter: Jeff Zhang
> Priority: Major
> Labels: usability
> Fix For: 1.11.0
>
>
> 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)