RE: Where do we apply windowing operations for a Spark Streaming application created in Diyotta?
Where do we apply windowing operations for a Spark Streaming application created in Diyotta?
On DataStream, In the roll-up transformationà Propertiesà we can configure window attribute, window length and sliding interval time.