[
https://issues.apache.org/jira/browse/FLINK-1886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513089#comment-14513089
]
hagersaleh commented on FLINK-1886:
-----------------------------------
how can handle left outer join for any two dataset this dataset inlcude any
filed number
example
data set one
ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
DataSet<Tuple4<Integer, String, String,String>>
customer=env.readCsvFile("/home/hadoop/Desktop/Dataset/customer.csv")
.fieldDelimiter('|')
.includeFields("11110000").ignoreFirstLine()
.types(Integer.class,String.class,String.class,String.class);
dataset two
ExecutionEnvironment orders = ExecutionEnvironment.getExecutionEnvironment();
DataSet<Tuple3<Integer, String, String>
customer=env.readCsvFile("/home/hadoop/Desktop/Dataset/order.csv")
.fieldDelimiter('|')
.includeFields("11110000").ignoreFirstLine()
.types(Integer.class,String.class,String.classs);
> 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)
