DStream Window Transformation
Transformation
window(windowLength, slideInterval)
Return a new DStream which is computed based on windowed batches of the source DStream.
Last updated
window(windowLength, slideInterval)
Return a new DStream which is computed based on windowed batches of the source DStream.
Last updated