support windowed dstream
support updateStateByKey