ikon的MY TYPE歌词音译

每个Worker在开始计算前，会调用BspServiceWorker类的prepareSuperStep()方法来进行聚集器值的派发和接受其他Workers发送的聚集器值。调用关系如下：

BspServiceWorker类的prepareSuperStep()方法如下：

@Override
public void prepareSuperstep() {
 if (getSuperstep() != INPUT_SUPERSTEP) {
	 /*
	 * aggregatorHandler为WorkerAggregatorHandler类型.可参考上文中MasterAggregatorHandler的类继承关系
	 * workerAggregatorRequestProcessor声明为WorkerAggregatorRequestProcessor（接口）类型，
	 * 实际为NettyWorkerAggregatorRequestProcessor的实例，用于Worker间发送聚集器的值。
	 */
 aggregatorHandler.prepareSuperstep(workerAggregatorRequestProcessor);
 }
}

public void prepareSuperstep(WorkerAggregatorRequestProcessor requestProcessor) {
 AllAggregatorServerData allAggregatorData =
 serviceWorker.getServerData().getAllAggregatorData();
 /**
 * 等待直到Master发送给该Worker的聚集器都已接受完，
 * 返回值为Master发送给该Worker的所有Data（聚集器）
 */
 Iterable dataToDistribute =
 allAggregatorData.getDataFromMasterWhenReady(
  serviceWorker.getMasterInfo());
 
 // 把从Master收到的Data（聚集器）发送给其他所有Workers
 requestProcessor.distributeAggregators(dataToDistribute);

 // 等待直到接受完其他Workers发送给该Workers的聚集器
 allAggregatorData.fillNextSuperstepMapsWhenReady(
 getOtherWorkerIdsSet(), previousAggregatedValueMap,
 currentAggregatorMap);
 // 只是清空allAggregatorServerData的List masterData对象
 // 为下一个超级步接受Master发送的聚集器做准备
 allAggregatorData.reset();
}

 /**
 * Require more permits. This will increase the number of times permits
 * were required. Doesn't wait for permits to become available.
 *
 * @param permits Number of permits to require
 * @param taskId Task id which required permits
 */
 public synchronized void requirePermits(long permits, int taskId) {
 arrivedTaskIds.add(taskId);
 waitingOnPermits += permits;
 notifyAll();
 }

 /**
 * Send aggregators to their owners and in the end to the master
 *
 * @param requestProcessor Request processor for aggregators
 */
 public void finishSuperstep(
 WorkerAggregatorRequestProcessor requestProcessor) {
 OwnerAggregatorServerData ownerAggregatorData =
 serviceWorker.getServerData().getOwnerAggregatorData();
 // First send partial aggregated values to their owners and determine
 // which aggregators belong to this worker
 for (Map.Entry> entry :
 currentAggregatorMap.entrySet()) {
 boolean sent = requestProcessor.sendAggregatedValue(entry.getKey(),
  entry.getValue().getAggregatedValue());
 if (!sent) {
  // If it's my aggregator, add it directly
  ownerAggregatorData.aggregate(entry.getKey(),
  entry.getValue().getAggregatedValue());
 }
 }
 // Flush
 requestProcessor.flush();
 // Wait to receive partial aggregated values from all other workers
 Iterable> myAggregators =
 ownerAggregatorData.getMyAggregatorValuesWhenReady(
  getOtherWorkerIdsSet());

 // Send final aggregated values to master
 AggregatedValueOutputStream aggregatorOutput =
 new AggregatedValueOutputStream();
 for (Map.Entry entry : myAggregators) {
 int currentSize = aggregatorOutput.addAggregator(entry.getKey(),
  entry.getValue());
 if (currentSize > maxBytesPerAggregatorRequest) {
  requestProcessor.sendAggregatedValuesToMaster(
  aggregatorOutput.flush());
 } 
 }
 requestProcessor.sendAggregatedValuesToMaster(aggregatorOutput.flush());
 // Wait for master to receive aggregated values before proceeding
 serviceWorker.getWorkerClient().waitAllRequests();
 ownerAggregatorData.reset();
 }

