How does this compare to Spark structured streaming? That too allows writing SQL on streams and having the state update incrementally.