Thank you so much for posting your query here. In order to compute cumulative sum, you might want to look at “Moving Aggregation” node, in KNIME. However, in your case to work in Spark environment, I am afraid Spark SQL Query node is the node I can recommend in this case.
If more complexity is involved and Spark SQL query node is out of option, you might want to check out “PySpark Script” node. There are a couple of dedicated nodes to execute PySpark scripts. Hope it helps.
Thank you for your reply.
As you mentioned, I found the answer in pyspark node.
Aggregation was possible using window function and conditional statement in pyspark node