flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Yun Gao" <yungao...@aliyun.com.INVALID>
Subject Re: Dataset是否能以index提取內部元素
Date Wed, 29 Jan 2020 03:39:40 GMT
       另外,DataSet本身應該沒有按index來提取特定元素的API,如果想要實現相應的功能,感覺應該需要首先給DataSet中各個元素增加index,將其變為Tuple2<Integer,
Edge>,然後在後續的map操作中根據index來執行不同操作~


------------------------------------------------------------------
From:Yun Gao <yungao.gy@aliyun.com.INVALID>
Send Time:2020 Jan. 29 (Wed.) 11:34
To:user-zh <user-zh@flink.apache.org>
Subject:Re: Dataset是否能以index提取內部元素

     Hello,
          使用index對每個Edge分別處理是說?如果是指dataset中edge的index的話,邏輯上可以通過使用edges.map()或Graph#mapEdges,並在MapFunction中對每個Edge分別進行處理,從而得到一個新的Edge的DataSet;如果是指各欄位的index的話,Edge對象應該可以有相應的對source/target/value的get和set方法,可以對每個欄位進行操作~
             




------------------------------------------------------------------
From:月月 <yuestudyflink@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分別處理,但搜尋好號像沒有找到相關用法。

感謝!


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message