4. 大同步后，Master调用MasterAggregatorHandler类的prepareSusperStep(masterClient)方法，收集聚集器的值。方法内容如下：

 public void prepareSuperstep(MasterClient masterClient) {

 // 收集上次超级步的聚集值，为master compute 做准备
 for (AggregatorWrapper aggregator : aggregatorMap.values()) {
	// 如果是 Persistent Aggregator，则累加
	if (aggregator.isPersistent()) {
 aggregator.aggregateCurrent(aggregator.getPreviousAggregatedValue());
 }
 aggregator.setPreviousAggregatedValue(
  aggregator.getCurrentAggregatedValue());
 aggregator.resetCurrentAggregator();
 progressable.progress();
 }
 }

备注：Job迭代结束条件有三，满足其一就行：
1) 达到最大迭代次数
2) 没有活跃顶点且没有消息在传递
3) 终止MasterCompute计算

总结：为解决在多个Aggregator条件下，Master成为系统瓶颈的问题。采取了把所有Aggregator派发给某一部分Workers，由这些Workers完成全局的聚集值的计算与发送，Master只需要与这些Workers进行简单数据通信即可，大大降低了Master的工作量。

追加：下面用图示方法说明上述执行过程。

实验条件：

1). 一个Master，四个Worker

2). 两个Aggregators，记为A1和A2。

1. Master把Aggregators发送给Workers，收到Aggregator的Worker就作为该Aggregator的Owner。下图中Master把A1发送给Worker1，A2发送给Worker3.那么Worker1就作为A1的Owner，Worker3就是A2的Owner。该步骤在MasterAggregatorHandler类的finishSuperStep(MasterClient masterClient) 方法中完成，使用的是SendAggregatorsToOwnerRequest 通信协议。注：每个Owner Worker 可能有多个聚集器。

图1 Master分发Aggregator

2. Workers接受Master发送的Aggregator，然后把Aggregator发送给其他Workers。Worker1要把A1分别发送给Worker2、Worker3和Worker4；Worker3要把A2分别发送给Worker1、Worker2和Worker4。该步骤在WorkerAggregatorHandler类的prepareSuperstep( WorkerAggregatorRequestProcessor requestProcessor)方法中完成，使用的是SendAggregatorsToMasterRequest 通信协议。此步骤完成后，每个Worker上都有了聚集器A1和A2（具体为上一个超步的全局最终聚集值）。

3. 每个Worker调用Vertex.compute()方法开始计算，收集本地的Aggregator聚集值。对聚集体A1来说，Worker1、Worker2、Worker3、Worker4的本地聚集值依次记为：

A1₁ 、A1₂、 A1_3、A1_{4；对聚集器A2来说，Worker1、Worker2、Worker3、Worker4的本地聚集值依次记为：}

A2₁ 、A2₂、 A2₃、A2_{4 。计算完成后，每个Worker就要把本地的聚集值发送给聚集器的Owner，聚集器的Owner在接受的时候会合并聚集。那么A11 、A12、 A13、A14要发送给Worker1进行全局聚集得到A1^’，A21 、A22、 A23、A24 要发送给Worker3进行全局聚集得到A2^{’ 。}}

_{^{公式如下：}}

此部分采用的是SendWorkerAggregatorsRequest通信协议。Worker1和Worker3要把汇总的A1和A2的新值：A1’ 和A2’发送给Master，供下一次超级步的MasterCompute.compute()方法使用采用的是SendAggregatorsToMasterRequest通信协议。此部分在WorkerAggregatorHandler类的finishSuperstep( WorkerAggregatorRequestProcessor requestProcessor)方法中完成。过程如下图所示：

4. Master收到Worker1发送的A1’ 和Woker3发送的A2’后，此步骤在MasterAggregatorHandler类的prepareSusperStep(masterClient)方法中完成。然后调用MasterCompute.compute()方法，此方法可能会修改聚集器的值，如得到A1’’和A2’’。在masterCompute.compute()方法内若根据聚集器的值调用了MasterCompute类的haltCompute()方法来终止MaterCompute，则表明要结束整个Job。那么Master就会通知所有Workers要结束整个作业；在该方法内若没有调用MasterCompute类的haltCompute()方法，则回到步骤1继续进行迭代，继续把A1’’发送给Worker1，A2’’发送给Worker3。

完！

本人原创，转载请注明出处！欢迎大家加入Giraph 技术交流群： 228591158

热心网友 时间：2022-04-14 19:33

