STORM StateQuery方法的使用与底层原理

Stream.stateQuery(TridentState state, Fields inputFields, QueryFunction function, Fields functionFields)方法主要是根据输入从持久化存储系统中读取相应的数据并将其看成一个数据流供Strom Topology使用。下面咱们看一下stateQuery的具体执行过程：php @Override

>>阅读原文<<