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)