MY TYPE
知元:诺嫩 涅 崔hiang作gio 涅 崔hiang作gio
马拉起 啊那都 呢gi米 哇
摸里不拖 白个噶几 塔
韩彬:诺嫩 涅 崔hiang作gio 难 诺了 啵mion
噶起够 西破所 安达里 那
恰gi qion噶几都 seng噶gi那
pow
RAP韩彬:噶嫩 拍mog 啊嘞 on东哇
哇qion seing 丝gi尼金涅 玩表看 丑哇
晒加 肯 的喊 卡地gon 啊嘞
读 多咯金 gin seng摸里噶 cam 够哇
韩彬:书出本 nun呜思嗯都 mom 跌里嫩 得喊 摸思嗯都
rap韩彬:耶啵kie曼 啵一够 卡思米 吗 多lio
wuei 一接呀 那他那你 you are my 崔hiang作gio
振焕:oh oh 诺耶 卡nio林 米所
诺了 啵嫩 nun比都
很恰be 跌噶 哦所
含西都 几路含 读里 哦所perfect
俊会:Oh oh 诶giu 所gin 木所里
oh oh 噶噶我几嫩 屋里
wuei 一接呀 那他那所
得地哦 撒浪一 恰加哇所
知元:诺嫩 涅 崔hiang作gio 涅 崔hiang作gio
马拉起 啊那都 呢gi米 哇
摸里不拖 白个噶几 塔
韩彬:诺嫩 涅 崔hiang作gio 难 诺了 啵mion
噶起够 西破所 安达里 那
恰gi qion噶几都 seng噶gi那 pow
知元:a girl 加西 曼 猪 木路给
个 噶起蓝 吗吐嫩 哦地所 都 被我跌
You work and walk and spit words like a boss wonder women
hion西怕嫩 诺耶 哟送西落嗯
知元:oh 呢gim 作gim 呢gim
都mon噶 咩红作gin nun比 切咩lio dwei
son 谢含 个son gi
RAP知元:都摸噶 哦zong zong 含mon几
i like it babe
东赫:oh oh 诺耶 卡nio林 米所
诺了 啵嫩 nun比都
很恰be 跌噶 哦所
含西都 几路含 读里 哦所perfect
允亨:Oh oh 诶giu 所gin 木所里
oh oh 噶噶我几嫩 屋里
wuei 一接呀 那他那所
得地哦 撒浪一 恰加我所
知元:诺嫩 涅 崔hiang作gio 涅 崔hiang作gio
马拉起 啊那都 呢gi米 哇
摸里不拖 白个噶几 塔
韩彬:诺嫩 涅 崔hiang作gio 难 诺了 啵mion
噶起够 西破所 安达里 那
恰gi qion噶几都 seng噶gi那 pow
粲右:男 你噶 从曼 出哇
都噶跟 哈pun哈嫩 摸思噶几都
涅 丝带里呀
俊会:哦 吗额米 咋 吗咋
涅 噶思米 啵擦哦啦
你噶 那 不了 跌吗达
一噶耶 呜思米 个你几 啦那
韩彬:oh girl you know that I love you
知元:诺嫩 涅 崔hiang作gio 涅 崔hiang作gio
马拉起 啊那都 呢gi米 哇
摸里不拖 白个噶几 塔
韩彬:诺嫩 涅 崔hiang作gio 难 诺了 啵mion
噶起够 西破所 安达里 那
恰gi qion噶几都 seng噶gi那
pow
男 你噶 从曼 出哇（oh baby baby wo~）
都噶跟 哈pun哈嫩 摸思噶几都
涅 丝带里呀
男 你噶 从曼 出哇
都噶跟 哈pun哈嫩 摸思噶几都
‌涅 丝带里呀

自己做的 望采纳

热心网友 时间：2022-04-14 20:51

