flink-dev mailing list archives

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

Mime
View raw message