Hi spark-enthusiasts,

I am new to spark streaming. I need to fit a moving average model for stock
prices.

How to convert a data stream
{x_1, x_2, x_3, ..., x_n, ...}
into a table with the format:
x_1, x_2, x_3, x_4, x_5, x_6
x_2, x_3, x_4, x_5, x_6, x_7
...
x_{n + 1}, x_{n + 2}, ..., x_{n + 7}
...

Thank you very much!

Reply via email to