Hi Fan,
It’s not hard to implement an “InMemoryTableSink” for debugging use by
yourself.
The main part should be a SinkFunction that deals with Tuple
records. You can either show the changelog (the record itself) or print the
materialized result (e.g., a result list) for each received item.
Hi everyone,
Recently I am using Flink SQL API to test some SQL queries. I run a small
dataset and output the result to CsvTableSink so that I can easily open the
file and verify the result by eye. But unfortunately, I found that
CsvTableSink does not support retraction message and thus I could no
