首頁猿問 java如何區(qū)分apache...

java如何區(qū)分apache beam中KV實(shí)例中的兩個(gè)鍵？

Java

慕運(yùn)維8079593 2023-07-19 10:38:52

apache beam 的版本是2.15.0.在此代碼中，類Airport用作 KV 實(shí)例的鍵，最后計(jì)算每個(gè)Airport實(shí)例的平均值。c.output(KV.of(stats.airport,?stats.timestamp));但是apache beam如何在內(nèi)部比較兩個(gè)鍵并返回兩個(gè)實(shí)例是否相同？如果所有類成員具有相同的值，兩個(gè)實(shí)例是否被視為相同？文檔沒有提到兩個(gè)鍵的比較。如果有人能幫助我理解，我將不勝感激。

查看完整描述

1 回答

元芳怎么了

TA貢獻(xiàn)1798條經(jīng)驗(yàn) 獲得超7個(gè)贊

這實(shí)際上在GroupByKey轉(zhuǎn)換文檔中進(jìn)行了解釋，這是在聚合的幕后完成的操作Mean：

不是通過常規(guī) Java?( )K比較類型的兩個(gè)鍵是否相等，而是首先使用輸入的鍵對(duì)每個(gè)鍵進(jìn)行編碼，然后比較編碼的字節(jié)。這允許有效的并行評(píng)估。請(qǐng)注意，這要求鍵的是確定性的（請(qǐng)參閱）。如果密鑰不確定，則在管道構(gòu)建時(shí)會(huì)引發(fā)異常。Object.equalsjava.lang.ObjectCoderPCollectionCoderCoder.verifyDeterministic()Coder

請(qǐng)注意，Mean使用which 是+Combine.PerKey的“簡(jiǎn)寫”?。GroupByKeyCombine.GroupedValues

反對(duì) 回復(fù) 2023-07-19