Apache Flink

Hey Team! I am relatively new to the flink world and having some issues I hope you can help clarify for me. Thanks in advance! I am creating two temporary views, each one like so: `tableEnv.createTemporaryView(tableName, stream)`,  I am then joining the two views by querying them, something like this:

```val resultTable = streamTableEnvironment.sqlQuery(myQuery)

streamTableEnvironment.toChangelogStream(resultTable)```
The issue I am seeing with this is I am getting is that the entire view is republished each time a new message is consumed and thus added to the table. I assume this is the expected behaviour, but is there anyway to configure only publishing the new row in the case of an insert or the updated row in the case of an update?

I can provide more detailed code examples if that would be helpful :gratitude-thank-you:

I do see this: `It is important to note that a continuous query output is always semantically equivalent to the result of the same query executed in batch mode on a snapshot of the input tables.` so seems like this is just the expected behaviour.