stormtrident分布式查詢的問題怎么解決

本篇內(nèi)容主要講解“storm trident分布式查詢的問題怎么解決”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學習“storm trident分布式查詢的問題怎么解決”吧!

創(chuàng)新互聯(lián)專業(yè)為企業(yè)提供固原網(wǎng)站建設、固原做網(wǎng)站、固原網(wǎng)站設計、固原網(wǎng)站制作等企業(yè)網(wǎng)站建設、網(wǎng)頁設計與制作、固原企業(yè)網(wǎng)站模板建站服務，10年固原做網(wǎng)站經(jīng)驗，不只是建網(wǎng)站，更提供有價值的思路和整體網(wǎng)絡服務。

背景是一個很簡單的場景，從一個文檔中讀取句子，然后算出每個單詞出現(xiàn)的次數(shù)，將結(jié)果存入MyMemoryMapState中。

然后做一個分布式查詢：

topology.newDRPCStream("word", drpc)//默認輸入的fields 是"args"
  .stateQuery(wordCounts, new Fields("args"), new MapGet(), new Fields("count"));

drpc調(diào)用的代碼

drpc.execute("word", "first")

結(jié)果出現(xiàn)有時候查詢是null，有時候會有數(shù)據(jù)。比較奇怪，既然內(nèi)存中已經(jīng)有了數(shù)據(jù)，為什么查不出呢？

后來嘗試修改了分布式查詢代碼

topology.newDRPCStream("word", drpc)//默認輸入的fields 是"args"
  .groupBy(new Fields("args"))
  .stateQuery(wordCounts, new Fields("args"), new MapGet(), new Fields("count"));

然后每次都能查詢出結(jié)果。不明白為什么非要groupby 一下。需要了解一下stateQuery的過程！

到此，相信大家對“storm trident分布式查詢的問題怎么解決”有了更深的了解，不妨來實際操作一番吧！這里是創(chuàng)新互聯(lián)網(wǎng)站，更多相關內(nèi)容可以進入相關頻道進行查詢，關注我們，繼續(xù)學習！

名稱欄目：stormtrident分布式查詢的問題怎么解決
文章出自：http://bm7419.com/article6/goceig.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供微信小程序、小程序開發(fā)、定制網(wǎng)站、手機網(wǎng)站建設、定制開發(fā)、用戶體驗

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)