Hi all! While working on a Table Sink implementation for Kudu (key-value store) , we got a bit confused about the expected semantics of UpsertStreamTableSink vs OverwritableTableSink and statements like INSERT vs INSERT OVERWRITE
I am wondering what external operation should each incoming record corresponds to? - Insert (fail on duplicate row) - Delete - Upsert Purely looking at the UpsertStreamTableSink we either upsert or delete so every INSERT is pretty much an INSERT OVERWRITE. Still we cannot use INSERT OVERWRITE if we don't implement OverwritableTableSink. So I wonder what implementing OverwritableTableSink is expected to do for an UpsertStreamTableSink. Can someone please help me clarify this so we can get it right? Thanks Gyula
