Flink 实时计算案例：TxPayMatchByJoin
数据源
OrderLog.csv
34749,pay,324n0239,1558430916 34755,pay,8x0zvy8w3,1558430918 34758,create,,1558430921 34759,create,,1558430922 34752,pay,rnp435rk,1558430925 34760,create,,1558430926 34761,create,,1558430927 34762,create,,1558430933
ReceiptLog.csv
ewr342as4,wechat,1558430845 sd76f87d6,wechat,1558430847 3hu3k2432,alipay,1558430848 8fdsfae83,alipay,1558430850 32h3h4b4t,wechat,1558430852 766lk5nk4,wechat,1558430855 435kjb45d,alipay,1558430859 5k432k4n,wechat,1558430862 435kjb45s,wechat,1558430866
Flink join 代码
package
