@Override
    public TypeInformation<T> getProducedType() {
        return deserializationSchema.getProducedType();
    }
The basic source of Incremental Snapshot framework for datasource, it is based on FLIP-27 and
Watermark Signal Algorithm which supports parallel reading snapshot of table and then continue to
capture data change by streaming reading.
Copy from com.ververica:flink-cdc-base:2.3.0.
inlong-sort/sort-flink/cdc-base/src/main/java/org/apache/inlong/sort/cdc/base/source/IncrementalSource.java