[jira] [Created] (FLINK-1886) how can handles left join ,right join , FULL OUTER JOIN in flink

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-1886) how can handles left join ,right join , FULL OUTER JOIN in flink

Shang Yuanchun (Jira)
hagersaleh created FLINK-1886:
---------------------------------

             Summary: 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)