paimon-flink/paimon-flink-1.14/src/main/java/org/apache/paimon/flink/source/table/RichTableSource.java [29:51]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class RichTableSource extends BaseTableSource
        implements LookupTableSource, SupportsWatermarkPushDown {

    private final FlinkTableSource source;

    public RichTableSource(FlinkTableSource source) {
        super(source);
        this.source = source;
    }

    @Override
    public RichTableSource copy() {
        return new RichTableSource(source.copy());
    }

    @Override
    public LookupRuntimeProvider getLookupRuntimeProvider(LookupContext context) {
        return source.getLookupRuntimeProvider(context);
    }

    @Override
    public void applyWatermark(WatermarkStrategy<RowData> watermarkStrategy) {
        source.pushWatermark(watermarkStrategy);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



paimon-flink/paimon-flink-1.15/src/main/java/org/apache/paimon/flink/source/table/RichTableSource.java [29:51]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class RichTableSource extends BaseTableSource
        implements LookupTableSource, SupportsWatermarkPushDown {

    private final FlinkTableSource source;

    public RichTableSource(FlinkTableSource source) {
        super(source);
        this.source = source;
    }

    @Override
    public RichTableSource copy() {
        return new RichTableSource(source.copy());
    }

    @Override
    public LookupRuntimeProvider getLookupRuntimeProvider(LookupContext context) {
        return source.getLookupRuntimeProvider(context);
    }

    @Override
    public void applyWatermark(WatermarkStrategy<RowData> watermarkStrategy) {
        source.pushWatermark(watermarkStrategy);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -