Hello, 使用index對每個Edge分別處理是說?如果是指dataset中edge的index的話,邏輯上可以通過使用edges.map()或Graph#mapEdges,並在MapFunction中對每個Edge分別進行處理,從而得到一個新的Edge的DataSet;如果是指各欄位的index的話,Edge對象應該可以有相應的對source/target/value的get和set方法,可以對每個欄位進行操作~
------------------------------------------------------------------ From:月月 <yuestudyfl...@gmail.com> Send Time:2020 Jan. 29 (Wed.) 00:06 To:user-zh <user-zh@flink.apache.org> Subject:Dataset是否能以index提取內部元素 您好, 我主要是使用Gelly這個API來做研究,由於研究目標要針對 *DataSet<Edge<Long, Long>> (Edge是Gelly特別extend的tuple3,有3個欄位:t0, t1, t2)* 內部的各個edge使用t0及t1的值來進行運算後更改t2。 原本想說可以用index來針對每個Edge分別處理,但搜尋好號像沒有找到相關用法。 感謝!