我主要是使用Gelly這個API來做研究,由於研究目標要針對
DataSet<Edge<Long, Long>> (Edge是Gelly特別extend的tuple3,有3個欄位:t0, t1, t2)
內部的各個edge使用t0及t1的值來進行運算後更改t2。
原本想說可以用index來針對每個Edge分別處理,但搜尋好號像沒有找到相關用法。*来自志愿者整理的flink邮件归档
使用index對每個Edge分別處理是說?如果是指dataset中edge的index的話,邏輯上可以通過使用edges.map()或Graph#mapEdges,並在MapFunction中對每個Edge分別進行處理,從而得到一個新的Edge的DataSet;如果是指各欄位的index的話,Edge對象應該可以有相應的對source/target/value的get和set方法,可以對每個欄位進行操作~*来自志愿者整理的FLINK邮件归档
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。