apache spark - Is the DStream return by updateStateByKey function only contains one RDD? -
is dstream return updatestatebykey function contains 1 rdd? if not,under circumstances dstream contains more 1 rdd?
it contains rdd every batch. dstream returned updatestatebykey "state" dstream. can still view dstream normal dstream though. every batch, rdd representing latest state (key-value pairs) according update function pass in updatestatebykey.
Comments
Post a Comment