STORM StateQuery方法的使用與底層原理

Stream.stateQuery(TridentState state, Fields inputFields, QueryFunction function, Fields functionFields)方法主要是根據輸入從持久化存儲系統中讀取相應的數據並將其看成一個數據流供Strom Topology使用。下面咱們看一下stateQuery的具體執行過程：php @Override

>>阅读原文<<