You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/17 07:05:12 UTC

[jira] [Closed] (FLINK-3915) Updating a Dataset in Flink using Flink's Table API

     [ https://issues.apache.org/jira/browse/FLINK-3915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Fabian Hueske closed FLINK-3915.
--------------------------------
    Resolution: Information Provided

This is not possible with the current version (1.0.x) of the Table API. The Table API is currently reworked and will support such use cases in the next minor version (1.1.0). 
With Flink 1.0.x you can use the DataSet API to set a field based on the values of other fields.

Closing this issue, since it is question and not a bug report or feature request.

> Updating a Dataset in Flink using Flink's Table API
> ---------------------------------------------------
>
>                 Key: FLINK-3915
>                 URL: https://issues.apache.org/jira/browse/FLINK-3915
>             Project: Flink
>          Issue Type: Wish
>          Components: Table API
>    Affects Versions: 1.0.1
>            Reporter: Akshay Shingote
>
> I am using Flink Table API. I want to update the table in Flink through Pattern Detection..I am using 3 fields : routeno,source,distance,category . Now I want to update the category based on the value of distance for every routeno...For ex : if routeno=1 and distance<=200 then category='daily' ..How can I update this using Flink's Table API?? Can we update dataset or Table using Flink's Table API ??



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)