no能内 去航求gio
内 去航求gio
嘛啦几昂那豆 奴ki米哇
魔力不透 百噶几大
no能内 去航求gio
囊no内啵谬
噶气go西破 桑大你那
卡gi就 噶几斗sin噶你那
POW（怕喔）
噶能 百莫 啊咧 哦动画 哇
囧嗯 sexy gi里几能 完表尅 囧话
塞加肯 的他 噶地go 阿拉痛
豆咯金 kim sei魔力噶 穷豆哇
素囧嘣 努能孙豆
莫 给力能豆 他 莫斯豆
耶啵给慢 啵一go
噶四米慢 豆流
为 一介诶 那疼豆流为
You're My 去航求gio
Wo Oh no也卡了里米嗖
Wo Oh 那了啵能奴婢豆
哼驾崩得噶哦不嗖
航西都 几录哇疼你哦不嗖 Perfect
WO Oh 一go 色key莫素滴
WO Oh 噶gin喔金能奴婢
为 一介诶 拉他哇嗖
特地哟 撒浪嗯掐架哇嗖
no能内 去航求gio
内 去航求gio
嘛啦几昂那豆 奴ki米哇
魔力不透 百噶几大
no能内 去航求gio
囊no内啵谬
噶气go西破桑大你那
卡gi就噶几斗sin噶你那
POW（怕喔）
诶girl 强西 买jo 莫了给
各 噶气啦 嘛去龙
no哦地嗖 豆得我得
You Work And Walk And Spit Worlds Like A Boss
Wonder Woman 航西怕能 no诶 噶嗖四龙嗯
Oh 能gin九gi能gin
豆mong噶 魅后就gi努比起 魅聊的
送sei黑 gi嗖给
豆mong噶 啊囧囧哈 mong气
I Like Baby
Wo Oh no也卡了里米嗖
Wo Oh 那了啵能奴婢豆
哼驾崩得噶哦不嗖
航西都 几录哇疼你哦不嗖 Perfect
WO Oh 一go 色key莫素滴
WO Oh 噶gin喔金能奴婢
为 一介诶 拉他哇嗖
特地哟 撒浪嗯掐架哇嗖
no能内 去航求gio
内 去航求gio
嘛啦几昂那豆 奴ki米哇
魔力不透 百噶几大
no能内 去航求gio
囊no内啵谬
噶气go西破桑大你那
卡gi就噶几斗sin噶你那
POW（怕喔）
囊 你噶 穷慢 求哇
豆噶gin 哈pong 哈登莫斯噶几豆 内style里呀
Oh 嘛 嗯米掐吗掐
内噶 素米啵掐啦
你噶内 扑了得马达
一噶里哟四米 各里几啦那
Oh Girl You Konw That I Love You
no能内 去航求gio
内 去航求gio
嘛啦几昂那豆 奴ki米哇
魔力不透 百噶几大
no能内 去航求gio
囊no内啵谬
噶气go西破桑大你那
卡gi就噶几斗sin噶你那
POW（怕喔）
囊 你噶 穷慢 求哇
豆噶gin 哈pong 哈登莫斯噶几豆 内style里呀
囊 你噶 穷慢 求哇
豆噶gin 哈pong 哈登莫斯噶几豆 内style里呀

热心网友 时间：2022-04-14 22:26

(中文汉字)

诺嫩捏 去 hiang做kyo 捏cwi hiang做kyo
吗啦 几啊那多 呢gi米哇
莫里不脱 百 歌噶几塔
诺嫩捏 去hiang做kyo 男诺 日啵mion
噶几 go西破所安 大里那
擦gi com噶 几多seng 噶gi那
Pow
噶嫩百莫噶咧wm动话哇
Qong涩思gi你几你玩pyo干做话
撒扎根得谈噶第go那咧
度多罗金gin僧莫里噶camgo哇
苏组喷弄乌森多mong跌里嫩得谈莫思多
也be gye蛮啵里go卡思米吗多lyo
Wer以接呀那大那你 you are my去hiang做kyo
Oh oh诺也卡lyo林米所
Oh oh那乐啵嫩弄皮多
很扎per跌噶哦不所
韩西多几路还得米哦不所perfect
Oh oh额kyo所gin莫所里
Oh oh卡噶我几嫩屋里
Wer以接呀那大那所
得第哦撒浪以擦扎哇所
诺嫩内去hiang做kyo内去hiang做kyo
那啦几啊那多呢gi米哇
莫里不脱百歌噶几塔
诺嗯呢内去hiang做kyo男诺乐啵mion
卡几go西破所安大里那
卡几qon噶几多僧噶gi那
Pow
A girl zam西买总木乐gye
可噶气蓝买度嫩哦第所所pie我跌
You work and walk and spit words like a boss
Wonder woman hyon西怕嫩诺也
哟suong思罗wm
Oh 呢gin做gin呢gin
多mon噶咩ho扎gin弄皮且咩溜twer
Som涩韩可送gi
多mon噶哦总总韩mom几 I like it babe
Oh oh诺也卡lyo林米所
Oh oh那乐啵嫩弄皮多
很扎per跌噶哦不所
韩西都几路还得米哦不所perfect
Oh oh额kyo所gin莫所里
Oh oh卡噶我几嫩屋里
Wer以接呀那大那所
得第哦撒浪以擦扎哇所
诺嫩内去hiang做kyo内去hiang做kyo
吗啦几啊那多呢gi米哇
莫里不脱百歌噶几塔
诺嫩内去hiang做kyo男诺乐啵mion
卡几go西破所安大里那
扎gi zon噶几多僧噶gi那
Pow
男你噶从买做哇
多卡歌吗普吗嫩莫森噶几多
内思大以里呀
哦吗额米才吗扎
内卡思米破擦乌啦
你噶乃不乐跌吗大
以噶诶乌思米歌你几啦那
Oh girl you know that I love you
诺嫩内去hiang做kyo内去hiang做kyo
吗啦几啊那多呢gi米哇
莫里不脱百歌噶几塔
诺嫩内去hiang做kyo男诺乐啵mion
卡几go西破所安大里那
扎gi zon噶几多僧噶gi那
Pow
男你噶从买做哇
多卡歌吗普吗嫩莫思噶几多
塔内思大以里呀
男你噶从买做哇
多卡歌吗普吗嫩莫思噶几多
塔内思大以里呀

