Re: [Structured Streaming Query] Calculate Running Avg from Kafka feed using SQL query

rk.apache.org/docs/latest/structured-streaming- > programming-guide.html#output-sinks > > -- > *From:* Aakash Basu <aakash.spark@gmail.com> > *Sent:* Friday, April 6, 2018 3:22:07 AM > *To:* user > *Subject:* Fwd: [Structured Streaming Qu

Re: [Structured Streaming Query] Calculate Running Avg from Kafka feed using SQL query

h Basu <aakash.spark@gmail.com> Sent: Friday, April 6, 2018 3:22:07 AM To: user Subject: Fwd: [Structured Streaming Query] Calculate Running Avg from Kafka feed using SQL query Any help? Need urgent help. Someone please clarify the doubt? -- Forwarded message -- From:

Fwd: [Structured Streaming Query] Calculate Running Avg from Kafka feed using SQL query

Any help? Need urgent help. Someone please clarify the doubt? -- Forwarded message -- From: Aakash Basu <aakash.spark@gmail.com> Date: Mon, Apr 2, 2018 at 1:01 PM Subject: [Structured Streaming Query] Calculate Running Avg from Kafka feed using SQL query To: user

Re: [Structured Streaming Query] Calculate Running Avg from Kafka feed using SQL query

Hi all, The following is the updated code, where I'm getting the avg in a DF, but the collect() function, to store the value as a variable and pass it to the final select query is not working. So, avg is currently a dataframe and not a variable with value stored in it. New code - from

Re: [Structured Streaming Query] Calculate Running Avg from Kafka feed using SQL query

Any help, guys? On Mon, Apr 2, 2018 at 1:01 PM, Aakash Basu wrote: > Hi, > > This is a very interesting requirement, where I am getting stuck at a few > places. > > *Requirement* - > > Col1Col2 > 1 10 > 2 11 > 3 12 > 4

[Structured Streaming Query] Calculate Running Avg from Kafka feed using SQL query

Hi, This is a very interesting requirement, where I am getting stuck at a few places. *Requirement* - Col1Col2 1 10 2 11 3 12 4 13 5 14 *I have to calculate avg of col1 and then divide each row of col2 by that avg. And,