您好,登錄后才能下訂單哦!
這篇文章主要介紹“storm的MemoryMapState有什么用”,在日常操作中,相信很多人在storm的MemoryMapState有什么用問題上存在疑惑,小編查閱了各式資料,整理出簡單好用的操作方法,希望對大家解答”storm的MemoryMapState有什么用”的疑惑有所幫助!接下來,請跟著小編一起來學習吧!
MemoryMapState 是trident中定義的一種state,用來保存storm trident算出的數據。
看一下MemoryMapState 和 State的關系
MemoryMapState 將所有的數據存放在內部靜態屬性
static ConcurrentHashMap<String, Map<List<Object>, Object>> _dbs = new ConcurrentHashMap<String, Map<List<Object>, Object>>();
關于ConcurrentHashMap,可以當作一個線程安全的map
public class ConcurrentHashMap<K, V> extends AbstractMap<K, V> implements ConcurrentMap<K, V>, Serializable
MemoryMapState 對ConcurrentHashMap的操作,主要依靠內部類 MemoryMapStateBacking進行。
static class MemoryMapStateBacking<T> implements IBackingMap<T>, ITupleCollection
storm學到現在,感覺里面都是套子,一個類的方法其實是調用自己一個屬性的方法,很多層。
到此,關于“storm的MemoryMapState有什么用”的學習就結束了,希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習,快去試試吧!若想繼續學習更多相關知識,請繼續關注億速云網站,小編會繼續努力為大家帶來更多實用的文章!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。