（中文拼音）知元：no nen nei qu hiang zo gio nei qu hiang zo gio
ma la ji a na do ne gi mi wa
mo li bu to ba ge ga ji da

韩彬：no nen nei qu hiang zo gio nan no le bo mion
ga ji go xi po so an da li na
za gi zon ga ji do seing ga gi na
pow
ga nen ba mo a lei un dong hua wa
cong sei si ki ni jin ei wan bio kan zo hua
do lo jin gin seing mo li ga can go wa
su zu ben nu nu sen do mong dei li nen de tan mo si do
yebe gei man bo i go ga si mi ma do lio
weiI zei ya ya na ta na ni you”re my qu hiang zo gio

振焕：oh oh no ei ga nio lin mi so
ohoh na le bo nen nun bi do
henza be dei ga o so
hanxi do ji lu ha te mi o so perfect

俊辉：oh oh ei gio so gin mo so li
ohoh ga ga wo ji nen u li
weii zei ya na ta na so
dedi o sa lang i ca za wa so

知元：no nen nei qu hiang zo gio nei qu hiang zo gio
mala ji a na do ne gi mi wa
moli bu to ba ge ga ji da

韩彬：no nen nei qu hiang zo gio nan no le bo mion
gaji go xi po so an da li na
zagi zon ga ji do seing ga gi na
pow

知元:A girl zan xi ma jon mu le gei
gega qi lan ma tu nen o di so do bei wo dei
Youwork and walk andspit words like a boss
wonderwomen hion xi pa nen no ei yo song si loun
Ohne gin zo gin ne gin
domwon ga mei ho zo gin nun bi cei mei lio dwei
sonsei hang e son gi
domwon ga o zong zong han mon ji i like itbabe

东赫：oh oh no ei ga nio lin mi so
ohoh na le bon en nun bi do
henza be dei ga o so
hanxi do ji lu ha te mi o so perfect

允亨：oh oh ei gio so gin mo so li
ohoh ga ga wo ji nen u li
weii zei ya na tan a so
dedi o sa lang i ca za wa so

知元：no nen nei qu hiang zo gio nei qu hiang zo gio
mala ji a na do ne gi mi wa
moli bu to ba ge ga li da

韩彬：no nen nei qu hiang zo gio nan no le bo mion
gaji go xi po so an da li na
zagi zon ga ji do seing ga gi na
pow

粲右:nan nig a zong ma jo a
Doga gen ha pun ha nen mo si ga ji do
neisi ta li ya

俊会:o ma e mi za ma za
neiga si mi bo ca o la
niga na bu le dei ma da
ige ei u se mi ge ni ji a na

韩彬:Oh girl you know that I love you

知元：no nen nei qu hiang zo gio nei qu hiang zogio
mala ji a na do ne gi mi wa
moli bu to ba ge ga ji da

韩彬：no nen nei qu hiang zo gio nan no le bo mion
gaji go xi po so an da li na
zagi zon ga ji do seing ga gi na
pow

合：nan ni ga zong ma jo a
doga gen ha pu ma nen mo sig a ji do
danei si ta i li ya

nannig a zong ma jo a
doga gen ha pu ma nen mo sig a ji do
danei sit a i li ya