flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Robert Metzger (JIRA)" <j...@apache.org>
Subject [jira] [Closed] (FLINK-1886) how can handles left join ,right join , FULL OUTER JOIN in flink
Date Tue, 14 Apr 2015 09:19:12 GMT

     [ 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)

Mime
View raw message