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

Robert Metzger closed FLINK-1886.
---------------------------------
    Resolution: Invalid

> how can handles left join ,right join , FULL OUTER JOIN in flink
> ----------------------------------------------------------------
>
>                 Key: FLINK-1886
>                 URL: https://issues.apache.org/jira/browse/FLINK-1886
>             Project: Flink
>          Issue Type: Bug
>            Reporter: hagersaleh
>
> how can handles left join ,right join , FULL OUTER JOIN in flink
> how can write code for handle this
> example in inner join
> DataSet<ShippingPriorityItem> result = 
>                               
> customerWithOrders.join(lineitems).where(0).equalTo(0)
>                                                                       .with(
>                                                                               
>         new JoinFunction<ShippingPriorityItem, Lineitem, 
> ShippingPriorityItem>() {
>                                                                               
>                 @Override
>                                                                               
>                 public ShippingPriorityItem join(ShippingPriorityItem i, 
> Lineitem l) {
>                                                                               
>                         i.setRevenue(l.getExtendedprice() * (1 - 
> l.getDiscount()));
>                                                                               
>                         return i;
>                                                                               
>                 }
>                                                                               
>         })



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

Reply via email to